generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-13 10:52:56 +01:00
Code Issues Projects Releases Wiki Activity

Add a send timeout in expect_bounce_fail() so tests for authentication

Browse Source 
failures don't block.
This commit is contained in:
Goswin von Brederlow 2014-05-19 17:01:44 +02:00
parent 77f5f7adae
commit 0ebf94e429
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tests/testutil.hpp
View File

@ -112,15 +112,17 @@ expect_bounce_fail (void *server, void *client)
{ {
const char *content = "12345678ABCDEFGH12345678abcdefgh"; const char *content = "12345678ABCDEFGH12345678abcdefgh";
char buffer [32]; char buffer [32];
int timeout = 150;
// Send message from client to server // Send message from client to server
int rc = zmq_send (client, content, 32, ZMQ_SNDMORE); int rc = zmq_setsockopt (client, ZMQ_SNDTIMEO, &timeout, sizeof (int));
assert (rc == 32); assert (rc == 0);
rc = zmq_send (client, content, 32, ZMQ_SNDMORE);
assert ((rc == 32) || ((rc == -1) && (errno == EAGAIN)));
rc = zmq_send (client, content, 32, 0); rc = zmq_send (client, content, 32, 0);
assert (rc == 32); assert ((rc == 32) || ((rc == -1) && (errno == EAGAIN)));
// Receive message at server side (should not succeed) // Receive message at server side (should not succeed)
int timeout = 150;
rc = zmq_setsockopt (server, ZMQ_RCVTIMEO, &timeout, sizeof (int)); rc = zmq_setsockopt (server, ZMQ_RCVTIMEO, &timeout, sizeof (int));
assert (rc == 0); assert (rc == 0);
rc = zmq_recv (server, buffer, 32, 0); rc = zmq_recv (server, buffer, 32, 0);
@ -128,10 +130,12 @@ expect_bounce_fail (void *server, void *client)
assert (zmq_errno () == EAGAIN); assert (zmq_errno () == EAGAIN);
// Send message from server to client to test other direction // Send message from server to client to test other direction
rc = zmq_setsockopt (server, ZMQ_SNDTIMEO, &timeout, sizeof (int));
assert (rc == 0);
rc = zmq_send (server, content, 32, ZMQ_SNDMORE); rc = zmq_send (server, content, 32, ZMQ_SNDMORE);
assert (rc == 32); assert ((rc == 32) || ((rc == -1) && (errno == EAGAIN)));
rc = zmq_send (server, content, 32, 0); rc = zmq_send (server, content, 32, 0);
assert (rc == 32); assert ((rc == 32) || ((rc == -1) && (errno == EAGAIN)));
// Receive message at client side (should not succeed) // Receive message at client side (should not succeed)
rc = zmq_setsockopt (client, ZMQ_RCVTIMEO, &timeout, sizeof (int)); rc = zmq_setsockopt (client, ZMQ_RCVTIMEO, &timeout, sizeof (int));