rollback of half-processed messages in case of disconnection

1 files changed, 4 insertions, 0 deletions

diff --git a/src/session.hpp b/src/session.hpp
index 25a0d12..9bda1ad 100644
--- a/src/session.hpp
+++ b/src/session.hpp
@@ -72,6 +72,10 @@ namespace zmq
         //  Inbound pipe, i.e. one the session is getting messages from.
         class reader_t *in_pipe;
 
+        //  This flag is true if the remainder of the message being processed
+        //  is still in the in pipe.
+        bool incomplete_in;
+
         //  If true, in_pipe is active. Otherwise there are no messages to get.
         bool active;