summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-10-31 15:56:39 +0100
committerMartin Sustrik <sustrik@250bpm.com>2011-10-31 15:56:39 +0100
commit4b832ea37410035bba7b85e5e9988af8eda648c2 (patch)
tree6176bb39cdc71cce967fc7e7a45474bba3f92357 /src
parent9227c389331c26d24e515bdd46867013f0cbd641 (diff)
Revert the early dropping of request and replies for disconnected clients
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src')
-rw-r--r--src/xrep.cpp4
-rw-r--r--src/xreq.cpp4
2 files changed, 6 insertions, 2 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp
index 9f2a947..6ca39f4 100644
--- a/src/xrep.cpp
+++ b/src/xrep.cpp
@@ -35,9 +35,11 @@ zmq::xrep_t::xrep_t (class ctx_t *parent_, uint32_t tid_) :
{
options.type = ZMQ_XREP;
+ // TODO: Uncomment the following line when XREP will become true XREP
+ // rather than generic router socket.
// If peer disconnect there's noone to send reply to anyway. We can drop
// all the outstanding requests from that peer.
- options.delay_on_disconnect = false;
+ // options.delay_on_disconnect = false;
prefetched_msg.init ();
}
diff --git a/src/xreq.cpp b/src/xreq.cpp
index 79b3b94..02a5202 100644
--- a/src/xreq.cpp
+++ b/src/xreq.cpp
@@ -27,9 +27,11 @@ zmq::xreq_t::xreq_t (class ctx_t *parent_, uint32_t tid_) :
{
options.type = ZMQ_XREQ;
+ // TODO: Uncomment the following line when XREQ will become true XREQ
+ // rather than generic dealer socket.
// If the socket is closing we can drop all the outbound requests. There'll
// be noone to receive the replies anyway.
- options.delay_on_close = false;
+ // options.delay_on_close = false;
}
zmq::xreq_t::~xreq_t ()