Introduces bi-directional pipes

So far, there was a pair of unidirectional pipes between a socket
and a session (or an inproc peer). This resulted in complex
problems with half-closed states and tracking which inpipe
corresponds to which outpipe.

This patch doesn't add any functionality in itself, but is
essential for further work on features like subscription
forwarding.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

1 files changed, 3 insertions, 0 deletions

diff --git a/src/own.cpp b/src/own.cpp
index 4cbfdd6..cdf20a4 100644
--- a/src/own.cpp
+++ b/src/own.cpp
@@ -173,6 +173,7 @@ void zmq::own_t::process_term (int linger_)
 void zmq::own_t::register_term_acks (int count_)
 {
     term_acks += count_;
+    printf ("reg %d acks (%p, %d)\n", count_, (void*) this, term_acks);
 }
 
 void zmq::own_t::unregister_term_ack ()
@@ -180,6 +181,8 @@ void zmq::own_t::unregister_term_ack ()
     zmq_assert (term_acks > 0);
     term_acks--;
 
+    printf ("unreg 1 acks (%p, %d)\n", (void*) this, term_acks);
+
     //  This may be a last ack we are waiting for before termination...
     check_term_acks (); 
 }