From 7146ef85e96551ce6f7b80d014463f246d09c878 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Wed, 2 Dec 2009 21:26:47 +0100 Subject: seqnum mechanism automated --- src/zmq_listener_init.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'src/zmq_listener_init.cpp') diff --git a/src/zmq_listener_init.cpp b/src/zmq_listener_init.cpp index 0d9488d..632bebe 100644 --- a/src/zmq_listener_init.cpp +++ b/src/zmq_listener_init.cpp @@ -83,7 +83,10 @@ void zmq::zmq_listener_init_t::flush () // Reserve a sequence number for following 'attach' command. session->inc_seqnum (); } - send_attach (session, engine); + + // No need to increment seqnum as it was laready incremented above. + send_attach (session, engine, false); + engine = NULL; // Destroy the init object. @@ -103,7 +106,6 @@ void zmq::zmq_listener_init_t::process_plug () { zmq_assert (engine); engine->plug (this); - owned_t::process_plug (); } void zmq::zmq_listener_init_t::process_unplug () -- cgit v1.2.3