mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-05-01 07:02:23 +02:00
Make receiver code more readable
This commit is contained in:
@@ -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;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user