Commit 5485d6e3 authored by Rik van der Heijden's avatar Rik van der Heijden

Check proxy return values in tests

parent b7910314
...@@ -165,7 +165,8 @@ server_task (void *ctx) ...@@ -165,7 +165,8 @@ server_task (void *ctx)
threads[thread_nbr] = zmq_threadstart (&server_worker, ctx); threads[thread_nbr] = zmq_threadstart (&server_worker, ctx);
// Connect backend to frontend via a proxy // Connect backend to frontend via a proxy
zmq_proxy_steerable (frontend, backend, NULL, control); rc = zmq_proxy_steerable (frontend, backend, NULL, control);
assert (rc == 0);
for (thread_nbr = 0; thread_nbr < QT_WORKERS; thread_nbr++) for (thread_nbr = 0; thread_nbr < QT_WORKERS; thread_nbr++)
zmq_threadclose (threads[thread_nbr]); zmq_threadclose (threads[thread_nbr]);
......
...@@ -52,7 +52,8 @@ server_task (void *ctx) ...@@ -52,7 +52,8 @@ server_task (void *ctx)
assert (rc == 0); assert (rc == 0);
// Use rep as both frontend and backend // Use rep as both frontend and backend
zmq_proxy_steerable (rep, rep, NULL, control); rc = zmq_proxy_steerable (rep, rep, NULL, control);
assert (rc == 0);
rc = zmq_close (rep); rc = zmq_close (rep);
assert (rc == 0); assert (rc == 0);
......
...@@ -61,7 +61,8 @@ server_task (void *ctx) ...@@ -61,7 +61,8 @@ server_task (void *ctx)
assert (rc == 0); assert (rc == 0);
// Connect backend to frontend via a proxy // Connect backend to frontend via a proxy
zmq_proxy_steerable (frontend, backend, NULL, control); rc = zmq_proxy_steerable (frontend, backend, NULL, control);
assert (rc == 0);
rc = zmq_close (frontend); rc = zmq_close (frontend);
assert (rc == 0); assert (rc == 0);
......
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