From ab03a57b18c0959ee4c71c0fb32cc0b22417edfe Mon Sep 17 00:00:00 2001
From: Doug Hoyte <doug@hcsw.org>
Date: Thu, 27 Jul 2023 17:50:07 -0400
Subject: [PATCH] stop WriterPipeline threads on shutdown

---
 src/WriterPipeline.h | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/WriterPipeline.h b/src/WriterPipeline.h
index 374f45b..d01fa7a 100644
--- a/src/WriterPipeline.h
+++ b/src/WriterPipeline.h
@@ -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();