Remove redundant notify_all, spelling mistake
This commit is contained in:
parent
b670bf98e0
commit
cab4c24d06
|
@ -1854,8 +1854,7 @@ bool Monitor::Analyse() {
|
||||||
while (!snap->decoded and !zm_terminate and !analysis_thread->Stopped()) {
|
while (!snap->decoded and !zm_terminate and !analysis_thread->Stopped()) {
|
||||||
// Need to wait for the decoder thread.
|
// Need to wait for the decoder thread.
|
||||||
Debug(1, "Waiting for decode");
|
Debug(1, "Waiting for decode");
|
||||||
packetqueue.unlock(packet_lock);
|
packetqueue.unlock(packet_lock); // This will delete packet_lock and notify_all
|
||||||
packetqueue.notify_all(); // decode might be waiting
|
|
||||||
packetqueue.wait();
|
packetqueue.wait();
|
||||||
|
|
||||||
// Another thread may have moved our it. Unlikely but possible
|
// Another thread may have moved our it. Unlikely but possible
|
||||||
|
@ -3063,7 +3062,7 @@ int Monitor::PrimeCapture() {
|
||||||
Debug(1, "Creating decoder thread");
|
Debug(1, "Creating decoder thread");
|
||||||
decoder = ZM::make_unique<DecoderThread>(this);
|
decoder = ZM::make_unique<DecoderThread>(this);
|
||||||
} else {
|
} else {
|
||||||
Debug(1, "Restartg decoder thread");
|
Debug(1, "Restarting decoder thread");
|
||||||
decoder->Start();
|
decoder->Start();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue