ThreadsafeQueue: add wakeup event instead of custom termination markers

This avoids the issue that the ~SDR termination marker doesn't reach the
consumer because it's still prebuffering

1 files changed, 4 insertions, 4 deletions

diff --git a/src/MemlessPoly.cpp b/src/MemlessPoly.cpp
index 1e19071..88a68bc 100644
--- a/src/MemlessPoly.cpp
+++ b/src/MemlessPoly.cpp
@@ -280,9 +280,10 @@ void MemlessPoly::worker_thread(MemlessPoly::worker_t *workerdata)
 
     while (true) {
         worker_t::input_data_t in_data;
-        workerdata->in_queue.wait_and_pop(in_data);
-
-        if (in_data.terminate) {
+        try {
+            workerdata->in_queue.wait_and_pop(in_data);
+        }
+        catch (const ThreadsafeQueueWakeup&) {
             break;
         }
 
@@ -322,7 +323,6 @@ int MemlessPoly::internal_process(Buffer* const dataIn, Buffer* dataOut)
             size_t start = 0;
             for (auto& worker : m_workers) {
                 worker_t::input_data_t dat;
-                dat.terminate = false;
                 dat.dpd_type = m_dpd_type;
                 dat.lut_scalefactor = m_lut_scalefactor;
                 dat.lut = m_lut.data();