summaryrefslogtreecommitdiff
path: root/src/session.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-05-26 11:30:25 +0200
committerMartin Sustrik <sustrik@250bpm.com>2011-05-26 11:30:25 +0200
commit718885fdcd7af797f940078ca8c22aebab93c8bb (patch)
tree33d0d96a5d122338ee8eaddc44fd138b5f6d0651 /src/session.hpp
parent87a6490b39c44e8f9c521f6ccea14f800a712d3f (diff)
Pending messages are delivered even if connection doesn't exist yet
Bug in previous refactoring fixed. Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/session.hpp')
-rw-r--r--src/session.hpp10
1 files changed, 3 insertions, 7 deletions
diff --git a/src/session.hpp b/src/session.hpp
index f1564d8..8bca735 100644
--- a/src/session.hpp
+++ b/src/session.hpp
@@ -59,10 +59,6 @@ namespace zmq
protected:
- // This function allows to shut down the session even though
- // there are messages pending.
- void terminate ();
-
// Two events for the derived session type. Attached is triggered
// when session is attached to a peer. The function can reject the new
// peer by returning false. Detached is triggered at the beginning of
@@ -105,9 +101,9 @@ namespace zmq
// is still in the in pipe.
bool incomplete_in;
- // If true the termination process is already underway, ie. term ack
- // for the pipe was already registered etc.
- bool terminating;
+ // True if termination have been suspended to push the pending
+ // messages to the network.
+ bool pending;
// The protocol I/O engine connected to the session.
struct i_engine *engine;