sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-04-30 14:22:23 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix ZMQ exceptions and error reporting

Browse Source
This commit is contained in:
babic_a
2020-05-06 10:28:07 +02:00
parent 1765b485ef
commit 7b524501c0
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-buffer/src/LiveRecvModule.cpp
+10 -10
View File
@@ -41,16 +41,17 @@ LiveRecvModule::~LiveRecvModule()
void* LiveRecvModule::connect_socket(size_t module_id)
{
void* sock = zmq_socket(ctx_, ZMQ_SUB);
if (sock == nullptr) {
throw runtime_error(zmq_strerror(errno));
}
int rcvhwm = STREAM_RCV_QUEUE_SIZE;
if (zmq_setsockopt(sock, ZMQ_RCVHWM, &rcvhwm,
sizeof(rcvhwm)) != 0) {
throw runtime_error(strerror(errno));
if (zmq_setsockopt(sock, ZMQ_RCVHWM, &rcvhwm, sizeof(rcvhwm)) != 0) {
throw runtime_error(zmq_strerror(errno));
}
int linger = 0;
if (zmq_setsockopt(sock, ZMQ_LINGER, &linger,
sizeof(linger)) != 0) {
throw runtime_error(strerror(errno));
if (zmq_setsockopt(sock, ZMQ_LINGER, &linger, sizeof(linger)) != 0) {
throw runtime_error(zmq_strerror(errno));
}
stringstream ipc_addr;
@@ -58,12 +59,11 @@ void* LiveRecvModule::connect_socket(size_t module_id)
const auto ipc = ipc_addr.str();
if (zmq_connect(sock, ipc.c_str()) != 0) {
throw runtime_error(strerror(errno));
throw runtime_error(zmq_strerror(errno));
}
if (zmq_setsockopt(sock, ZMQ_SUBSCRIBE, "",
sizeof("")) != 0) {
throw runtime_error(strerror(errno));
if (zmq_setsockopt(sock, ZMQ_SUBSCRIBE, "", sizeof("")) != 0) {
throw runtime_error(zmq_strerror(errno));
}
return sock;