3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-17 08:34:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove debug printf in test_xpub_welcome_msg

Browse Source
This commit is contained in:
Doron Somech 2014-11-26 15:53:50 +02:00
parent 768b62eb9d
commit 0ac0b04755
1 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
tests/test_xpub_welcome_msg.cpp
View File

@ -38,27 +38,26 @@ int main (void)
// Create a subscriber // Create a subscriber
void *sub = zmq_socket (ctx, ZMQ_SUB); void *sub = zmq_socket (ctx, ZMQ_SUB);
// Subscribe to the welcome message // Subscribe to the welcome message
rc = zmq_setsockopt(sub, ZMQ_SUBSCRIBE, "W", 1); rc = zmq_setsockopt(sub, ZMQ_SUBSCRIBE, "W", 1);
assert(rc == 0); assert(rc == 0);
assert (sub); assert (sub);
rc = zmq_connect (sub, "inproc://soname"); rc = zmq_connect (sub, "inproc://soname");
assert (rc == 0); assert (rc == 0);
char buffer[2]; char buffer[2];
// Receive the welcome subscription // Receive the welcome subscription
rc = zmq_recv(pub, buffer, 2, 0); rc = zmq_recv(pub, buffer, 2, 0);
assert(rc == 2); assert(rc == 2);
assert(buffer[0] == 1); assert(buffer[0] == 1);
assert(buffer[1] == 'W'); assert(buffer[1] == 'W');
// Receive the welcome message // Receive the welcome message
rc = zmq_recv(sub, buffer, 1, 0); rc = zmq_recv(sub, buffer, 1, 0);
printf("%d\n", rc); assert(rc == 1);
assert(rc == 1); assert(buffer[0] == 'W');
assert(buffer[0] == 'W');
// Clean up. // Clean up.
rc = zmq_close (pub); rc = zmq_close (pub);