Commit 628787c9 authored by Richard Newton's avatar Richard Newton

Merge pull request #720 from hintjens/master

test_stream failed when response was broken into frames
parents 770d52ec 65050b1b
...@@ -102,8 +102,17 @@ if test "x$zmq_search_libsodium_lib" = "xyes"; then ...@@ -102,8 +102,17 @@ if test "x$zmq_search_libsodium_lib" = "xyes"; then
fi fi
fi fi
# Set pedantic AC_ARG_WITH([relaxed],
libzmq_pedantic="yes" [AS_HELP_STRING([--with-relaxed],
[Switch off pedantic compiler])],
[zmq_relaxed="yes"],
[])
if test "x$zmq_relaxed" = "xyes"; then
libzmq_pedantic="no"
else
libzmq_pedantic="yes"
fi
# By default compiling with -Werror except OSX. # By default compiling with -Werror except OSX.
libzmq_werror="yes" libzmq_werror="yes"
......
...@@ -89,15 +89,14 @@ test_stream_to_dealer (void) ...@@ -89,15 +89,14 @@ test_stream_to_dealer (void)
assert (rc == sizeof (greeting)); assert (rc == sizeof (greeting));
// Now we expect the data from the DEALER socket // 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); rc = zmq_msg_recv (&identity, stream, 0);
assert (rc > 0); assert (rc > 0);
assert (zmq_msg_more (&identity)); assert (zmq_msg_more (&identity));
// Second frame contains the next chunk of data
// Second frame contains the rest of greeting along with
// the Ready command
int bytes_read = 0;
while (bytes_read < 97) {
rc = zmq_recv (stream, buffer + bytes_read, 255 - bytes_read, 0); rc = zmq_recv (stream, buffer + bytes_read, 255 - bytes_read, 0);
assert (rc >= 0); assert (rc >= 0);
bytes_read += rc; bytes_read += rc;
......
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