diff options
Diffstat (limited to 'TAO/tao/Acceptor_Impl.cpp')
| -rw-r--r-- | TAO/tao/Acceptor_Impl.cpp | 164 |
1 files changed, 0 insertions, 164 deletions
diff --git a/TAO/tao/Acceptor_Impl.cpp b/TAO/tao/Acceptor_Impl.cpp deleted file mode 100644 index fa123ff5473..00000000000 --- a/TAO/tao/Acceptor_Impl.cpp +++ /dev/null @@ -1,164 +0,0 @@ -// This may look like C, but it's really -*- C++ -*- -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// TAO -// -// = FILENAME -// Acceptor_Impl.cpp -// -// = AUTHOR -// Carlos O'Ryan <coryan@cs.wustl.edu> -// Ossama Othman <othman@cs.wustl.edu> -// -// ============================================================================ - -#ifndef TAO_ACCEPTOR_IMPL_C -#define TAO_ACCEPTOR_IMPL_C - -#include "tao/Acceptor_Impl.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -#include "tao/ORB_Core.h" -#include "tao/Server_Strategy_Factory.h" -#include "tao/Connector_Registry.h" -#include "tao/debug.h" - -#if !defined(__ACE_INLINE__) -#include "tao/Acceptor_Impl.i" -#endif /* __ACE_INLINE__ */ - -ACE_RCSID(tao, Acceptor_Impl, "$Id$") - -//////////////////////////////////////////////////////////////////////////////// - -template <class SVC_HANDLER> -TAO_Creation_Strategy<SVC_HANDLER>::TAO_Creation_Strategy (TAO_ORB_Core *orb_core) - : orb_core_ (orb_core) -{ -} - -template <class SVC_HANDLER> int -TAO_Creation_Strategy<SVC_HANDLER>::make_svc_handler (SVC_HANDLER *&sh) -{ - if (sh == 0) - ACE_NEW_RETURN (sh, - SVC_HANDLER (this->orb_core_), - -1); - - return 0; -} - -//////////////////////////////////////////////////////////////////////////////// - -template <class SVC_HANDLER> -TAO_Concurrency_Strategy<SVC_HANDLER>::TAO_Concurrency_Strategy (TAO_ORB_Core *orb_core) - : orb_core_ (orb_core) -{ -} - -template <class SVC_HANDLER> int -TAO_Concurrency_Strategy<SVC_HANDLER>::activate_svc_handler (SVC_HANDLER *sh, - void *arg) -{ - if (this->ACE_Concurrency_Strategy<SVC_HANDLER>::activate_svc_handler (sh, - arg) == -1) - return -1; - - TAO_Server_Strategy_Factory *f = - this->orb_core_->server_factory (); - - if (f->activate_server_connections ()) - return sh->activate (f->server_connection_thread_flags (), - f->server_connection_thread_count ()); - - return this->orb_core_->reactor ()->register_handler - (sh, ACE_Event_Handler::READ_MASK); -} - -//////////////////////////////////////////////////////////////////////////////// - -template <class SVC_HANDLER, ACE_PEER_ACCEPTOR_1> -TAO_Accept_Strategy<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>::TAO_Accept_Strategy (TAO_ORB_Core *orb_core) - : orb_core_ (orb_core) -{ -} - -template <class SVC_HANDLER, ACE_PEER_ACCEPTOR_1> int -TAO_Accept_Strategy<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>::open (const ACE_PEER_ACCEPTOR_ADDR &local_addr, - int restart) -{ - int result = ACCEPT_STRATEGY_BASE::open (local_addr, - restart); - - if (result == 0) - return result; - - // If the error occured due to the fact that the open handle limit - // was exhausted, then purge some "old" connections. - result = this->out_of_sockets_handler (); - if (result == -1) - return -1; - - // If we are able to purge, try again. - return ACCEPT_STRATEGY_BASE::open (local_addr, restart); -} - -template <class SVC_HANDLER, ACE_PEER_ACCEPTOR_1> int -TAO_Accept_Strategy<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>::accept_svc_handler (SVC_HANDLER *svc_handler) -{ - int result = ACCEPT_STRATEGY_BASE::accept_svc_handler (svc_handler); - - if (result == 0) - return result; - - // If the error occured due to the fact that the open handle limit - // was exhausted, then purge some "old" connections. - this->out_of_sockets_handler (); - - return result; -} - -template <class SVC_HANDLER, ACE_PEER_ACCEPTOR_1> int -TAO_Accept_Strategy<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>::out_of_sockets_handler (void) -{ - if (ACE::out_of_handles (errno)) - { - // Close some cached connections by explicitly purging the - // connection cache maintained by the connectors in the - // connector registry. - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "Purging connections from Connectors in Connector Registry of all ORBs...\n")); - - ACE_MT (ACE_GUARD_RETURN (ACE_SYNCH_RECURSIVE_MUTEX, guard, - *ACE_Static_Object_Lock::instance (), 0)); - - TAO_ORB_Table *table = TAO_ORB_Table::instance (); - TAO_ORB_Table::Iterator end = table->end (); - for (TAO_ORB_Table::Iterator iterator = table->begin (); - iterator != end; - ++iterator) - { - TAO_ORB_Core *orb_core = (*iterator).int_id_; - - int result = orb_core->connector_registry ()->purge_connections (); - - if (result != 0) - return result; - } - - return 0; - } - - return -1; -} - -//////////////////////////////////////////////////////////////////////////////// - -#endif /* TAO_ACCEPTOR_IMPL_C */ |