mirror of
https://github.com/zeromq/libzmq.git
synced 2024-12-13 10:52:56 +01:00
Bug in XREP and XREQ fixed (issue 280)
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
This commit is contained in:
parent
83975c1b21
commit
5a6503e5c2
@ -264,7 +264,7 @@ bool zmq::xrep_t::xhas_in ()
|
||||
return true;
|
||||
|
||||
// Try to read the next message to the pre-fetch buffer.
|
||||
int rc = xrecv (&prefetched_msg, ZMQ_DONTWAIT);
|
||||
int rc = xrep_t::xrecv (&prefetched_msg, ZMQ_DONTWAIT);
|
||||
if (rc != 0 && errno == EAGAIN)
|
||||
return false;
|
||||
zmq_assert (rc == 0);
|
||||
|
@ -86,7 +86,7 @@ bool zmq::xreq_t::xhas_in ()
|
||||
return true;
|
||||
|
||||
// Try to read the next message to the pre-fetch buffer.
|
||||
int rc = xrecv (&prefetched_msg, ZMQ_DONTWAIT);
|
||||
int rc = xreq_t::xrecv (&prefetched_msg, ZMQ_DONTWAIT);
|
||||
if (rc != 0 && errno == EAGAIN)
|
||||
return false;
|
||||
zmq_assert (rc == 0);
|
||||
|
Loading…
Reference in New Issue
Block a user