Commit af934f85 authored by Pieter Hintjens's avatar Pieter Hintjens

Removed use of deprecated API methods

parent 8ba097f3
...@@ -45,7 +45,7 @@ while (true) { ...@@ -45,7 +45,7 @@ while (true) {
int rc = zmq_msg_init (&frame); int rc = zmq_msg_init (&frame);
assert (rc == 0); assert (rc == 0);
// Block until a message is available to be received from socket // Block until a message is available to be received from socket
rc = zmq_recvmsg (socket, &frame, 0); rc = zmq_msg_recv (socket, &frame, 0);
assert (rc != -1); assert (rc != -1);
if (zmq_msg_get (&frame, ZMQ_MORE)) if (zmq_msg_get (&frame, ZMQ_MORE))
fprintf (stderr, "more\n"); fprintf (stderr, "more\n");
......
...@@ -35,7 +35,7 @@ while (true) { ...@@ -35,7 +35,7 @@ while (true) {
int rc = zmq_msg_init (&part); int rc = zmq_msg_init (&part);
assert (rc == 0); assert (rc == 0);
// Block until a message is available to be received from socket // Block until a message is available to be received from socket
rc = zmq_recvmsg (socket, &part, 0); rc = zmq_msg_recv (socket, &part, 0);
assert (rc != -1); assert (rc != -1);
if (zmq_msg_more (&part)) if (zmq_msg_more (&part))
fprintf (stderr, "more\n"); fprintf (stderr, "more\n");
......
...@@ -78,9 +78,7 @@ assert (nbytes != -1); ...@@ -78,9 +78,7 @@ assert (nbytes != -1);
SEE ALSO SEE ALSO
-------- --------
linkzmq:zmq_recvmsg[3]
linkzmq:zmq_send[3] linkzmq:zmq_send[3]
linkzmq:zmq_sendmsg[3]
linkzmq:zmq_getsockopt[3] linkzmq:zmq_getsockopt[3]
linkzmq:zmq_socket[7] linkzmq:zmq_socket[7]
linkzmq:zmq[7] linkzmq:zmq[7]
......
...@@ -110,7 +110,6 @@ SEE ALSO ...@@ -110,7 +110,6 @@ SEE ALSO
-------- --------
linkzmq:zmq_recv[3] linkzmq:zmq_recv[3]
linkzmq:zmq_send[3] linkzmq:zmq_send[3]
linkzmq:zmq_sendmsg[3]
linkzmq:zmq_getsockopt[3] linkzmq:zmq_getsockopt[3]
linkzmq:zmq_socket[7] linkzmq:zmq_socket[7]
linkzmq:zmq[7] linkzmq:zmq[7]
......
...@@ -87,9 +87,7 @@ assert (rc == 2); ...@@ -87,9 +87,7 @@ assert (rc == 2);
SEE ALSO SEE ALSO
-------- --------
linkzmq:zmq_sendmsg[3]
linkzmq:zmq_recv[3] linkzmq:zmq_recv[3]
linkzmq:zmq_recvmsg[3]
linkzmq:zmq_socket[7] linkzmq:zmq_socket[7]
linkzmq:zmq[7] linkzmq:zmq[7]
......
...@@ -106,8 +106,6 @@ rc = zmq_sendmsg (socket, &part3, 0); ...@@ -106,8 +106,6 @@ rc = zmq_sendmsg (socket, &part3, 0);
SEE ALSO SEE ALSO
-------- --------
linkzmq:zmq_recv[3] linkzmq:zmq_recv[3]
linkzmq:zmq_recv[3]
linkzmq:zmq_recvmsg[3]
linkzmq:zmq_socket[7] linkzmq:zmq_socket[7]
linkzmq:zmq[7] linkzmq:zmq[7]
......
...@@ -37,7 +37,7 @@ static void *req_socket_monitor (void *ctx) ...@@ -37,7 +37,7 @@ static void *req_socket_monitor (void *ctx)
while (true) { while (true) {
zmq_msg_t msg; zmq_msg_t msg;
zmq_msg_init (&msg); zmq_msg_init (&msg);
rc = zmq_recvmsg (s, &msg, 0); rc = zmq_msg_recv (s, &msg, 0);
if (rc == -1 && zmq_errno() == ETERM) break; if (rc == -1 && zmq_errno() == ETERM) break;
assert (rc != -1); assert (rc != -1);
memcpy (&event, zmq_msg_data (&msg), sizeof (event)); memcpy (&event, zmq_msg_data (&msg), sizeof (event));
...@@ -217,7 +217,7 @@ static void *rep_socket_monitor (void *ctx) ...@@ -217,7 +217,7 @@ static void *rep_socket_monitor (void *ctx)
while (true) { while (true) {
zmq_msg_t msg; zmq_msg_t msg;
zmq_msg_init (&msg); zmq_msg_init (&msg);
rc = zmq_recvmsg (s, &msg, 0); rc = zmq_msg_recv (s, &msg, 0);
if (rc == -1 && zmq_errno() == ETERM) break; if (rc == -1 && zmq_errno() == ETERM) break;
assert (rc != -1); assert (rc != -1);
memcpy (&event, zmq_msg_data (&msg), sizeof (event)); memcpy (&event, zmq_msg_data (&msg), sizeof (event));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment