Commit 2564c8e5 authored by Luca Boccassi's avatar Luca Boccassi Committed by GitHub

Merge pull request #2662 from sigiesec/fix-hwm-tests-race-2

Problem: occasional test failures due to messages not (yet) received in test assertion
parents 02e93492 8842e0f0
...@@ -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