diff options
Diffstat (limited to 'TAO/tao/default_resource.cpp')
| -rw-r--r-- | TAO/tao/default_resource.cpp | 487 |
1 files changed, 0 insertions, 487 deletions
diff --git a/TAO/tao/default_resource.cpp b/TAO/tao/default_resource.cpp deleted file mode 100644 index 433ac742f64..00000000000 --- a/TAO/tao/default_resource.cpp +++ /dev/null @@ -1,487 +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 "ace/Select_Reactor.h" -#include "ace/FlReactor.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_type_ (TAO_REACTOR_SELECT_MT), - cdr_allocator_type_ (TAO_ALLOCATOR_THREAD_LOCK), - protocol_factories_ () -{ -} - -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], - "-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, - "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])); - } - } - - 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 (ACE_LACKS_UNIX_DOMAIN_SOCKETS) - 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 /* ACE_LACKS_UNIX_DOMAIN_SOCKETS */ - 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) -{ - return new TAO_Acceptor_Registry; -} - -TAO_Connector_Registry* -TAO_Default_Resource_Factory::get_connector_registry (void) -{ - return new TAO_Connector_Registry; -} - -// @@ TODO We may be changing the state of the global -// Allocated_Resources structure, but without any locks? -// It seems to be done all over the place. - -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, 0); - break; - - case TAO_REACTOR_SELECT_ST: - ACE_NEW_RETURN (impl, TAO_NULL_LOCK_REACTOR, 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_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, 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; -} - -// **************************************************************** - -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 */ |