Commit 8842e0f0 authored by Simon Giesecke's avatar Simon Giesecke

Problem: occasional test failures due to messages not (yet) received in test assertion

Solution: add sleep
parent 02e93492
...@@ -53,9 +53,12 @@ int test_defaults () ...@@ -53,9 +53,12 @@ int test_defaults ()
// Send until we block // Send until we block
int send_count = 0; int send_count = 0;
while (send_count < MAX_SENDS && zmq_send (connect_socket, NULL, 0, ZMQ_DONTWAIT) == 0) while (send_count < MAX_SENDS
&& zmq_send (connect_socket, NULL, 0, ZMQ_DONTWAIT) == 0)
++send_count; ++send_count;
msleep (SETTLE_TIME);
// Now receive all sent messages // Now receive all sent messages
int recv_count = 0; int recv_count = 0;
while (zmq_recv (bind_socket, NULL, 0, ZMQ_DONTWAIT) == 0) while (zmq_recv (bind_socket, NULL, 0, ZMQ_DONTWAIT) == 0)
......
...@@ -58,10 +58,11 @@ int test_defaults (int send_hwm, int msgCnt) ...@@ -58,10 +58,11 @@ int test_defaults (int send_hwm, int msgCnt)
while (send_count < msgCnt && zmq_send (pub_socket, NULL, 0, ZMQ_DONTWAIT) == 0) while (send_count < msgCnt && zmq_send (pub_socket, NULL, 0, ZMQ_DONTWAIT) == 0)
++send_count; ++send_count;
msleep (SETTLE_TIME);
// Now receive all sent messages // Now receive all sent messages
int recv_count = 0; int recv_count = 0;
while (0 == zmq_recv (sub_socket, NULL, 0, ZMQ_DONTWAIT)) while (0 == zmq_recv (sub_socket, NULL, 0, ZMQ_DONTWAIT)) {
{
++recv_count; ++recv_count;
} }
......
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