diff options
| author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-02 21:26:47 +0100 |
|---|---|---|
| committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-02 21:26:47 +0100 |
| commit | 7146ef85e96551ce6f7b80d014463f246d09c878 (patch) | |
| tree | 103ccf90868acc3982987643817f385fbde76681 /src/zmq_connecter_init.cpp | |
| parent | cb84580bbced0b5d34ddcbac6e0aed5d0ad7cae6 (diff) | |
seqnum mechanism automated
Diffstat (limited to 'src/zmq_connecter_init.cpp')
| -rw-r--r-- | src/zmq_connecter_init.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/zmq_connecter_init.cpp b/src/zmq_connecter_init.cpp index f0cbf90..3f165cd 100644 --- a/src/zmq_connecter_init.cpp +++ b/src/zmq_connecter_init.cpp @@ -67,7 +67,8 @@ bool zmq::zmq_connecter_init_t::read (::zmq_msg_t *msg_) zmq_assert (false); } - send_attach (session, engine); + // No need to increment seqnum as it was alredy incremented above. + send_attach (session, engine, false); engine = NULL; // Destroy the init object. @@ -113,7 +114,6 @@ void zmq::zmq_connecter_init_t::process_plug () { zmq_assert (engine); engine->plug (this); - owned_t::process_plug (); } void zmq::zmq_connecter_init_t::process_unplug () |