Log: replace spsc queue by Threadsafequeue

The function pushing messages into the queue gets called from more than one
thread, which is illegal according to boost::lockfree documentation.

2 files changed, 3 insertions, 7 deletions

diff --git a/src/Log.cpp b/src/Log.cpp
index 4780f58..0792fcf 100644
--- a/src/Log.cpp
+++ b/src/Log.cpp
@@ -77,9 +77,7 @@ void Logger::io_process()
     set_thread_name("logger");
     while (1) {
         log_message_t m;
-        while (m_message_queue.pop(m) == false) {
-            std::this_thread::sleep_for(std::chrono::milliseconds(10));
-        }
+        m_message_queue.wait_and_pop(m);
 
         auto message = m.message;
 
diff --git a/src/Log.h b/src/Log.h
index bf1d5e4..ae252a6 100644
--- a/src/Log.h
+++ b/src/Log.h
@@ -43,7 +43,7 @@
 #include <map>
 #include <mutex>
 #include <thread>
-#include <boost/lockfree/spsc_queue.hpp>
+#include "ThreadsafeQueue.h"
 
 #define SYSLOG_IDENT "ODR-DabMod"
 #define SYSLOG_FACILITY LOG_LOCAL0
@@ -179,9 +179,7 @@ class Logger {
     private:
         std::list<LogBackend*> backends;
 
-        boost::lockfree::spsc_queue<
-            log_message_t,
-            boost::lockfree::capacity<80> > m_message_queue;
+        ThreadsafeQueue<log_message_t> m_message_queue;
         std::thread m_io_thread;
         std::mutex m_cerr_mutex;
 };