Modify TimesliceReceiver to put the end work item back for other cons…

…umers.
cbm-fles · Sep 7, 2016 · 4037ead · 4037ead
1 parent 58323bc
commit 4037ead
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/fles_ipc/TimesliceReceiver.cpp b/lib/fles_ipc/TimesliceReceiver.cpp
@@ -90,6 +90,8 @@ TimesliceView* TimesliceReceiver::do_get()
 #endif
     if (recvd_size == 0) {
         eos_ = true;
+        // put end work item back for other consumers
+        work_items_mq_->send(nullptr, 0, 0);
         return nullptr;
     }
     assert(recvd_size == sizeof(wi));