Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Dont wait for pending subscription commands on shutdown

When (X)SUB socket is being shut down there may be pending
outbound subscription commands in the pipes. In such case
we want to close the socket immediately instead of waiting
for the commands to be sent.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
  • Loading branch information...
commit 3fbe8ac3c3aaec777c305de8fbdc0d748c3b14aa 1 parent 91fdedf
@sustrik sustrik authored
Showing with 5 additions and 0 deletions.
  1. +5 −0 src/xsub.cpp
View
5 src/xsub.cpp
@@ -30,6 +30,11 @@ zmq::xsub_t::xsub_t (class ctx_t *parent_, uint32_t tid_) :
more (false)
{
options.type = ZMQ_XSUB;
+
+ // When socket is being closed down we don't want to wait till pending
+ // subscription commands are sent to the wire.
+ options.linger = 0;
+
int rc = message.init ();
errno_assert (rc == 0);
}
Please sign in to comment.
Something went wrong with that request. Please try again.