diff --git a/core-buffer/src/BufferUtils.cpp b/core-buffer/src/BufferUtils.cpp index 5d91d5d..ab42ed7 100644 --- a/core-buffer/src/BufferUtils.cpp +++ b/core-buffer/src/BufferUtils.cpp @@ -98,6 +98,11 @@ void* BufferUtils::connect_socket( detector_name + "-" + stream_name; +#ifdef DEBUG_OUTPUT + cout << "[BufferUtils::connect_socket]"; + cout << " IPC address: " << ipc_address << endl; +#endif + void* socket = zmq_socket(ctx, ZMQ_SUB); if (socket == nullptr) { throw runtime_error(zmq_strerror(errno)); @@ -131,6 +136,12 @@ void* BufferUtils::bind_socket( detector_name + "-" + stream_name; +#ifdef DEBUG_OUTPUT + cout << "[BufferUtils::bind_socket]"; + cout << " IPC address: " << ipc_address << endl; +#endif + + void* socket = zmq_socket(ctx, ZMQ_PUB); const int sndhwm = BUFFER_ZMQ_SNDHWM;