summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-11-15 13:56:59 +0100
committerMartin Sustrik <sustrik@250bpm.com>2011-11-15 13:56:59 +0100
commit5a6503e5c275c544e1447401e17a4746985614ea (patch)
tree15302e5dc8f1bc52761cb29fb4115a232344aa8b
parent83975c1b21722bb689c7b84cde5a6958145fcbd4 (diff)
Bug in XREP and XREQ fixed (issue 280)
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
-rw-r--r--src/xrep.cpp2
-rw-r--r--src/xreq.cpp2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp
index 336d4e5..f304b23 100644
--- a/src/xrep.cpp
+++ b/src/xrep.cpp
@@ -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);
diff --git a/src/xreq.cpp b/src/xreq.cpp
index 59d3f39..bf288ee 100644
--- a/src/xreq.cpp
+++ b/src/xreq.cpp
@@ -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);