Apply b1fc144 from common

6 files changed, 73 insertions, 21 deletions

diff --git a/Makefile.am b/Makefile.am
index e9001d6..2ae6a43 100644
--- a/Makefile.am
+++ b/Makefile.am
@@ -143,6 +143,7 @@ odr_dabmux_SOURCES  =src/DabMux.cpp \
 					 lib/crc.c \
 					 lib/ClockTAI.h \
 					 lib/ClockTAI.cpp \
+					 lib/Globals.cpp \
 					 lib/Log.h \
 					 lib/Log.cpp \
 					 lib/RemoteControl.cpp \
@@ -185,8 +186,11 @@ zmqinput_keygen_CFLAGS   = -Wall $(GITVERSION_FLAGS) $(ZMQ_CPPFLAGS)
 odr_zmq2farsync_SOURCES  = src/zmq2farsync/zmq2farsync.cpp \
 						   src/dabOutput/dabOutput.h \
 						   src/dabOutput/dabOutputRaw.cpp \
+						   lib/Globals.cpp \
 						   lib/Log.h \
 						   lib/Log.cpp \
+						   lib/RemoteControl.cpp \
+						   lib/RemoteControl.h \
 						   lib/zmq.hpp
 
 odr_zmq2farsync_LDADD    = $(ZMQ_LIBS)
@@ -212,8 +216,11 @@ odr_zmq2edi_SOURCES  = src/zmq2edi/zmq2edi.cpp \
 					   lib/edioutput/TagPacket.h \
 					   lib/edioutput/Transport.cpp \
 					   lib/edioutput/Transport.h \
+					   lib/Globals.cpp \
 					   lib/Log.h \
 					   lib/Log.cpp \
+					   lib/RemoteControl.cpp \
+					   lib/RemoteControl.h \
 					   lib/crc.h \
 					   lib/crc.c \
 					   lib/ReedSolomon.h \
diff --git a/lib/Globals.cpp b/lib/Globals.cpp
new file mode 100644
index 0000000..6be26ec
--- /dev/null
+++ b/lib/Globals.cpp
@@ -0,0 +1,36 @@
+/*
+   Copyright (C) 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012
+   Her Majesty the Queen in Right of Canada (Communications Research
+   Center Canada)
+
+   Copyright (C) 2019
+   Matthias P. Braendli, matthias.braendli@mpb.li
+
+    http://www.opendigitalradio.org
+ */
+/*
+   This file is part of the ODR-mmbTools.
+
+   This program is free software: you can redistribute it and/or modify
+   it under the terms of the GNU General Public License as
+   published by the Free Software Foundation, either version 3 of the
+   License, or (at your option) any later version.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+/* Ensure construction and destruction of static globals in the right order */
+
+#include "Log.h"
+#include "RemoteControl.h"
+
+// the RC needs logging, and needs to be initialised later.
+Logger etiLog;
+RemoteControllers rcs;
+
diff --git a/lib/Log.cpp b/lib/Log.cpp
index 2417f3a..abbd69a 100644
--- a/lib/Log.cpp
+++ b/lib/Log.cpp
@@ -34,12 +34,23 @@
 
 using namespace std;
 
-/* etiLog is a singleton used in all parts of the program to output log messages.
- */
-Logger etiLog;
+
+Logger::Logger()
+{
+    m_io_thread = std::thread(&Logger::io_process, this);
+}
+
+Logger::~Logger() {
+    m_message_queue.trigger_wakeup();
+    m_io_thread.join();
+
+    std::lock_guard<std::mutex> guard(m_backend_mutex);
+    backends.clear();
+}
 
 void Logger::register_backend(std::shared_ptr<LogBackend> backend)
 {
+    std::lock_guard<std::mutex> guard(m_backend_mutex);
     backends.push_back(backend);
 }
 
@@ -75,7 +86,7 @@ void Logger::logstr(log_level_t level, std::string&& message)
 {
     if (level == discard) {
         return;
-	}
+    }
 
     log_message_t m(level, move(message));
     m_message_queue.push(move(m));
@@ -101,13 +112,15 @@ void Logger::io_process()
             message.resize(message.length()-1);
         }
 
-        for (auto &backend : backends) {
-            backend->log(m.level, message);
-        }
+        {
+            std::lock_guard<std::mutex> guard(m_backend_mutex);
+            for (auto &backend : backends) {
+                backend->log(m.level, message);
+            }
 
-        if (m.level != log_level_t::trace) {
-            std::lock_guard<std::mutex> guard(m_cerr_mutex);
-            std::cerr << levels_as_str[m.level] << " " << message << std::endl;
+            if (m.level != log_level_t::trace) {
+                std::cerr << levels_as_str[m.level] << " " << message << std::endl;
+            }
         }
     }
 }
diff --git a/lib/Log.h b/lib/Log.h
index d5c39e0..f20e698 100644
--- a/lib/Log.h
+++ b/lib/Log.h
@@ -133,16 +133,10 @@ struct log_message_t {
 
 class Logger {
     public:
-        Logger() {
-            m_io_thread = std::thread(&Logger::io_process, this);
-        }
-
+        Logger();
         Logger(const Logger& other) = delete;
         const Logger& operator=(const Logger& other) = delete;
-        ~Logger() {
-            m_message_queue.trigger_wakeup();
-            m_io_thread.join();
-        }
+        ~Logger();
 
         void register_backend(std::shared_ptr<LogBackend> backend);
 
@@ -163,9 +157,11 @@ class Logger {
 
         ThreadsafeQueue<log_message_t> m_message_queue;
         std::thread m_io_thread;
-        std::mutex m_cerr_mutex;
+        std::mutex m_backend_mutex;
 };
 
+/* etiLog is a singleton used in all parts of the program to output log messages.
+ * It is constructed in Globals.cpp */
 extern Logger etiLog;
 
 // Accumulate a line of logs, using same syntax as stringstream
diff --git a/lib/RemoteControl.cpp b/lib/RemoteControl.cpp
index 878af59..4adb90c 100644
--- a/lib/RemoteControl.cpp
+++ b/lib/RemoteControl.cpp
@@ -32,8 +32,6 @@
 
 using namespace std;
 
-RemoteControllers rcs;
-
 RemoteControllerTelnet::~RemoteControllerTelnet()
 {
     m_active = false;
diff --git a/lib/RemoteControl.h b/lib/RemoteControl.h
index bd88f82..2358b3a 100644
--- a/lib/RemoteControl.h
+++ b/lib/RemoteControl.h
@@ -149,6 +149,8 @@ class RemoteControllers {
         std::list<std::shared_ptr<BaseRemoteController> > m_controllers;
 };
 
+/* rcs is a singleton used in all parts of the program to interact with the RC.
+ * It is constructed in Globals.cpp */
 extern RemoteControllers rcs;
 
 /* Implements a Remote controller based on a simple telnet CLI