From 70f8218bcda5ba081849e8ad25be862f824ea436 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Wed, 8 Apr 2020 10:39:20 +0200 Subject: [PATCH] Make receiver code more readable --- core-writer/src/module/ZmqRecvModule.cpp | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp index 35b9f04..600dcb1 100644 --- a/core-writer/src/module/ZmqRecvModule.cpp +++ b/core-writer/src/module/ZmqRecvModule.cpp @@ -124,9 +124,11 @@ void ZmqRecvModule::receive_thread(const string& connect_address) auto frame = receiver.receive(); // .first and .second = nullptr when no message received - // If no message or currently not writing, idle. - if (frame.first == nullptr || - !is_saving_.load(memory_order_relaxed)) { + if (frame.first == nullptr ) { + continue; + } + + if (!is_saving_.load(memory_order_relaxed)) { continue; }