3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-01-14 09:47:56 +08:00
Code Issues Projects Releases Wiki Activity

test that proxy messages are received

Browse Source
This commit is contained in:
Min RK 2015-06-05 13:45:23 -07:00
parent 0f10ef1b38
commit 286c6f93ee
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
tests/test_proxy_terminate.cpp
View File

@ -86,22 +86,41 @@ int main (void)
rc = zmq_connect (publisher, "tcp://127.0.0.1:15564");
assert (rc == 0);
// Start a secondary puller which reads the data out the other end
char buf[255];
void *puller = zmq_socket (ctx, ZMQ_PULL);
assert (puller);
rc = zmq_connect (puller, "tcp://127.0.0.1:15563");
assert (rc == 0);
msleep (50);
rc = zmq_send (publisher, "This is a test", 14, 0);
assert (rc == 14);
rc = zmq_recv (puller, buf, 255, 0);
assert (rc == 14);
msleep (50);
rc = zmq_send (publisher, "This is a test", 14, 0);
assert (rc == 14);
rc = zmq_recv (puller, buf, 255, 0);
assert (rc == 14);
msleep (50);
rc = zmq_send (publisher, "This is a test", 14, 0);
assert (rc == 14);
rc = zmq_recv (puller, buf, 255, 0);
assert (rc == 14);
rc = zmq_send (control, "TERMINATE", 9, 0);
assert (rc == 9);
rc = zmq_close (publisher);
assert (rc == 0);
rc = zmq_close (puller);
assert (rc == 0);
rc = zmq_close (control);
assert (rc == 0);