diff options
Diffstat (limited to 'src/libs/client')
| -rw-r--r-- | src/libs/client/ThreadedSigClientInterface.cpp | 5 | ||||
| -rw-r--r-- | src/libs/client/ThreadedSigClientInterface.h | 6 |
2 files changed, 6 insertions, 5 deletions
diff --git a/src/libs/client/ThreadedSigClientInterface.cpp b/src/libs/client/ThreadedSigClientInterface.cpp index bbe336a6..152f94a6 100644 --- a/src/libs/client/ThreadedSigClientInterface.cpp +++ b/src/libs/client/ThreadedSigClientInterface.cpp @@ -61,9 +61,10 @@ ThreadedSigClientInterface::emit_signals() // thread indefinitely while processing continually arriving events const size_t limit = _sigs.capacity(); size_t num_processed = 0; - while (!_sigs.is_empty() && num_processed++ < limit) { + while (!_sigs.empty() && num_processed++ < limit) { //printf("emit %zu\n", _sigs.fill()); - Closure& ev = _sigs.pop(); + Closure& ev = _sigs.front(); + _sigs.pop(); ev(); ev.disconnect(); } diff --git a/src/libs/client/ThreadedSigClientInterface.h b/src/libs/client/ThreadedSigClientInterface.h index e286fc95..0a2b8652 100644 --- a/src/libs/client/ThreadedSigClientInterface.h +++ b/src/libs/client/ThreadedSigClientInterface.h @@ -22,7 +22,7 @@ #include <sigc++/sigc++.h> #include "interface/ClientInterface.h" #include "SigClientInterface.h" -#include "raul/Queue.h" +#include "raul/SRSWQueue.h" #include "raul/Atom.h" using std::string; @@ -138,8 +138,8 @@ private: bool _enabled; - Queue<Closure> _sigs; - uint32_t _num_plugins; + SRSWQueue<Closure> _sigs; + uint32_t _num_plugins; sigc::slot<void> bundle_begin_slot; sigc::slot<void> bundle_end_slot; |