|
|
|
@ -30,6 +30,7 @@ static int zmq_send_multipart(void *sock, const void* data, size_t size, ...)
@@ -30,6 +30,7 @@ static int zmq_send_multipart(void *sock, const void* data, size_t size, ...)
|
|
|
|
|
if (rc != 0) |
|
|
|
|
{ |
|
|
|
|
zmqError("Unable to initialize ZMQ msg"); |
|
|
|
|
va_end(args); |
|
|
|
|
return -1; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -43,6 +44,7 @@ static int zmq_send_multipart(void *sock, const void* data, size_t size, ...)
@@ -43,6 +44,7 @@ static int zmq_send_multipart(void *sock, const void* data, size_t size, ...)
|
|
|
|
|
{ |
|
|
|
|
zmqError("Unable to send ZMQ msg"); |
|
|
|
|
zmq_msg_close(&msg); |
|
|
|
|
va_end(args); |
|
|
|
|
return -1; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -53,6 +55,7 @@ static int zmq_send_multipart(void *sock, const void* data, size_t size, ...)
@@ -53,6 +55,7 @@ static int zmq_send_multipart(void *sock, const void* data, size_t size, ...)
|
|
|
|
|
|
|
|
|
|
size = va_arg(args, size_t); |
|
|
|
|
} |
|
|
|
|
va_end(args); |
|
|
|
|
return 0; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|