Skip to content

Commit

Permalink
Fix log messages in JControlZMQ
Browse files Browse the repository at this point in the history
  • Loading branch information
nathanwbrei committed Dec 5, 2024
1 parent 79ac8b2 commit d9e6cd4
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions src/plugins/janacontrol/JControlZMQ.cc
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ JControlZMQ::JControlZMQ(JApplication *app, int port):_japp(app), _port(port)
{
// This is called from jcontrol plugin's InitPlugin() routine

LOG << "Launching JControlZMQ thread ..." << LOG_END
LOG << "Launching JControlZMQ thread ..." << LOG_END;

// Create new zmq context, get the current host name, and launch server thread
_zmq_context = zmq_ctx_new();
Expand All @@ -110,10 +110,10 @@ JControlZMQ::~JControlZMQ()
// Tell server thread to quit and wait for it to finish
_done =true;
if(_thr != nullptr) {
LOG << "Joining JControlZMQ thread ..." << LOG_END
LOG << "Joining JControlZMQ thread ..." << LOG_END;
_thr->join();
delete _thr;
LOG << "JControlZMQ thread joined." << LOG_END
LOG << "JControlZMQ thread joined." << LOG_END;
}

// Delete the zmq context
Expand All @@ -132,7 +132,7 @@ void JControlZMQ::ServerLoop()
/// indefinitely until the internal _done member is set to true.
/// Currently, that is done only by calling the destructor.

LOG << "JControlZMQ server starting ..." << LOG_END
LOG << "JControlZMQ server starting ..." << LOG_END;

// This just makes it easier to identify this thread while debugging.
// Linux and Mac OS X use different calling signatures for pthread_setname_np
Expand All @@ -148,7 +148,7 @@ void JControlZMQ::ServerLoop()
void *responder = zmq_socket( _zmq_context, ZMQ_REP );
auto ret = zmq_bind( responder, bind_str);
if( ret != 0 ){
LOG << "JControlZMQ: Unable to bind zeroMQ control socket " << _port << "!" << LOG_END
LOG << "JControlZMQ: Unable to bind zeroMQ control socket " << _port << "!" << LOG_END;
perror("zmq_bind");
return;
}
Expand All @@ -164,7 +164,7 @@ void JControlZMQ::ServerLoop()
std::this_thread::sleep_for(std::chrono::milliseconds(250));
continue;
}else{
LOG << "JControlZMQ: ERROR listening on control socket: errno=" << errno << LOG_END
LOG << "JControlZMQ: ERROR listening on control socket: errno=" << errno << LOG_END;
_done = true;
continue;
}
Expand Down

0 comments on commit d9e6cd4

Please sign in to comment.