diff --git a/core-buffer/src/LiveRecvModule.cpp b/core-buffer/src/LiveRecvModule.cpp index 2d23fd1..422982d 100644 --- a/core-buffer/src/LiveRecvModule.cpp +++ b/core-buffer/src/LiveRecvModule.cpp @@ -24,6 +24,7 @@ LiveRecvModule::LiveRecvModule( using namespace chrono; cout << "[" << system_clock::now() << "]"; cout << "[LiveRecvModule::LiveRecvModule]"; + cout << endl; #endif receiving_thread_ = thread( @@ -58,6 +59,8 @@ void* LiveRecvModule::connect_socket(size_t module_id) ipc_addr << ipc_prefix_ << module_id; const auto ipc = ipc_addr.str(); + cout << "ipc " << ipc << endl; + if (zmq_connect(sock, ipc.c_str()) != 0) { throw runtime_error(zmq_strerror(errno)); }