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, 3 insertions, 11 deletions

diff --git a/src/fq.hpp b/src/fq.hpp
index bbe1b59..106e978 100644
--- a/src/fq.hpp
+++ b/src/fq.hpp
@@ -35,18 +35,16 @@ namespace zmq
     {
     public:
 
-        fq_t (class own_t *sink_);
+        fq_t ();
         ~fq_t ();
 
         void attach (pipe_t *pipe_);
-        void terminate ();
+        void activated (pipe_t *pipe_);
+        void terminated (pipe_t *pipe_);
 
         int recv (msg_t *msg_, int flags_);
         bool has_in ();
 
-        void activated (pipe_t *pipe_);
-        void terminated (pipe_t *pipe_);
-
     private:
 
         //  Inbound pipes.
@@ -64,12 +62,6 @@ namespace zmq
         //  there are following parts still waiting in the current pipe.
         bool more;
 
-        //  Object to send events to.
-        class own_t *sink;
-
-        //  If true, termination process is already underway.
-        bool terminating;
-
         fq_t (const fq_t&);
         const fq_t &operator = (const fq_t&);
     };