Removed ACE dependencies from LogWorker

src/server/shared/Logging/Log.cpp

@@ -273,7 +273,7 @@ void Log::write(LogMessage* msg) const
     msg->text.append("\n");
 
     if (worker)
-        worker->enqueue(new LogOperation(logger, msg));
+        worker->enqueue(*(new LogOperation(logger, msg)));
     else
     {
         logger->write(*msg);

src/server/shared/Logging/Log.h

@@ -23,7 +23,7 @@
 #include "Appender.h"
 #include "Logger.h"
 #include "LogWorker.h"
-
+#include <stdarg.h>
 #include <unordered_map>
 #include <string>
 

src/server/shared/Logging/LogWorker.cpp

@@ -17,29 +17,22 @@
 
 #include "LogWorker.h"
 
-LogWorker::LogWorker()
-    : m_queue(HIGH_WATERMARK, LOW_WATERMARK)
-{
-    ACE_Task_Base::activate(THR_NEW_LWP | THR_JOINABLE | THR_INHERIT_SCHED, 1);
-}
-
 LogWorker::~LogWorker()
 {
-    m_queue.deactivate();
-    wait();
+    m_queue.cancel();
 }
 
-int LogWorker::enqueue(LogOperation* op)
+void LogWorker::enqueue(LogOperation& op)
 {
-    return m_queue.enqueue(op);
+    return m_queue.add(op);
 }
 
 int LogWorker::svc()
 {
     while (1)
     {
-        LogOperation* request;
-        if (m_queue.dequeue(request) == -1)
+        LogOperation* request = nullptr;
+        if (!m_queue.next(*request))
             break;
 
         request->call();

src/server/shared/Logging/LogWorker.h

@@ -19,29 +19,19 @@
 #define LOGWORKER_H
 
 #include "LogOperation.h"
+#include "LockedQueue.h"
 
-#include <ace/Task.h>
-#include <ace/Activation_Queue.h>
-
-class LogWorker: protected ACE_Task_Base
+class LogWorker
 {
     public:
-        LogWorker();
+        LogWorker() {};
         ~LogWorker();
 
-        typedef ACE_Message_Queue_Ex<LogOperation, ACE_MT_SYNCH> LogMessageQueueType;
-
-        enum
-        {
-            HIGH_WATERMARK = 8 * 1024 * 1024,
-            LOW_WATERMARK  = 8 * 1024 * 1024
-        };
-
-        int enqueue(LogOperation *op);
+        void enqueue(LogOperation& op);
 
     private:
         virtual int svc();
-        LogMessageQueueType m_queue;
+        LockedQueue<LogOperation> m_queue;
 };
 
 #endif