From 72161fb075025410312c6735d681c3de9a36a4e5 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Mon, 28 Dec 2009 21:29:31 +0100 Subject: format of subscriptions changed (no * needed anymore) --- src/socket_base.cpp | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) (limited to 'src/socket_base.cpp') diff --git a/src/socket_base.cpp b/src/socket_base.cpp index 43209d5..2348f67 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -326,17 +326,20 @@ int zmq::socket_base_t::recv (::zmq_msg_t *msg_, int flags_) if (errno != EAGAIN) return -1; app_thread->process_commands (false, false); - ticks = 0; rc = xrecv (msg_, flags_); + ticks = 0; } else { while (rc != 0) { - if (errno != EAGAIN) + if (errno == EINPROGRESS) + app_thread->process_commands (false, true); + else if (errno == EAGAIN) + app_thread->process_commands (true, false); + else return -1; - app_thread->process_commands (true, false); - ticks = 0; rc = xrecv (msg_, flags_); } + ticks = 0; } -- cgit v1.2.3