aboutsummaryrefslogtreecommitdiffstats
path: root/src/libs/3rdparty/botan/src/lib/filters/threaded_fork.cpp
diff options
context:
space:
mode:
authorChristian Kandeler <christian.kandeler@qt.io>2018-11-23 11:07:57 +0100
committerChristian Kandeler <christian.kandeler@qt.io>2018-12-13 15:10:11 +0000
commitd7178b88c4b2572fb83b28f8178940766216deed (patch)
tree861eb8069fb97c8e8e79f56cb8f88f05126639fc /src/libs/3rdparty/botan/src/lib/filters/threaded_fork.cpp
parent030d4d01084b04af361f07dd6360dfad8e2cc19c (diff)
SSH: Use OpenSSH tools
... instead of our own SSH library. Advantages: - Full compatibility with OpenSSH behavior guaranteed. - Minimal maintenance effort. - Less code to build. - Big chunk of 3rd party sources can be removed from our repository. One the downside, Windows users now need to install OpenSSH for RemoteLinux support. Hoewever, people doing embedded development probably have it installed anyway. [ChangeLog] Switched SSH backend to OpenSSH Fixes: QTCREATORBUG-15744 Fixes: QTCREATORBUG-15807 Fixes: QTCREATORBUG-19306 Fixes: QTCREATORBUG-20210 Change-Id: Ifcfefdd39401e45ba1f4aca35d2c5bf7046c7aab Reviewed-by: Eike Ziller <eike.ziller@qt.io> Reviewed-by: Ulf Hermann <ulf.hermann@qt.io>
Diffstat (limited to 'src/libs/3rdparty/botan/src/lib/filters/threaded_fork.cpp')
-rw-r--r--src/libs/3rdparty/botan/src/lib/filters/threaded_fork.cpp153
1 files changed, 0 insertions, 153 deletions
diff --git a/src/libs/3rdparty/botan/src/lib/filters/threaded_fork.cpp b/src/libs/3rdparty/botan/src/lib/filters/threaded_fork.cpp
deleted file mode 100644
index 35ea9410955..00000000000
--- a/src/libs/3rdparty/botan/src/lib/filters/threaded_fork.cpp
+++ /dev/null
@@ -1,153 +0,0 @@
-/*
-* Threaded Fork
-* (C) 2013 Joel Low
-* 2013 Jack Lloyd
-*
-* Botan is released under the Simplified BSD License (see license.txt)
-*/
-
-#include <botan/basefilt.h>
-
-#if defined(BOTAN_HAS_THREAD_UTILS)
-
-#include <botan/internal/semaphore.h>
-#include <botan/internal/barrier.h>
-#include <functional>
-
-namespace Botan {
-
-struct Threaded_Fork_Data
- {
- /*
- * Semaphore for indicating that there is work to be done (or to
- * quit)
- */
- Semaphore m_input_ready_semaphore;
-
- /*
- * Synchronises all threads to complete processing data in lock-step.
- */
- Barrier m_input_complete_barrier;
-
- /*
- * The work that needs to be done. This should be only when the threads
- * are NOT running (i.e. before notifying the work condition, after
- * the input_complete_barrier has reset.)
- */
- const uint8_t* m_input = nullptr;
-
- /*
- * The length of the work that needs to be done.
- */
- size_t m_input_length = 0;
- };
-
-/*
-* Threaded_Fork constructor
-*/
-Threaded_Fork::Threaded_Fork(Filter* f1, Filter* f2, Filter* f3, Filter* f4) :
- Fork(nullptr, static_cast<size_t>(0)),
- m_thread_data(new Threaded_Fork_Data)
- {
- Filter* filters[4] = { f1, f2, f3, f4 };
- set_next(filters, 4);
- }
-
-/*
-* Threaded_Fork constructor
-*/
-Threaded_Fork::Threaded_Fork(Filter* filters[], size_t count) :
- Fork(nullptr, static_cast<size_t>(0)),
- m_thread_data(new Threaded_Fork_Data)
- {
- set_next(filters, count);
- }
-
-Threaded_Fork::~Threaded_Fork()
- {
- m_thread_data->m_input = nullptr;
- m_thread_data->m_input_length = 0;
-
- m_thread_data->m_input_ready_semaphore.release(m_threads.size());
-
- for(auto& thread : m_threads)
- thread->join();
- }
-
-std::string Threaded_Fork::name() const
- {
- return "Threaded Fork";
- }
-
-void Threaded_Fork::set_next(Filter* f[], size_t n)
- {
- Fork::set_next(f, n);
- n = m_next.size();
-
- if(n < m_threads.size())
- m_threads.resize(n);
- else
- {
- m_threads.reserve(n);
- for(size_t i = m_threads.size(); i != n; ++i)
- {
- m_threads.push_back(
- std::shared_ptr<std::thread>(
- new std::thread(
- std::bind(&Threaded_Fork::thread_entry, this, m_next[i]))));
- }
- }
- }
-
-void Threaded_Fork::send(const uint8_t input[], size_t length)
- {
- if(m_write_queue.size())
- thread_delegate_work(m_write_queue.data(), m_write_queue.size());
- thread_delegate_work(input, length);
-
- bool nothing_attached = true;
- for(size_t j = 0; j != total_ports(); ++j)
- if(m_next[j])
- nothing_attached = false;
-
- if(nothing_attached)
- m_write_queue += std::make_pair(input, length);
- else
- m_write_queue.clear();
- }
-
-void Threaded_Fork::thread_delegate_work(const uint8_t input[], size_t length)
- {
- //Set the data to do.
- m_thread_data->m_input = input;
- m_thread_data->m_input_length = length;
-
- //Let the workers start processing.
- m_thread_data->m_input_complete_barrier.wait(total_ports() + 1);
- m_thread_data->m_input_ready_semaphore.release(total_ports());
-
- //Wait for all the filters to finish processing.
- m_thread_data->m_input_complete_barrier.sync();
-
- //Reset the thread data
- m_thread_data->m_input = nullptr;
- m_thread_data->m_input_length = 0;
- }
-
-void Threaded_Fork::thread_entry(Filter* filter)
- {
- while(true)
- {
- m_thread_data->m_input_ready_semaphore.acquire();
-
- if(!m_thread_data->m_input)
- break;
-
- filter->write(m_thread_data->m_input, m_thread_data->m_input_length);
- m_thread_data->m_input_complete_barrier.sync();
- }
- }
-
-}
-
-#endif