stop WriterPipeline threads on shutdown

This commit is contained in:
Doug Hoyte
2023-07-27 17:50:07 -04:00
parent ca0449286c
commit ab03a57b18

View File

@ -50,7 +50,7 @@ struct WriterPipeline {
shutdownRequested = true;
writerInbox.push_move({});
shutdownCv.notify_all();
break;
return;
}
std::string flatStr;
@ -143,6 +143,7 @@ struct WriterPipeline {
if (shutdownComplete) {
flushInbox.push_move(true);
if (numLive != 0) LW << "numLive was not 0 after shutdown!";
return;
}
backpressureCv.notify_all();