diff options
author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2018-02-19 11:52:39 +0100 |
---|---|---|
committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2018-02-19 11:53:39 +0100 |
commit | 039f82969aff73749ff50e9d65950a85509fde0c (patch) | |
tree | 25709b273d3af7b47201c40514ab3ef54dd29477 /src/ManagementServer.h | |
parent | a48f80b33a9859da52dfbcebf0bc69e80c1bb8e5 (diff) | |
download | dabmux-039f82969aff73749ff50e9d65950a85509fde0c.tar.gz dabmux-039f82969aff73749ff50e9d65950a85509fde0c.tar.bz2 dabmux-039f82969aff73749ff50e9d65950a85509fde0c.zip |
ManagementServer: Use zmq poller instead of nonblock and usleep
Diffstat (limited to 'src/ManagementServer.h')
-rw-r--r-- | src/ManagementServer.h | 25 |
1 files changed, 4 insertions, 21 deletions
diff --git a/src/ManagementServer.h b/src/ManagementServer.h index f8d722e..c0b50e7 100644 --- a/src/ManagementServer.h +++ b/src/ManagementServer.h @@ -135,29 +135,12 @@ class InputStat class ManagementServer { public: - ManagementServer() : - m_zmq_context(), - m_zmq_sock(m_zmq_context, ZMQ_REP), - m_running(false), - m_fault(false) { } - - ~ManagementServer() - { - m_running = false; - m_fault = false; - m_thread.join(); - } - + ManagementServer(); ManagementServer(const ManagementServer& other) = delete; ManagementServer& operator=(const ManagementServer& other) = delete; + ~ManagementServer(); - void open(int listenport) - { - m_listenport = listenport; - if (m_listenport > 0) { - m_thread = std::thread(&ManagementServer::serverThread, this); - } - } + void open(int listenport); /* Un-/Register a statistics data source */ void registerInput(InputStat* is); @@ -174,7 +157,7 @@ class ManagementServer */ void update_ptree(const boost::property_tree::ptree& pt); - bool fault_detected() { return m_fault; } + bool fault_detected() const { return m_fault; } void restart(void); private: |