diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-08-07 10:16:17 +0200 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-08-07 10:16:17 +0200 |
| commit | d423927765f72c8300f27a46d80452d54c39cbf9 (patch) | |
| tree | 1d72d713aca8c629a5d23906495a625911db16eb | |
| parent | 0bb9b364693659a184862771f98a4b6046587073 (diff) | |
| download | dabmux-d423927765f72c8300f27a46d80452d54c39cbf9.tar.gz dabmux-d423927765f72c8300f27a46d80452d54c39cbf9.tar.bz2 dabmux-d423927765f72c8300f27a46d80452d54c39cbf9.zip | |
Use nonblocking management server ZMQ recv
| -rw-r--r-- | src/ManagementServer.cpp | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/ManagementServer.cpp b/src/ManagementServer.cpp index 9687278..9a22776 100644 --- a/src/ManagementServer.cpp +++ b/src/ManagementServer.cpp @@ -206,10 +206,12 @@ void ManagementServer::serverThread() while (m_running) { zmq::message_t zmq_message; - m_zmq_sock.recv(&zmq_message); - - - handle_message(zmq_message); + if (m_zmq_sock.recv(&zmq_message, ZMQ_DONTWAIT)) { + handle_message(zmq_message); + } + else { + usleep(10000); + } } m_fault = true; |