diff options
Diffstat (limited to 'TAO/tao/UIOP_Transport.cpp')
-rw-r--r-- | TAO/tao/UIOP_Transport.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/TAO/tao/UIOP_Transport.cpp b/TAO/tao/UIOP_Transport.cpp index 4b777387990..c2dab7b6fb4 100644 --- a/TAO/tao/UIOP_Transport.cpp +++ b/TAO/tao/UIOP_Transport.cpp @@ -235,6 +235,7 @@ TAO_UIOP_Client_Transport::handle_client_input (int /* block */, ACE_DEBUG ((LM_DEBUG, "TAO (%P|%t) UIOP_Transport::handle_client_input -" " nil message state\n")); + this->tms_->connection_closed (); return -1; } @@ -248,6 +249,7 @@ TAO_UIOP_Client_Transport::handle_client_input (int /* block */, ACE_DEBUG ((LM_DEBUG, "TAO (%P|%t) - %p\n", "UIOP_Transport::handle_client_input, handle_input")); + this->tms_->connection_closed (); return -1; } if (result == 0) @@ -264,6 +266,7 @@ TAO_UIOP_Client_Transport::handle_client_input (int /* block */, "TAO (%P|%t) - %p\n", "UIOP_Transport::handle_client_input, parse reply")); message_state->reset (); + this->tms_->connection_closed (); return -1; } @@ -282,6 +285,7 @@ TAO_UIOP_Client_Transport::handle_client_input (int /* block */, "handle_client_input - " "dispatch reply failed\n")); message_state->reset (); + this->tms_->connection_closed (); return -1; } @@ -307,7 +311,7 @@ TAO_UIOP_Client_Transport::register_handler (void) ACE_Reactor *r = this->orb_core ()->reactor (); if (r == this->handler ()->reactor ()) return 0; - + return r->register_handler (this->handler (), ACE_Event_Handler::READ_MASK); } |