diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-09-16 21:19:02 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-09-16 21:19:02 +0000 |
commit | 40fdc8a404e75ab03b68cc62e9987cf208fd8c30 (patch) | |
tree | 37d9c4d3abe4aefd8a34ed797883dd2cd4862ca7 /TAO/tao/Connection_Handler.cpp | |
parent | c254b281f1b9a4ca19dd0c3ee73a0654a7718909 (diff) | |
download | ATCD-40fdc8a404e75ab03b68cc62e9987cf208fd8c30.tar.gz |
This commit was manufactured by cvs2svn to create branchtypecode-overhaul
'typecode-overhaul'.
Diffstat (limited to 'TAO/tao/Connection_Handler.cpp')
-rw-r--r-- | TAO/tao/Connection_Handler.cpp | 53 |
1 files changed, 4 insertions, 49 deletions
diff --git a/TAO/tao/Connection_Handler.cpp b/TAO/tao/Connection_Handler.cpp index fdfe3ef99e6..9ae1a7c2583 100644 --- a/TAO/tao/Connection_Handler.cpp +++ b/TAO/tao/Connection_Handler.cpp @@ -209,43 +209,6 @@ TAO_Connection_Handler::handle_output_eh ( int TAO_Connection_Handler::handle_input_eh ( - ACE_HANDLE h, ACE_Event_Handler *eh) -{ - if (this->transport ()->acts_as_server () && - this->orb_core_->get_tss_resources ()->upcalls_temporarily_suspended_on_this_thread_) - { -#if 0 // DON'T IMPLEMENT YET, BUT RECORD THE IDEA FOR POSTERITY - // ACE_Time_Value this->spin_prevention_backoff_delay_; - ACE_OS::usleep (this->spin_prevention_backoff_delay_); - this->spin_prevention_backoff_delay_ = 2 * this->spin_prevention_backoff_delay_ + 1; -#endif - if (TAO_debug_level > 6) - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Connection_Handler[%d] - not going to handle_input " - "on Transport %d " - "because upcalls temporarily suspended on this thread\n", - this->transport()->id(), - this->transport()->id())); - return 0; - } - -#if 0 - this->spin_prevention_backoff_delay_ = 0; -#endif - - int result = this->handle_input_internal (h, eh); - - if (result == -1) - { - this->close_connection (); - return 0; - } - - return result; -} - -int -TAO_Connection_Handler::handle_input_internal ( ACE_HANDLE h, ACE_Event_Handler * eh) { // Let the transport know that it is used @@ -302,7 +265,7 @@ TAO_Connection_Handler::close_connection_eh (ACE_Event_Handler *eh) { ACE_DEBUG ((LM_DEBUG, "TAO (%P|%t) - Connection_Handler[%d]::" - "close_connection_eh, purging entry from cache\n", + "close_connection, purging entry from cache\n", handle)); } @@ -348,7 +311,7 @@ TAO_Connection_Handler::close_connection_eh (ACE_Event_Handler *eh) { ACE_DEBUG ((LM_DEBUG, "TAO (%P|%t) - Connection_Handler[%d]::" - "close_connection_eh, removing from the reactor\n", + "close_connection, removing from the reactor\n", handle)); } @@ -362,7 +325,7 @@ TAO_Connection_Handler::close_connection_eh (ACE_Event_Handler *eh) { ACE_DEBUG ((LM_DEBUG, "TAO (%P|%t) - Connection_Handler[%d]::" - "close_connection_eh, cancel all timers\n", + "close_connection, cancel all timers\n", handle)); } @@ -386,7 +349,7 @@ TAO_Connection_Handler::close_connection_eh (ACE_Event_Handler *eh) { ACE_DEBUG ((LM_DEBUG, "TAO (%P|%t) - Connection_Handler[%d]::" - "close_connection_eh\n", + "close_connection\n", id)); } @@ -408,11 +371,3 @@ void TAO_Connection_Handler::pos_io_hook (int & ) { } - -int -TAO_Connection_Handler::close_handler (void) -{ - this->state_changed (TAO_LF_Event::LFS_CONNECTION_CLOSED); - this->transport ()->remove_reference (); - return 0; -} |