We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cc70203 commit f033c54Copy full SHA for f033c54
src/llmq/signing_shares.cpp
@@ -224,18 +224,17 @@ void CSigSharesManager::Stop()
224
assert(false);
225
}
226
227
- // Stop worker pool
228
- workerPool.clear_queue();
229
- workerPool.stop(true);
230
-
231
- // Join threads
+ // Join threads FIRST to stop any pending push() calls
232
if (housekeepingThread.joinable()) {
233
housekeepingThread.join();
234
235
236
if (dispatcherThread.joinable()) {
237
dispatcherThread.join();
238
+
+ // Then stop worker pool (now safe, no more push() calls)
+ workerPool.clear_queue();
+ workerPool.stop(true);
239
240
241
void CSigSharesManager::RegisterAsRecoveredSigsListener()
0 commit comments