summaryrefslogtreecommitdiff
path: root/TAO/tao/UIOP_Transport.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/UIOP_Transport.cpp')
-rw-r--r--TAO/tao/UIOP_Transport.cpp6
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);
}