Skip to content
Snippets Groups Projects
Commit 8170f199 authored by daniel's avatar daniel
Browse files

Use zmq_msg_more to check for more messages

parent d075d19a
No related branches found
No related tags found
No related merge requests found
...@@ -167,10 +167,7 @@ int main(int argc, char *argv[]) { ...@@ -167,10 +167,7 @@ int main(int argc, char *argv[]) {
mensafb = setup_fb(argv[1], 12, 5); mensafb = setup_fb(argv[1], 12, 5);
while (1) { while (1) {
int64_t more; while (1) {
size_t more_size = sizeof(more);
do {
zmq_msg_t message; zmq_msg_t message;
zmq_msg_init (&message); zmq_msg_init (&message);
zmq_msg_recv (&message, responder, 0); zmq_msg_recv (&message, responder, 0);
...@@ -179,10 +176,13 @@ int main(int argc, char *argv[]) { ...@@ -179,10 +176,13 @@ int main(int argc, char *argv[]) {
handleCommand(mensafb, (struct packet *)zmq_msg_data(&message)); handleCommand(mensafb, (struct packet *)zmq_msg_data(&message));
} }
zmq_getsockopt (responder, ZMQ_RCVMORE, &more, &more_size); if (!zmq_msg_more(&message)) {
zmq_msg_close(&message);
break;
}
zmq_msg_close (&message); zmq_msg_close(&message);
} while(more); }
zmq_send(responder, NULL, 0, 0); zmq_send(responder, NULL, 0, 0);
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment