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

Check for n_receiving_threads parameter

Browse Source
This commit is contained in:
babic_a
2020-04-08 08:59:33 +02:00
parent b872bb7510
commit 3503e6c754
1 changed files with 17 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/module/ZmqRecvModule.cpp
+17 -3
View File
@@ -31,14 +31,28 @@ void ZmqRecvModule::start_recv(
throw runtime_error(err_msg.str());
}
if (n_receiving_threads < 1) {
stringstream err_msg;
using namespace date;
using namespace chrono;
err_msg << "[" << system_clock::now() << "]";
err_msg << "[ZmqRecvModule::start_recv]";
err_msg << " n_receiving_threads ";
err_msg << n_receiving_threads << " must be > 1." << endl;
throw runtime_error(err_msg.str());
}
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ZmqRecvModule::start]";
cout << " Starting with parameters:";
cout << "\tconnect_address: " << connect_address;
cout << "\tn_receiving_thread: " << (int) n_receiving_threads << endl;
cout << " Starting with ";
cout << "connect_address " << connect_address;
cout << " n_receiving_thread ";
cout << (int) n_receiving_threads << endl;
#endif
is_receiving_ = true;