sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-12 18:55:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

Revert "Add counter for frames to save instead of just flag"

Browse Source 
This reverts commit 16612a2d
This commit is contained in:
babic_a
2020-04-08 15:04:33 +02:00
parent 16612a2d72
commit 2e9568da8d
1 changed files with 5 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/module/ZmqRecvModule.cpp
+5 -13
View File
@@ -84,18 +84,17 @@ void ZmqRecvModule::stop_recv()
receiving_threads_.clear();
}
void ZmqRecvModule::start_saving(const int n_frames_to_save)
void ZmqRecvModule::start_saving()
{
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ZmqRecvModule::start_saving]";
cout << " n_frames_to_save " << n_frames_to_save;
cout << endl;
cout << " Enable saving." << endl;
#endif
n_frames_to_save_ = n_frames_to_save;
is_saving_ = true;
}
void ZmqRecvModule::stop_saving()
@@ -108,12 +107,7 @@ void ZmqRecvModule::stop_saving()
cout << " Disable saving." << endl;
#endif
n_frames_to_save_ = 0;
}
bool ZmqRecvModule::is_saving()
{
return n_frames_to_save_ != 0;
is_saving_ = false;
}
void ZmqRecvModule::receive_thread(const string& connect_address)
@@ -134,12 +128,10 @@ void ZmqRecvModule::receive_thread(const string& connect_address)
continue;
}
if (!is_saving()) {
if (!is_saving_.load(memory_order_relaxed)) {
continue;
}
n_frames_to_save_--;
auto frame_metadata = frame.first;
auto frame_data = frame.second;