seqnum mechanism automated

1 files changed, 9 insertions, 3 deletions

diff --git a/src/object.hpp b/src/object.hpp
index 9d4cd9a..84a57cd 100644
--- a/src/object.hpp
+++ b/src/object.hpp
@@ -63,13 +63,14 @@ namespace zmq
         //  Derived object can use these functions to send commands
         //  to other objects.
         void send_stop ();
-        void send_plug (class owned_t *destination_);
+        void send_plug (class owned_t *destination_, bool inc_seqnum_ = true);
         void send_own (class socket_base_t *destination_,
             class owned_t *object_);
         void send_attach (class session_t *destination_,
-            struct i_engine *engine_);
+            struct i_engine *engine_, bool inc_seqnum_ = true);
         void send_bind (class socket_base_t *destination_,
-             class reader_t *in_pipe_, class writer_t *out_pipe_);
+             class reader_t *in_pipe_, class writer_t *out_pipe_,
+             bool inc_seqnum_ = true);
         void send_revive (class object_t *destination_);
         void send_pipe_term (class writer_t *destination_);
         void send_pipe_term_ack (class reader_t *destination_);
@@ -93,6 +94,11 @@ namespace zmq
         virtual void process_term ();
         virtual void process_term_ack ();
 
+        //  Special handler called after a command that requires a seqnum
+        //  was processed. The implementation should catch up with its counter
+        //  of processed commands here.
+        virtual void process_seqnum ();
+
         //  Pointer to the root of the infrastructure.
         class dispatcher_t *dispatcher;