diff options
| author | Martin Sustrik <sustrik@250bpm.com> | 2011-10-31 15:56:39 +0100 | 
|---|---|---|
| committer | Martin Sustrik <sustrik@250bpm.com> | 2011-10-31 15:56:39 +0100 | 
| commit | 4b832ea37410035bba7b85e5e9988af8eda648c2 (patch) | |
| tree | 6176bb39cdc71cce967fc7e7a45474bba3f92357 | |
| parent | 9227c389331c26d24e515bdd46867013f0cbd641 (diff) | |
Revert the early dropping of request and replies for disconnected clients
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
| -rw-r--r-- | src/xrep.cpp | 4 | ||||
| -rw-r--r-- | src/xreq.cpp | 4 | 
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 () | 
