summaryrefslogtreecommitdiff
path: root/src/dispatcher.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-12-02 21:26:47 +0100
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-12-02 21:26:47 +0100
commit7146ef85e96551ce6f7b80d014463f246d09c878 (patch)
tree103ccf90868acc3982987643817f385fbde76681 /src/dispatcher.cpp
parentcb84580bbced0b5d34ddcbac6e0aed5d0ad7cae6 (diff)
seqnum mechanism automated
Diffstat (limited to 'src/dispatcher.cpp')
-rw-r--r--src/dispatcher.cpp2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/dispatcher.cpp b/src/dispatcher.cpp
index 1e41ee8..51143b3 100644
--- a/src/dispatcher.cpp
+++ b/src/dispatcher.cpp
@@ -252,6 +252,8 @@ zmq::socket_base_t *zmq::dispatcher_t::find_endpoint (const char *addr_)
// Increment the command sequence number of the peer so that it won't
// get deallocated until "bind" command is issued by the caller.
+ // The subsequent 'bind' has to be called with inc_seqnum parameter
+ // set to false, so that the seqnum isn't incremented twice.
endpoint->inc_seqnum ();
endpoints_sync.unlock ();