From 83eeb5d6d0786a4231b199c34d2bb99559a15dbd Mon Sep 17 00:00:00 2001
From: Patrick Pelissier <patrick.pelissier@gmail.com>
Date: Fri, 12 Jan 2018 18:48:38 +0100
Subject: [PATCH] Make the code more robust

---
 m-worker.h | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/m-worker.h b/m-worker.h
index a9a54eb9..2c44b7b6 100644
--- a/m-worker.h
+++ b/m-worker.h
@@ -222,7 +222,10 @@ worker_clear(worker_t g)
 {
   for(unsigned int i = 0; i < g->numWorker_g; i++) {
     worker_order_t w = WORKER_EMPTY_ORDER;
-    worker_queue_push (g->queue_g, w);
+    // Normaly all worker threads shall be waiting at this
+    // stage, so all push won't block as the queue is empty.
+    // But for robustness, let's wait.
+    worker_queue_push_blocking (g->queue_g, w, true);
   }
   
   for(unsigned int i = 0; i < g->numWorker_g; i++) {