sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-03 10:34:13 +02:00
Code Issues Packages Projects Releases Wiki Activity

Implement ZmqRecvModule stop procedure

Browse Source
This commit is contained in:
babic_a
2020-04-01 15:45:06 +02:00
parent a3110580dc
commit d21f721358
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/ZmqRecvModule.cpp
+14 -2
View File
@@ -39,8 +39,7 @@ void ZmqRecvModule::start(
cout << "[ZmqRecvModule::start]";
cout << " Starting with parameters:";
cout << "\tconnect_address: " << connect_address;
cout << "\tn_receiving_thread: " << n_receiving_threads;
cout << endl;
cout << "\tn_receiving_thread: " << n_receiving_threads << endl;
#endif
is_receiving_ = true;
@@ -53,8 +52,21 @@ void ZmqRecvModule::start(
void ZmqRecvModule::stop()
{
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ZmqRecvModule::stop]";
cout << " Stop receiving threads." << endl;
#endif
is_receiving_ = false;
for (auto& thread_ptr:receiving_threads_) {
thread_ptr.join();
}
receiving_threads_.clear();
}
void ZmqRecvModule::receive_thread(const string& connect_address)