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 35ea941095..0000000000
--- 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