Lines 40-52
Link Here
|
40 |
zmq_msg_t msg; |
40 |
zmq_msg_t msg; |
41 |
zmq_msg_init (&msg); |
41 |
zmq_msg_init (&msg); |
42 |
zmq_msg_recv (&msg, pubSocket, 0); |
42 |
zmq_msg_recv (&msg, pubSocket, 0); |
43 |
int msgSize = zmq_msg_size(&msg); |
|
|
44 |
char* buffer = (char*)zmq_msg_data(&msg); |
43 |
char* buffer = (char*)zmq_msg_data(&msg); |
45 |
|
44 |
|
46 |
if (buffer[0] == 0) { |
45 |
if (buffer[0] == 0) { |
47 |
assert(isSubscribed); |
46 |
assert(isSubscribed); |
48 |
isSubscribed = false; |
47 |
isSubscribed = false; |
49 |
} else { |
48 |
} |
|
|
49 |
else { |
50 |
assert(!isSubscribed); |
50 |
assert(!isSubscribed); |
51 |
isSubscribed = true; |
51 |
isSubscribed = true; |
52 |
} |
52 |
} |
Lines 64-73
Link Here
|
64 |
zmq_msg_t msg; |
64 |
zmq_msg_t msg; |
65 |
zmq_msg_init (&msg); |
65 |
zmq_msg_init (&msg); |
66 |
zmq_msg_recv (&msg, subSocket, 0); |
66 |
zmq_msg_recv (&msg, subSocket, 0); |
67 |
int msgSize = zmq_msg_size(&msg); |
|
|
68 |
char* buffer = (char*)zmq_msg_data(&msg); |
69 |
|
70 |
|
71 |
zmq_getsockopt (subSocket, ZMQ_RCVMORE, &more, &more_size); |
67 |
zmq_getsockopt (subSocket, ZMQ_RCVMORE, &more, &more_size); |
72 |
zmq_msg_close (&msg); |
68 |
zmq_msg_close (&msg); |
73 |
|
69 |
|