diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp index 9ea0096..c1ab03d 100644 --- a/core-writer/src/module/ZmqRecvModule.cpp +++ b/core-writer/src/module/ZmqRecvModule.cpp @@ -60,6 +60,8 @@ void ZmqRecvModule::start_recv( cout << (int) n_receiving_threads << endl; #endif + // TODO: Join threads if joinable and not yet joined. + is_receiving_ = true; for (uint8_t i_rec=0; i_rec < n_receiving_threads; i_rec++) {