generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-05-28 23:24:12 +02:00
Code Issues Projects Releases Wiki Activity

test_stream failed when response was broken into frames

Browse Source
This commit is contained in:
Pieter Hintjens 2013-10-23 23:58:39 +02:00
parent 770d52ecfe
commit 1ee7b9b1ea
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tests/test_stream.cpp
View File

@ -89,15 +89,14 @@ test_stream_to_dealer (void)
assert (rc == sizeof (greeting));
// Now we expect the data from the DEALER socket
// First frame is, again, the identity of the connection
// We want the rest of greeting along with the Ready command
int bytes_read = 0;
while (bytes_read < 97) {
// First frame is the identity of the connection (each time)
rc = zmq_msg_recv (&identity, stream, 0);
assert (rc > 0);
assert (zmq_msg_more (&identity));
// Second frame contains the rest of greeting along with
// the Ready command
int bytes_read = 0;
while (bytes_read < 97) {
// Second frame contains the next chunk of data
rc = zmq_recv (stream, buffer + bytes_read, 255 - bytes_read, 0);
assert (rc >= 0);
bytes_read += rc;