From 724ac2101e0fa70656217091c76fbb33f7a2f2e8 Mon Sep 17 00:00:00 2001
From: Babicaa <andrej.babic@psi.ch>
Date: Tue, 2 Apr 2019 12:01:36 +0200
Subject: [PATCH] Receiver process adaptation

---
 lib/src/ProcessManager.cpp | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/lib/src/ProcessManager.cpp b/lib/src/ProcessManager.cpp
index b0500f5..e23b2db 100644
--- a/lib/src/ProcessManager.cpp
+++ b/lib/src/ProcessManager.cpp
@@ -115,7 +115,7 @@ void ProcessManager::receive_zmq()
         auto frame = receiver.receive();
         
         // In case no message is available before the timeout, both pointers are NULL.
-        if (!frame.first){
+        if (!frame.first || !writer_manager.receive_frame()){
             continue;
         }
 
@@ -134,7 +134,6 @@ void ProcessManager::receive_zmq()
             cout << "." << endl;
         #endif
 
-        // Commit the frame to the buffer.
         ring_buffer.write(frame_metadata, frame_data);
 
         writer_manager.received_frame(frame_metadata->frame_index);