From 3503e6c75441758881e733ce773d7a0d4bdf1ff4 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Wed, 8 Apr 2020 08:59:33 +0200 Subject: [PATCH] Check for n_receiving_threads parameter --- core-writer/src/module/ZmqRecvModule.cpp | 20 +++++++++++++++++--- 1 file changed, 17 insertions(+), 3 deletions(-) diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp index 6e1d961..35b9f04 100644 --- a/core-writer/src/module/ZmqRecvModule.cpp +++ b/core-writer/src/module/ZmqRecvModule.cpp @@ -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;