diff options
Diffstat (limited to 'TAO/tao/default_resource.cpp')
| -rw-r--r-- | TAO/tao/default_resource.cpp | 719 |
1 files changed, 0 insertions, 719 deletions
diff --git a/TAO/tao/default_resource.cpp b/TAO/tao/default_resource.cpp deleted file mode 100644 index fd87fc53217..00000000000 --- a/TAO/tao/default_resource.cpp +++ /dev/null @@ -1,719 +0,0 @@ -// $Id$ - -#include "tao/default_resource.h" -#include "tao/Client_Strategy_Factory.h" -#include "tao/Server_Strategy_Factory.h" -#include "tao/ORB_Core.h" -#include "tao/debug.h" -#include "tao/IIOP_Factory.h" -#include "tao/UIOP_Factory.h" -#include "tao/Acceptor_Registry.h" -#include "tao/Connector_Registry.h" -#include "tao/Single_Reactor.h" -#include "tao/Reactor_Per_Priority.h" -#include "tao/Direct_Priority_Mapping.h" -#include "tao/Linear_Priority_Mapping.h" - -#include "ace/Select_Reactor.h" -#include "ace/FlReactor.h" -#include "ace/TkReactor.h" -#include "ace/WFMO_Reactor.h" -#include "ace/Msg_WFMO_Reactor.h" -#include "ace/TP_Reactor.h" -#include "ace/Dynamic_Service.h" -#include "ace/Arg_Shifter.h" - -#if !defined (__ACE_INLINE__) -# include "tao/default_resource.i" -#endif /* ! __ACE_INLINE__ */ - -ACE_RCSID(tao, default_resource, "$Id$") - -TAO_Default_Resource_Factory::TAO_Default_Resource_Factory (void) - : use_tss_resources_ (0), - use_locked_data_blocks_ (1), - reactor_registry_type_ (TAO_SINGLE_REACTOR), - reactor_type_ (TAO_REACTOR_SELECT_MT), - cdr_allocator_type_ (TAO_ALLOCATOR_THREAD_LOCK), - protocol_factories_ (), - connection_caching_type_ (TAO_CONNECTION_CACHING_STRATEGY), - purge_percentage_ (TAO_PURGE_PERCENT), - reactor_mask_signals_ (1), - sched_policy_ (ACE_SCHED_OTHER), - priority_mapping_type_ (TAO_PRIORITY_MAPPING_LINEAR) -{ -} - -TAO_Default_Resource_Factory::~TAO_Default_Resource_Factory (void) -{ - TAO_ProtocolFactorySetItor end = this->protocol_factories_.end (); - - for (TAO_ProtocolFactorySetItor iterator = - this->protocol_factories_.begin (); - iterator != end; - ++iterator) - delete *iterator; - - this->protocol_factories_.reset (); -} - -int -TAO_Default_Resource_Factory::init (int argc, char **argv) -{ - ACE_TRACE ("TAO_Default_Server_Strategy_Factory::parse_args"); - - for (int curarg = 0; curarg < argc; curarg++) - if (ACE_OS::strcasecmp (argv[curarg], - "-ORBResources") == 0) - { - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, - "global") == 0) - this->use_tss_resources_ = 0; - else if (ACE_OS::strcasecmp (name, - "tss") == 0) - this->use_tss_resources_ = 1; - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBReactorLock") == 0) - { - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Resource obsolete -ORBReactorLock " - "option, please use -ORBReactorType\n")); - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, "null") == 0) - reactor_type_ = TAO_REACTOR_SELECT_ST; - else if (ACE_OS::strcasecmp (name, "token") == 0) - reactor_type_= TAO_REACTOR_SELECT_MT; - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBReactorMaskSignals") == 0) - { - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, "0") == 0) - this->reactor_mask_signals_ = 0; - else if (ACE_OS::strcasecmp (name, "1") == 0) - this->reactor_mask_signals_= 1; - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBReactorRegistry") == 0) - { - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, - "single") == 0) - this->reactor_registry_type_ = TAO_SINGLE_REACTOR; - else if (ACE_OS::strcasecmp (name, - "per-priority") == 0) - this->reactor_registry_type_ = TAO_REACTOR_PER_PRIORITY; - else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - unknown argument" - " <%s> for -ORBReactorRegistry\n", name)); - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBReactorType") == 0) - { - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, - "select_mt") == 0) - reactor_type_ = TAO_REACTOR_SELECT_MT; - else if (ACE_OS::strcasecmp (name, - "select_st") == 0) - reactor_type_ = TAO_REACTOR_SELECT_ST; - else if (ACE_OS::strcasecmp (name, - "fl") == 0) -#if defined(ACE_HAS_FL) - reactor_type_ = TAO_REACTOR_FL; -#else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - FlReactor" - " not supported on this platform\n")); -#endif /* ACE_HAS_FL */ - else if (ACE_OS::strcasecmp (name, "tk_reactor") == 0) -#if defined(ACE_HAS_TK) - reactor_type_ = TAO_REACTOR_TK; -#else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - TkReactor" - " not supported on this platform\n")); -#endif /* ACE_HAS_TK */ - else if (ACE_OS::strcasecmp (name, - "wfmo") == 0) -#if defined(ACE_WIN32) - reactor_type_ = TAO_REACTOR_WFMO; -#else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - WFMO Reactor" - " not supported on this platform\n")); -#endif /* ACE_WIN32 */ - else if (ACE_OS::strcasecmp (name, - "msg_wfmo") == 0) -#if defined(ACE_WIN32) - reactor_type_ = TAO_REACTOR_MSGWFMO; -#else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - MsgWFMO Reactor" - " not supported on this platform\n")); -#endif /* ACE_WIN32 */ - - else if (ACE_OS::strcasecmp (name, - "tp") == 0) - reactor_type_ = TAO_REACTOR_TP; - else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - unknown argument" - " <%s> for -ORBreactortype\n", name)); - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBInputCDRAllocator") == 0) - { - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, - "null") == 0) - { - this->cdr_allocator_type_ = TAO_ALLOCATOR_NULL_LOCK; - this->use_locked_data_blocks_ = 0; - } - else if (ACE_OS::strcasecmp (name, - "thread") == 0) - { - this->cdr_allocator_type_ = TAO_ALLOCATOR_THREAD_LOCK; - this->use_locked_data_blocks_ = 1; - } - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBProtocolFactory") == 0) - { - TAO_ProtocolFactorySet *pset = this->get_protocol_factories (); - curarg++; - if (curarg < argc) - { - TAO_Protocol_Item *item = 0; - ACE_NEW_RETURN (item, - TAO_Protocol_Item (argv[curarg]), - -1); - if (pset->insert (item) == -1) - ACE_ERROR ((LM_ERROR, - "(%P|%t) Unable to add protocol factories for %s: %p\n", - argv[curarg])); - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBConnectionCachingStrategy") == 0) - { - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, - "lru") == 0) - this->connection_caching_type_ = TAO_Resource_Factory::LRU; - else if (ACE_OS::strcasecmp (name, - "lfu") == 0) - this->connection_caching_type_ = TAO_Resource_Factory::LFU; - else if (ACE_OS::strcasecmp (name, - "fifo") == 0) - this->connection_caching_type_ = TAO_Resource_Factory::FIFO; - else if (ACE_OS::strcasecmp (name, - "null") == 0) - this->connection_caching_type_ = TAO_Resource_Factory::NOOP; - else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - unknown argument" - " <%s> for -ORBConnectionCachingStrategy\n", name)); - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBPurgePercentage") == 0) - { - curarg++; - if (curarg < argc) - this->purge_percentage_ = ACE_OS::atoi (argv[curarg]); - else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - unknown argument" - "for -ORBPurgePercentage\n")); - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBSchedPolicy") == 0) - { - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, - "SCHED_OTHER") == 0) - this->sched_policy_ = ACE_SCHED_OTHER; - else if (ACE_OS::strcasecmp (name, - "SCHED_FIFO") == 0) - this->sched_policy_ = ACE_SCHED_FIFO; - else if (ACE_OS::strcasecmp (name, - "SCHED_RR") == 0) - this->sched_policy_ = ACE_SCHED_RR; - else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - unknown argument" - " <%s> for -ORBSchedPolicy\n", name)); - } - } - - else if (ACE_OS::strcasecmp (argv[curarg], - "-ORBPriorityMapping") == 0) - { - curarg++; - if (curarg < argc) - { - char *name = argv[curarg]; - - if (ACE_OS::strcasecmp (name, - "linear") == 0) - this->priority_mapping_type_ = TAO_PRIORITY_MAPPING_LINEAR; - else if (ACE_OS::strcasecmp (name, - "direct") == 0) - this->priority_mapping_type_ = TAO_PRIORITY_MAPPING_DIRECT; - else - ACE_DEBUG ((LM_DEBUG, - "TAO_Default_Factory - unknown argument" - " <%s> for -ORBPriorityMapping\n", name)); - } - } - - return 0; -} - -int -TAO_Default_Resource_Factory::init_protocol_factories (void) -{ - TAO_ProtocolFactorySetItor end = protocol_factories_.end (); - TAO_ProtocolFactorySetItor factory = protocol_factories_.begin (); - - if (factory == end) - { - TAO_Protocol_Factory *protocol_factory = 0; - TAO_Protocol_Item *item = 0; - - protocol_factory = - ACE_Dynamic_Service<TAO_Protocol_Factory>::instance ("IIOP_Factory"); - - if (protocol_factory == 0) - { - if (TAO_orbdebug) - ACE_ERROR ((LM_WARNING, - "TAO (%P|%t) No %s found in Service Repository. " - "Using default instance IIOP Protocol Factory.\n")); - - ACE_NEW_RETURN (protocol_factory, - TAO_IIOP_Protocol_Factory, - -1); - } - - ACE_NEW_RETURN (item, TAO_Protocol_Item ("IIOP_Factory"), -1); - item->factory (protocol_factory); - - if (this->protocol_factories_.insert (item) == -1) - { - delete item; - delete protocol_factory; - - ACE_ERROR_RETURN ((LM_ERROR, - "TAO (%P|%t) Unable to add " - "<%s> to protocol factory set.\n", - item->protocol_name ().c_str ()), - -1); - } - - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, - "TAO (%P|%t) Loaded default protocol <IIOP_Factory>\n")); - } - -#if defined (TAO_HAS_UIOP) - protocol_factory = - ACE_Dynamic_Service<TAO_Protocol_Factory>::instance ("UIOP_Factory"); - - if (protocol_factory == 0) - { - if (TAO_orbdebug) - ACE_ERROR ((LM_WARNING, - "(%P|%t) WARNING - No %s found in Service Repository." - " Using default instance.\n", - "UIOP Protocol Factory")); - - ACE_NEW_RETURN (protocol_factory, - TAO_UIOP_Protocol_Factory, - -1); - } - - ACE_NEW_RETURN (item, TAO_Protocol_Item ("UIOP_Factory"), -1); - item->factory (protocol_factory); - - if (this->protocol_factories_.insert (item) == -1) - { - delete item; - delete protocol_factory; - - ACE_ERROR_RETURN ((LM_ERROR, - "TAO (%P|%t) Unable to add " - "<%s> to protocol factory set.\n", - item->protocol_name ().c_str ()), - -1); - } - - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, - "TAO (%P|%t) Loaded default protocol <UIOP_Factory>\n")); - } -#endif /* TAO_HAS_UIOP */ - return 0; - } - - for (; factory != end; factory++) - { - const ACE_CString &name = (*factory)->protocol_name (); - (*factory)->factory ( - ACE_Dynamic_Service<TAO_Protocol_Factory>::instance (name.c_str ())); - if ((*factory)->factory () == 0) - { - ACE_ERROR_RETURN ((LM_ERROR, - "TAO (%P|%t) Unable to load protocol <%s>, %p\n", - name.c_str (), ""), - -1); - } - - if (TAO_debug_level > 0) - { - ACE_DEBUG ((LM_DEBUG, - "TAO (%P|%t) Loaded protocol <%s>\n", - name.c_str ())); - } - } - return 0; -} - -int -TAO_Default_Resource_Factory::use_tss_resources (void) const -{ - return this->use_tss_resources_; -} - -int -TAO_Default_Resource_Factory::use_locked_data_blocks (void) const -{ - return this->use_locked_data_blocks_; -} - -TAO_ProtocolFactorySet * -TAO_Default_Resource_Factory::get_protocol_factories (void) -{ - return &protocol_factories_; -} - -TAO_Acceptor_Registry* -TAO_Default_Resource_Factory::get_acceptor_registry (void) -{ - TAO_Acceptor_Registry *ar = 0; - - ACE_NEW_RETURN(ar, - TAO_Acceptor_Registry, - 0); - - return ar; -} - -TAO_Connector_Registry* -TAO_Default_Resource_Factory::get_connector_registry (void) -{ - TAO_Connector_Registry *cr = 0; - - ACE_NEW_RETURN(cr, - TAO_Connector_Registry, - 0); - - return cr; -} - -TAO_Reactor_Registry * -TAO_Default_Resource_Factory::get_reactor_registry (void) -{ - TAO_Reactor_Registry *reactor_registry = 0; - switch (this->reactor_registry_type_) - { - default: - case TAO_SINGLE_REACTOR: - ACE_NEW_RETURN (reactor_registry, - TAO_Single_Reactor, - 0); - break; - - case TAO_REACTOR_PER_PRIORITY: - ACE_NEW_RETURN (reactor_registry, - TAO_Reactor_Per_Priority, - 0); - break; - } - - return reactor_registry; -} - -ACE_Reactor_Impl* -TAO_Default_Resource_Factory::allocate_reactor_impl (void) const -{ - ACE_Reactor_Impl *impl = 0; - switch (this->reactor_type_) - { - default: - case TAO_REACTOR_SELECT_MT: - ACE_NEW_RETURN (impl, - TAO_REACTOR ((ACE_Sig_Handler*)0, - (ACE_Timer_Queue*)0, - 0, - (ACE_Reactor_Notify*)0, - this->reactor_mask_signals_), - 0); - break; - - case TAO_REACTOR_SELECT_ST: - ACE_NEW_RETURN (impl, - TAO_NULL_LOCK_REACTOR ((ACE_Sig_Handler*)0, - (ACE_Timer_Queue*)0, - 0, - (ACE_Reactor_Notify*)0, - this->reactor_mask_signals_), - 0); - break; - - case TAO_REACTOR_FL: -#if defined(ACE_HAS_FL) - ACE_NEW_RETURN (impl, ACE_FlReactor, 0); -#endif /* ACE_HAS_FL */ - break; - - case TAO_REACTOR_TK: -#if defined(ACE_HAS_TK) - ACE_NEW_RETURN (impl, ACE_TkReactor, 0); -#endif /* ACE_HAS_TK */ - break; - - case TAO_REACTOR_WFMO: -#if defined(ACE_WIN32) && !defined (ACE_HAS_WINCE) - ACE_NEW_RETURN (impl, ACE_WFMO_Reactor, 0); -#endif /* ACE_WIN32 && !ACE_HAS_WINCE */ - break; - - case TAO_REACTOR_MSGWFMO: -#if defined(ACE_WIN32) - ACE_NEW_RETURN (impl, ACE_Msg_WFMO_Reactor, 0); -#endif /* ACE_WIN32 && !ACE_HAS_WINCE */ - break; - - case TAO_REACTOR_TP: - ACE_NEW_RETURN (impl, ACE_TP_Reactor ((ACE_Sig_Handler*)0, - (ACE_Timer_Queue*)0, - this->reactor_mask_signals_), - 0); - break; - } - return impl; -} - -ACE_Reactor * -TAO_Default_Resource_Factory::get_reactor (void) -{ - ACE_LOG_MSG->errnum (0); - - ACE_Reactor *reactor = 0; - ACE_NEW_RETURN (reactor, - ACE_Reactor (this->allocate_reactor_impl (), 1), - 0); - - if (ACE_LOG_MSG->errnum () != 0) - { - delete reactor; - reactor = 0; - } - - return reactor; -} - -typedef ACE_Malloc<ACE_LOCAL_MEMORY_POOL,ACE_Null_Mutex> NULL_LOCK_MALLOC; -typedef ACE_Allocator_Adapter<NULL_LOCK_MALLOC> NULL_LOCK_ALLOCATOR; - -typedef ACE_Malloc<ACE_LOCAL_MEMORY_POOL,ACE_SYNCH_MUTEX> LOCKED_MALLOC; -typedef ACE_Allocator_Adapter<LOCKED_MALLOC> LOCKED_ALLOCATOR; - -ACE_Allocator * -TAO_Default_Resource_Factory::input_cdr_dblock_allocator (void) -{ - ACE_Allocator *allocator = 0; - switch (this->cdr_allocator_type_) - { - case TAO_ALLOCATOR_NULL_LOCK: - ACE_NEW_RETURN (allocator, - NULL_LOCK_ALLOCATOR, - 0); - break; - - case TAO_ALLOCATOR_THREAD_LOCK: - default: - ACE_NEW_RETURN (allocator, - LOCKED_ALLOCATOR, - 0); - break; - } - - return allocator; -} - -ACE_Allocator * -TAO_Default_Resource_Factory::input_cdr_buffer_allocator (void) -{ - ACE_Allocator *allocator = 0; - switch (this->cdr_allocator_type_) - { - case TAO_ALLOCATOR_NULL_LOCK: - ACE_NEW_RETURN (allocator, - NULL_LOCK_ALLOCATOR, - 0); - break; - - case TAO_ALLOCATOR_THREAD_LOCK: - default: - ACE_NEW_RETURN (allocator, - LOCKED_ALLOCATOR, - 0); - break; - } - return allocator; -} - -ACE_Allocator* -TAO_Default_Resource_Factory::output_cdr_dblock_allocator (void) -{ - ACE_Allocator *allocator = 0; - ACE_NEW_RETURN (allocator, NULL_LOCK_ALLOCATOR, 0); - return allocator; -} - -ACE_Allocator * -TAO_Default_Resource_Factory::output_cdr_buffer_allocator (void) -{ - ACE_Allocator *allocator = 0; - ACE_NEW_RETURN (allocator, NULL_LOCK_ALLOCATOR, 0); - return allocator; -} - -TAO_Resource_Factory::Caching_Strategy -TAO_Default_Resource_Factory::connection_caching_strategy_type (void) const -{ - return this->connection_caching_type_; -} - -double -TAO_Default_Resource_Factory::purge_percentage (void) const -{ - return this->purge_percentage_; -} - -TAO_Priority_Mapping * -TAO_Default_Resource_Factory::get_priority_mapping (void) -{ -#if !defined (TAO_HAS_RT_CORBA) - return 0; -#else - TAO_Priority_Mapping *pm; - switch (this->priority_mapping_type_) - { - case TAO_PRIORITY_MAPPING_LINEAR: - ACE_NEW_RETURN (pm, - TAO_Linear_Priority_Mapping (this->sched_policy_), - 0); - break; - case TAO_PRIORITY_MAPPING_DIRECT: - ACE_NEW_RETURN (pm, - TAO_Direct_Priority_Mapping (this->sched_policy_), - 0); - break; - default: - ACE_NEW_RETURN (pm, - TAO_Priority_Mapping, - 0); - break; - } - return pm; -#endif /* TAO_HAS_RT_CORBA */ -} - -// **************************************************************** - -ACE_STATIC_SVC_DEFINE (TAO_Default_Resource_Factory, - ASYS_TEXT ("Resource_Factory"), - ACE_SVC_OBJ_T, - &ACE_SVC_NAME (TAO_Default_Resource_Factory), - ACE_Service_Type::DELETE_THIS | ACE_Service_Type::DELETE_OBJ, - 0) -ACE_FACTORY_DEFINE (TAO, TAO_Default_Resource_Factory) - -// **************************************************************** - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) - -template class ACE_Malloc<ACE_LOCAL_MEMORY_POOL,ACE_SYNCH_MUTEX>; -template class ACE_Allocator_Adapter<ACE_Malloc<ACE_LOCAL_MEMORY_POOL,ACE_SYNCH_MUTEX> >; - -template class ACE_Select_Reactor_Token_T<ACE_Noop_Token>; -template class ACE_Lock_Adapter<ACE_Select_Reactor_Token_T<ACE_Noop_Token> >; -template class ACE_Select_Reactor_T< ACE_Select_Reactor_Token_T<ACE_Noop_Token> >; - -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) - -#pragma instantiate ACE_Malloc<ACE_LOCAL_MEMORY_POOL,ACE_SYNCH_MUTEX> -#pragma instantiate ACE_Allocator_Adapter<ACE_Malloc<ACE_LOCAL_MEMORY_POOL,ACE_SYNCH_MUTEX> > - -#pragma instantiate ACE_Select_Reactor_Token_T<ACE_Noop_Token> -#pragma instantiate ACE_Lock_Adapter< ACE_Select_Reactor_Token_T<ACE_Noop_Token> > -#pragma instantiate ACE_Select_Reactor_T< ACE_Select_Reactor_Token_T<ACE_Noop_Token> > - -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |