add comments and a test for zm_terminate in the checkCommandQueue while loop
parent
83a652aade
commit
189e78b42d
|
@ -527,8 +527,9 @@ void MonitorStream::runStream() {
|
||||||
|
|
||||||
bool was_paused = paused;
|
bool was_paused = paused;
|
||||||
if ( connkey ) {
|
if ( connkey ) {
|
||||||
while(checkCommandQueue()) {
|
while ( checkCommandQueue() && !zm_terminate ) {
|
||||||
Debug(2, "Have checking command Queue for connkey: %d", connkey );
|
// Loop in here until all commands are processed.
|
||||||
|
Debug(2, "Have checking command Queue for connkey: %d", connkey);
|
||||||
got_command = true;
|
got_command = true;
|
||||||
}
|
}
|
||||||
// Update modified time of the socket .lock file so that we can tell which ones are stale.
|
// Update modified time of the socket .lock file so that we can tell which ones are stale.
|
||||||
|
@ -536,8 +537,7 @@ Debug(2, "Have checking command Queue for connkey: %d", connkey );
|
||||||
touch(sock_path_lock);
|
touch(sock_path_lock);
|
||||||
last_comm_update = now;
|
last_comm_update = now;
|
||||||
}
|
}
|
||||||
|
} // end if connkey
|
||||||
}
|
|
||||||
|
|
||||||
if ( paused ) {
|
if ( paused ) {
|
||||||
if ( !was_paused ) {
|
if ( !was_paused ) {
|
||||||
|
|
Loading…
Reference in New Issue