Move the pipe termination code to socket_base_t

So far, the pipe termination code was spread among socket type
classes, fair queuer, load balancer, etc. This patch moves
all the associated logic to a single place.

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

1 files changed, 4 insertions, 11 deletions

diff --git a/src/lb.hpp b/src/lb.hpp
index d764f6d..0dfd25e 100644
--- a/src/lb.hpp
+++ b/src/lb.hpp
@@ -34,17 +34,16 @@ namespace zmq
     {
     public:
 
-        lb_t (class own_t *sink_);
+        lb_t ();
         ~lb_t ();
 
         void attach (pipe_t *pipe_);
-        void terminate ();
-        int send (msg_t *msg_, int flags_);
-        bool has_out ();
-
         void activated (pipe_t *pipe_);
         void terminated (pipe_t *pipe_);
 
+        int send (msg_t *msg_, int flags_);
+        bool has_out ();
+
     private:
 
         //  List of outbound pipes.
@@ -64,12 +63,6 @@ namespace zmq
         //  True if we are dropping current message.
         bool dropping;
 
-        //  Object to send events to.
-        class own_t *sink;
-
-        //  If true, termination process is already underway.
-        bool terminating;
-
         lb_t (const lb_t&);
         const lb_t &operator = (const lb_t&);
     };