engine termination on disconnect fixed

src/connect_session.cpp

@@ -104,7 +104,7 @@ void zmq::connect_session_t::start_connecting ()
     zmq_assert (false);
 }
 
-void zmq::connect_session_t::detach ()
+void zmq::connect_session_t::detached ()
 {
     //  Clean up the mess left over by the failed connection.
     clean_pipes ();

src/connect_session.hpp

@@ -39,11 +39,11 @@ namespace zmq
             const char *protocol_, const char *address_);
         ~connect_session_t ();
 
-        //  i_inout interface implementation.
-        void detach ();
-
     private:
 
+        //  Hook into session's disconnection mechanism.
+        void detached ();
+
         //  Start the connection process.
         void start_connecting ();
 

src/session.cpp

@@ -49,8 +49,10 @@ zmq::session_t::~session_t ()
 
 void zmq::session_t::terminate ()
 {
-    //  TODO:
+    if (in_pipe)
-    zmq_assert (false);
+        in_pipe->terminate ();
+    if (out_pipe)
+        out_pipe->terminate ();
 }
 
 bool zmq::session_t::read (::zmq_msg_t *msg_)
@@ -228,6 +230,14 @@ void zmq::session_t::process_attach (i_engine *engine_,
     attached (peer_identity_);
 }
 
+void zmq::session_t::detach ()
+{
+    //  Engine is dead. Let's forget about it.
+    engine = NULL;
+
+    detached ();
+}
+
 void zmq::session_t::process_term ()
 {
     //  Here we are pugging into the own_t's termination mechanism.

src/session.hpp

@@ -46,6 +46,7 @@ namespace zmq
         bool read (::zmq_msg_t *msg_);
         bool write (::zmq_msg_t *msg_);
         void flush ();
+        void detach ();
 
         void attach_pipes (class reader_t *inpipe_, class writer_t *outpipe_,
             const blob_t &peer_identity_);

src/transient_session.cpp

@@ -29,7 +29,7 @@ zmq::transient_session_t::~transient_session_t ()
 {
 }
 
-void zmq::transient_session_t::detach ()
+void zmq::transient_session_t::detached ()
 {
     //  There's no way to reestablish a transient session. Tear it down.
     terminate ();

src/transient_session.hpp

@@ -36,9 +36,10 @@ namespace zmq
             class socket_base_t *socket_, const options_t &options_);
         ~transient_session_t ();
 
-        //  i_inout interface implementation.
+    private:
-        void detach ();
 
+        //  Hook into session's disconnection mechanism.
+        void detached ();
     };
 
 }