TAO_Acceptor_Registry Class Reference

Acceptor Registry and Generic Acceptor interface definitions. All loaded ESIOP or GIOP acceptor bridges must register with this object. More...

#include <Acceptor_Registry.h>

Collaboration diagram for TAO_Acceptor_Registry:

[legend]List of all members.

Public Member Functions
	TAO_Acceptor_Registry (void)
	Default constructor.
	~TAO_Acceptor_Registry (void)
	Default destructor.
int	open (TAO_ORB_Core *orb_core, ACE_Reactor *reactor, const TAO_EndpointSet &endpoint_set, bool ignore_address)
	Initialize all registered acceptors. Return -1 on error.
int	close_all (void)
	Close all open acceptors.
size_t	endpoint_count (void)
	Returns the total number of endpoints in all of its acceptors.
int	is_collocated (const TAO_MProfile &mprofile)
TAO_Acceptor *	get_acceptor (CORBA::ULong tag)
	Return the acceptor bridges.
TAO_AcceptorSetIterator	begin (void)
TAO_AcceptorSetIterator	end (void)
Private Member Functions
int	open_default (TAO_ORB_Core *orb_core, ACE_Reactor *reactor, const char *options)
	Create a default acceptor for all loaded protocols.
int	open_default (TAO_ORB_Core *orb_core, ACE_Reactor *reactor, int major, int minor, TAO_ProtocolFactorySetItor &factory, const char *options)
	Create a default acceptor using the specified protocol factory.
int	open_default_i (TAO_ORB_Core *orb_core, ACE_Reactor *reactor, int major, int minor, TAO_ProtocolFactorySetItor &factory, TAO_Acceptor *acceptor, const char *options)
	Open a default acceptor.
void	extract_endpoint_options (ACE_CString &addrs, ACE_CString &options, TAO_Protocol_Factory *factory)
	Extract endpoint-specific options from the endpoint string.
void	extract_endpoint_version (ACE_CString &address, int &major, int &minor)
int	open_i (TAO_ORB_Core *orb_core, ACE_Reactor *reactor, ACE_CString &address, TAO_ProtocolFactorySetItor &factory, bool ignore_address)
	TAO_Acceptor_Registry (const TAO_Acceptor_Registry &)
void	operator= (const TAO_Acceptor_Registry &)
Private Attributes
TAO_Acceptor **	acceptors_
	List of acceptors that are currently open.
size_t	size_
	Number of acceptors that are currently open.

---

Detailed Description

Acceptor Registry and Generic Acceptor interface definitions. All loaded ESIOP or GIOP acceptor bridges must register with this object.

This class maintains a list os acceptor factories for all loaded ORB protocols. There is one Acceptor_Registry per ORB_Core.

Definition at line 62 of file Acceptor_Registry.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Acceptor_Registry::TAO_Acceptor_Registry (  void   )

Default constructor. Definition at line 35 of file Acceptor_Registry.cpp. : acceptors_ (0), size_ (0) { }

TAO_Acceptor_Registry::~TAO_Acceptor_Registry (  void   )

Default destructor. Definition at line 41 of file Acceptor_Registry.cpp. References acceptors_, and close_all(). { this->close_all (); delete [] this->acceptors_; }

TAO_Acceptor_Registry::TAO_Acceptor_Registry (  const TAO_Acceptor_Registry &   )  [private]

---

Member Function Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE TAO_AcceptorSetIterator TAO_Acceptor_Registry::begin (  void   )

Definition at line 8 of file Acceptor_Registry.inl. References acceptors_. Referenced by close_all(), endpoint_count(), get_acceptor(), is_collocated(), and TAO_IIOP_Transport::set_bidir_context_info(). { return this->acceptors_; }

int TAO_Acceptor_Registry::close_all (  void   )

Close all open acceptors. Definition at line 619 of file Acceptor_Registry.cpp. References begin(), TAO_Acceptor::close(), end(), and TAO_AcceptorSetIterator. Referenced by TAO_Thread_Lane_Resources::finalize(), and ~TAO_Acceptor_Registry(). { const TAO_AcceptorSetIterator end = this->end (); for (TAO_AcceptorSetIterator i = this->begin (); i != end; ++i) { if (*i == 0) { continue; } (*i)->close (); delete *i; } this->size_ = 0; return 0; }

ACE_INLINE TAO_AcceptorSetIterator TAO_Acceptor_Registry::end (  void   )

Definition at line 14 of file Acceptor_Registry.inl. References acceptors_. Referenced by close_all(), endpoint_count(), get_acceptor(), is_collocated(), and TAO_IIOP_Transport::set_bidir_context_info(). { return this->acceptors_ + this->size_; }

size_t TAO_Acceptor_Registry::endpoint_count (  void   )

Returns the total number of endpoints in all of its acceptors. Definition at line 49 of file Acceptor_Registry.cpp. References begin(), end(), TAO_Acceptor::endpoint_count(), and TAO_AcceptorSetIterator. { int count = 0; const TAO_AcceptorSetIterator end = this->end (); for (TAO_AcceptorSetIterator i = this->begin (); i != end; ++i) { count += (*i)->endpoint_count (); } return count; }

void TAO_Acceptor_Registry::extract_endpoint_options (  ACE_CString &  addrs, ACE_CString &  options, TAO_Protocol_Factory *  factory )  [private]

Extract endpoint-specific options from the endpoint string. Definition at line 640 of file Acceptor_Registry.cpp. References TAO_Protocol_Factory::options_delimiter(). Referenced by open_i(). { ACE_CString::size_type const options_index = addrs.find (factory->options_delimiter ()); if (options_index == addrs.length () - 1) { // Get rid of trailing option delimiter. addrs = addrs.substring (0, addrs.length () - 1); } else if (options_index != ACE_CString::npos) { options = addrs.substring (options_index + 1); addrs = addrs.substring (0, options_index); } }

void TAO_Acceptor_Registry::extract_endpoint_version (  ACE_CString &  address, int &  major, int &  minor )  [private]

Extract endpoint/address specific version from the endpoint string. Definition at line 660 of file Acceptor_Registry.cpp. References ACE_OS::ace_isdigit(), TAO_DEF_GIOP_MAJOR, and TAO_DEF_GIOP_MINOR. Referenced by open_i(). { // Check if an "N.n@" version prefix was // specified. major = TAO_DEF_GIOP_MAJOR; minor = TAO_DEF_GIOP_MINOR; if (ACE_OS::ace_isdigit (address[0]) && address[1] == '.' && ACE_OS::ace_isdigit (address[2]) && address[3] == '@') { major = address[0] - '0'; minor = address[2] - '0'; address = address.substring (4); } }

TAO_Acceptor * TAO_Acceptor_Registry::get_acceptor (  CORBA::ULong  tag  )

Return the acceptor bridges. Definition at line 105 of file Acceptor_Registry.cpp. References begin(), end(), and TAO_AcceptorSetIterator. Referenced by TAO_Tagged_Profile::extract_object_key(). { TAO_AcceptorSetIterator end = this->end (); TAO_AcceptorSetIterator acceptor = this->begin (); for (; acceptor != end; ++acceptor) { if ((*acceptor)->tag () == tag) { return *acceptor; } } return 0; }

int TAO_Acceptor_Registry::is_collocated (  const TAO_MProfile &  mprofile  )

Check if there is at least one profile in mprofile that corresponds to a collocated object. Definition at line 63 of file Acceptor_Registry.cpp. References begin(), end(), TAO_Profile::endpoint(), TAO_MProfile::get_profile(), TAO_Endpoint::next(), TAO_MProfile::profile_count(), TAO_Profile::tag(), TAO_AcceptorSetIterator, and TAO_PHandle. Referenced by TAO_Thread_Lane_Resources::is_collocated(). { const TAO_AcceptorSetIterator end = this->end (); const CORBA::ULong count = mprofile.profile_count (); // If at least one endpoint in one of the profiles matches one of // the acceptors, we are collocated. for (TAO_AcceptorSetIterator i = this->begin (); i != end; ++i) { for (TAO_PHandle j = 0; j != count; ++j) { const TAO_Profile *profile = mprofile.get_profile (j); // @@ We need to invoke a nonconst <endpoint> method on // <profile>. The content of profile/endpoint will not // be modified. TAO_Profile *pf = const_cast<TAO_Profile *> (profile); // Check all endpoints for address equality. if ((*i)->tag () == pf->tag ()) { // @note This can be a potentially expensive (O(n^2)) // operation if the below is_collocated() call // also executes a loop. for (TAO_Endpoint *endp = pf->endpoint (); endp != 0; endp = endp->next ()) { if ((*i)->is_collocated (endp)) { return 1; } } } } } return 0; }

int TAO_Acceptor_Registry::open (  TAO_ORB_Core *  orb_core, ACE_Reactor *  reactor, const TAO_EndpointSet &  endpoint_set, bool  ignore_address )

Initialize all registered acceptors. Return -1 on error. Definition at line 122 of file Acceptor_Registry.cpp. References acceptors_, ACE_CString, ACE_ERROR, ACE_NEW_THROW_EX, ACE_TEXT, ACE_TEXT_CHAR_TO_TCHAR, ACE_Unbounded_Queue_Const_Iterator< T >::advance(), ACE_Unbounded_Set< T >::begin(), ACE_Unbounded_Set< T >::end(), LM_ERROR, ACE_Unbounded_Queue_Const_Iterator< T >::next(), open_default(), open_i(), prefix, TAO_ORB_Core::protocol_factories(), ACE_OS::strchr(), ACE_OS::strlen(), TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, TAO_debug_level, TAO_EndpointSetIterator, and TAO_ProtocolFactorySetItor. Referenced by TAO_Thread_Lane_Resources::open_acceptor_registry(). { if (endpoint_set.is_empty () // No endpoints were specified, we let each protocol pick its // own default. // All TAO pluggable protocols are expected to have the ability // to create a default endpoint. && this->open_default (orb_core, reactor, 0) == -1) { throw ::CORBA::INTERNAL ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, 0), CORBA::COMPLETED_NO); } // Count the maximum number of endpoints in the set. This will be // the maximum number of acceptors that need to be created. size_t acceptor_count = 0; TAO_EndpointSetIterator endpts (endpoint_set); for (ACE_CString *ep = 0; endpts.next (ep) != 0; endpts.advance ()) { const ACE_CString &iop = (*ep); // IOP://address1,address2 // ^ slot ACE_CString::size_type const slot = iop.find ("://", 0); if (slot == iop.npos) { if (TAO_debug_level > 0) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%P|%t) Invalid endpoint ") ACE_TEXT ("specification: <%s>.\n"), ACE_TEXT_CHAR_TO_TCHAR (iop.c_str ()))); } throw ::CORBA::BAD_PARAM ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, EINVAL), CORBA::COMPLETED_NO); } ++acceptor_count; // We've got at least one acceptor so far. #if defined (ACE_WIN32) && defined (ACE_HAS_IPV6) // Since Win32 has single-stack IPv4/IPv6 we need an additional // acceptor if an iiop protocol without endpoints is specified // to open explicitly on IPv6 ANY *and* IPv4 ANY. // Now get the list of available protocol factories. const TAO_ProtocolFactorySetItor end = orb_core->protocol_factories ()->end (); // extract the protocol prefix const ACE_CString prefix (iop.substring (0, slot)); for (TAO_ProtocolFactorySetItor factory = orb_core->protocol_factories ()->begin (); factory != end; ++factory) { if ((*factory)->factory ()->match_prefix (prefix)) { if ((*factory)->factory ()->tag () == IOP::TAG_INTERNET_IOP) { // just add additional space to cover for possibility ++acceptor_count; } break; // we found the protocol, no need to go on } } #endif /* ACE_WIN32 && ACE_HAS_IPV6 */ // Now count the number of commas. That number will be the // remaining number of endpoints in the current endpoint // specification. const char *ep_end = ep->c_str () + ACE_OS::strlen (ep->c_str ()); for (const char *e = ACE_OS::strchr (ep->c_str (), ','); e != 0 && e != ep_end; e = ACE_OS::strchr (e, ',')) { ++acceptor_count; ++e; } } // The array containing the TAO_Acceptors will never contain more // than the number of endpoints stored in TAO_ORB_Parameters. if (this->acceptors_ == 0) { ACE_NEW_THROW_EX (this->acceptors_, TAO_Acceptor *[acceptor_count], CORBA::NO_MEMORY ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, ENOMEM), CORBA::COMPLETED_NO)); } TAO_EndpointSetIterator endpoints (endpoint_set); for (ACE_CString *endpoint = 0; endpoints.next (endpoint) != 0; endpoints.advance ()) { const ACE_CString &iop = (*endpoint); // IOP://address1,address2 // ^ slot ACE_CString::size_type const slot = iop.find ("://", 0); if (slot == iop.npos) { if (TAO_debug_level > 0) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%P|%t) Invalid endpoint ") ACE_TEXT ("specification: <%s>.\n"), ACE_TEXT_CHAR_TO_TCHAR (iop.c_str ()))); } throw ::CORBA::BAD_PARAM ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, EINVAL), CORBA::COMPLETED_NO); } const ACE_CString prefix (iop.substring (0, slot)); // @@ We could move the protocol factory loop to the outermost // level but for now we leave it inside the endpoint loop // under the assumption that there will be more endpoints // than protocols. // Now get the list of available protocol factories. const TAO_ProtocolFactorySetItor end = orb_core->protocol_factories ()->end (); bool found = false; // If usable protocol (factory) is found then this will be // set equal to true. for (TAO_ProtocolFactorySetItor factory = orb_core->protocol_factories ()->begin (); factory != end; ++factory) { if ((*factory)->factory ()->match_prefix (prefix)) { // increment slot past the "://" (i.e. add 3) ACE_CString addrs = iop.substring (slot + 3); const int result = this->open_i (orb_core, reactor, addrs, factory, ignore_address); if (result != 0) { return -1; } found = true; // A usable protocol was found. } else { continue; } } if (found == false) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("TAO (%P|%t) ") ACE_TEXT ("no usable transport protocol ") ACE_TEXT ("was found.\n"))); throw ::CORBA::BAD_PARAM ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, EINVAL), CORBA::COMPLETED_NO); } } return 0; }

int TAO_Acceptor_Registry::open_default (  TAO_ORB_Core *  orb_core, ACE_Reactor *  reactor, int  major, int  minor, TAO_ProtocolFactorySetItor &  factory, const char *  options )  [private]

Create a default acceptor using the specified protocol factory. Definition at line 542 of file Acceptor_Registry.cpp. References ACE_ERROR, ACE_TEXT, ACE_TEXT_CHAR_TO_TCHAR, LM_ERROR, open_default_i(), TAO_debug_level, and TAO_ProtocolFactorySetItor. { // No endpoints were specified, we let each protocol pick its own // default endpoint. // Make an acceptor TAO_Acceptor *acceptor = (*factory)->factory ()->make_acceptor (); if (acceptor == 0) { if (TAO_debug_level > 0) { ACE_ERROR (( LM_ERROR, ACE_TEXT ("TAO (%P|%t) unable to create ") ACE_TEXT ("an acceptor for <%s>\n"), ACE_TEXT_CHAR_TO_TCHAR ((*factory)->protocol_name ().c_str ()) )); } return -1; } return this->open_default_i (orb_core, reactor, major, minor, factory, acceptor, options); }

int TAO_Acceptor_Registry::open_default (  TAO_ORB_Core *  orb_core, ACE_Reactor *  reactor, const char *  options )  [private]

Create a default acceptor for all loaded protocols. Definition at line 325 of file Acceptor_Registry.cpp. References acceptors_, ACE_ERROR, ACE_NEW_RETURN, ACE_TEXT, ACE_TEXT_CHAR_TO_TCHAR, ACE_Unbounded_Set< T >::begin(), TAO_ORB_Parameters::connect_ipv6_only(), TAO_IIOP_Acceptor::default_address(), ACE_Unbounded_Set< T >::end(), ACE_INET_Addr::get_port_number(), LM_ERROR, open_default_i(), TAO_ORB_Core::orb_params(), TAO_ORB_Core::protocol_factories(), ACE_INET_Addr::set(), TAO_IIOP_Acceptor::set_default_address(), ACE_Unbounded_Set< T >::size(), TAO_debug_level, TAO_DEF_GIOP_MAJOR, TAO_DEF_GIOP_MINOR, TAO_ProtocolFactorySet, and TAO_ProtocolFactorySetItor. Referenced by open(). { // Flag that indicates at least one endpoint was opened. If one // wasn't opened then there is a problem. bool opened_endpoint = false; #if defined (ACE_WIN32) && defined (ACE_HAS_IPV6) if (!orb_core->orb_params ()->connect_ipv6_only () && this->acceptors_ == 0) { // Since Win32 has single-stack IPv4/IPv6 we need an additional // acceptor to open explicitly on IPv6 ANY *and* IPv4 ANY. // This code takes care of that. TAO_ProtocolFactorySet *pfs = orb_core->protocol_factories (); // Number of acceptors to set up size_t acceptor_count = 0; const TAO_ProtocolFactorySetItor end = pfs->end (); // Loop through all the loaded protocols... for (TAO_ProtocolFactorySetItor i = pfs->begin (); i != end; ++i) { if (!(*i)->factory ()->requires_explicit_endpoint ()) { if ((*i)->factory ()->tag () == IOP::TAG_INTERNET_IOP) acceptor_count += 2; // IPv4 AND IPv6 endpoints else acceptor_count += 1; } } // Allocate TAO_Acceptor array ACE_NEW_RETURN (this->acceptors_, TAO_Acceptor *[acceptor_count], -1); // Loop through all the loaded protocols... for (TAO_ProtocolFactorySetItor i = pfs->begin (); i != end; ++i) { // If the protocol requires an explicit -ORBEndpoint option then // don't use it, otherwise open a default endpoint for that // protocol, this solves the problem with persistent endpoints // (such as UNIX domain rendesvouz points) that are not cleaned // up if the server crashes. if (!(*i)->factory ()->requires_explicit_endpoint ()) { // Make an acceptor TAO_Acceptor *acceptor = (*i)->factory ()->make_acceptor (); if (acceptor == 0) { if (TAO_debug_level > 0) { ACE_ERROR (( LM_ERROR, ACE_TEXT ("TAO (%P|%t) unable to create ") ACE_TEXT ("an acceptor for <%s>\n"), ACE_TEXT_CHAR_TO_TCHAR ((*i)->protocol_name ().c_str ()) )); } return -1; } if ((*i)->factory ()->tag () == IOP::TAG_INTERNET_IOP) { // Open first acceptor on IPv4 ANY ACE_INET_Addr addr(static_cast<unsigned short> (0)); // IPv4 ANY TAO_IIOP_Acceptor* iiop_acceptor = dynamic_cast<TAO_IIOP_Acceptor*> (acceptor); if (!iiop_acceptor) return -1; iiop_acceptor->set_default_address (addr); if (this->open_default_i (orb_core, reactor, TAO_DEF_GIOP_MAJOR, // default major TAO_DEF_GIOP_MINOR, // default minor i, acceptor, options) != 0) { return -1; } // record the port chosen for the IPv4 acceptor u_short port = iiop_acceptor->default_address ().get_port_number (); // Create second acceptor for IPV6 traffic acceptor = (*i)->factory ()->make_acceptor (); if (acceptor == 0) { if (TAO_debug_level > 0) { ACE_ERROR (( LM_ERROR, ACE_TEXT ("TAO (%P|%t) unable to create ") ACE_TEXT ("an acceptor for <%s>\n"), ACE_TEXT_CHAR_TO_TCHAR ((*i)->protocol_name ().c_str ()) )); } return -1; } addr.set (port, ACE_IPV6_ANY, AF_INET6); // IPv6 ANY on specified port iiop_acceptor = dynamic_cast<TAO_IIOP_Acceptor*> (acceptor); if (!iiop_acceptor) return -1; iiop_acceptor->set_default_address (addr); if (this->open_default_i (orb_core, reactor, TAO_DEF_GIOP_MAJOR, // default major TAO_DEF_GIOP_MINOR, // default minor i, acceptor, options) != 0) { return -1; } } else { if (this->open_default_i (orb_core, reactor, TAO_DEF_GIOP_MAJOR, // default major TAO_DEF_GIOP_MINOR, // default minor i, acceptor, options) != 0) { return -1; } } opened_endpoint = true; } } } else { #endif /* ACE_WIN32 && ACE_HAS_IPV6 */ TAO_ProtocolFactorySet *pfs = orb_core->protocol_factories (); // If the TAO_Acceptor array is zero by the time we get here then no // endpoints were specified by the user, meaning that the number of // acceptors will never be more than the number of loaded protocols // in the ORB core. if (this->acceptors_ == 0) { ACE_NEW_RETURN (this->acceptors_, TAO_Acceptor *[pfs->size ()], -1); } const TAO_ProtocolFactorySetItor end = pfs->end (); // Loop through all the loaded protocols... for (TAO_ProtocolFactorySetItor i = pfs->begin (); i != end; ++i) { // If the protocol requires an explicit -ORBEndpoint option then // don't use it, otherwise open a default endpoint for that // protocol, this solves the problem with persistent endpoints // (such as UNIX domain rendesvouz points) that are not cleaned // up if the server crashes. if (!(*i)->factory ()->requires_explicit_endpoint ()) { if (this->open_default (orb_core, reactor, TAO_DEF_GIOP_MAJOR, // default major TAO_DEF_GIOP_MINOR, // default minor i, options) != 0) { return -1; } opened_endpoint = true; } } #if defined (ACE_WIN32) && defined (ACE_HAS_IPV6) } #endif /* ACE_WIN32) && ACE_HAS_IPV6 */ if (!opened_endpoint) { if (TAO_debug_level > 0) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("TAO (%P|%t) No default endpoints ") ACE_TEXT ("opened.\n") ACE_TEXT ("Please specify one or more using ") ACE_TEXT ("the \"-ORBListenEndpoints\" ") ACE_TEXT ("option.\n"))); } return -1; } return 0; }

int TAO_Acceptor_Registry::open_default_i (  TAO_ORB_Core *  orb_core, ACE_Reactor *  reactor, int  major, int  minor, TAO_ProtocolFactorySetItor &  factory, TAO_Acceptor *  acceptor, const char *  options )  [private]

Open a default acceptor. Definition at line 582 of file Acceptor_Registry.cpp. References acceptors_, ACE_ERROR, ACE_TEXT, ACE_TEXT_CHAR_TO_TCHAR, LM_ERROR, TAO_Acceptor::open_default(), TAO_debug_level, and TAO_ProtocolFactorySetItor. Referenced by open_default(), and open_i(). { // Initialize the acceptor to listen on a default endpoint. if (acceptor->open_default (orb_core, reactor, major, minor, options) == -1) { delete acceptor; if (TAO_debug_level > 0) { ACE_ERROR (( LM_ERROR, ACE_TEXT ("TAO (%P|%t) unable to open ") ACE_TEXT ("default acceptor for <%s>%p\n"), ACE_TEXT_CHAR_TO_TCHAR ((*factory)->protocol_name ().c_str ()), ACE_TEXT ("") )); } return -1; } this->acceptors_[this->size_++] = acceptor; return 0; }

int TAO_Acceptor_Registry::open_i (  TAO_ORB_Core *  orb_core, ACE_Reactor *  reactor, ACE_CString &  address, TAO_ProtocolFactorySetItor &  factory, bool  ignore_address )  [private]

Iterator through addrs in the string , and create an acceptor for each one. Definition at line 681 of file Acceptor_Registry.cpp. References acceptors_, ACE_CString, ACE_ERROR, ACE_TEXT, ACE_TEXT_CHAR_TO_TCHAR, TAO_IIOP_Acceptor::default_address(), extract_endpoint_options(), extract_endpoint_version(), ACE_Auto_Basic_Array_Ptr< X >::get(), ACE_INET_Addr::get_port_number(), LM_ERROR, TAO_Acceptor::open(), open_default_i(), ACE_INET_Addr::set(), TAO_IIOP_Acceptor::set_default_address(), ACE_OS::strtok_r(), TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, TAO_debug_level, TAO_DEF_GIOP_MAJOR, TAO_DEF_GIOP_MINOR, and TAO_ProtocolFactorySetItor. Referenced by open(). { ACE_CString options_tmp; this->extract_endpoint_options (addrs, options_tmp, (*factory)->factory ()); const char *options = 0; if (options_tmp.length () > 0) options = options_tmp.c_str (); char *last_addr = 0; ACE_Auto_Basic_Array_Ptr<char> addr_str (addrs.rep ()); const char *astr = ACE_OS::strtok_r (addr_str.get (), ",", &last_addr); // Iterate over the addrs specified in the endpoint. do { // For the first time only through the loop, it is // possible for astr to be 0. This indicates that // the user is requesting the default endpoint for // the specified protocol. ACE_CString address (astr == 0 ? "" : astr); TAO_Acceptor *acceptor = (*factory)->factory ()->make_acceptor (); if (acceptor != 0) { // Extract the desired endpoint/protocol version if one // exists. int major = TAO_DEF_GIOP_MAJOR; int minor = TAO_DEF_GIOP_MINOR; this->extract_endpoint_version (address, major, minor); // Check for existence of endpoint. if (ignore_address || address.length () == 0) { // Protocol prefix was specified without any endpoints. // All TAO pluggable protocols are expected to have the // ability to create a default endpoint. #if defined (ACE_WIN32) && defined (ACE_HAS_IPV6) if ((*factory)->factory ()->tag () == IOP::TAG_INTERNET_IOP) { // Open first acceptor on IPv4 ANY ACE_INET_Addr addr(static_cast<unsigned short> (0)); // IPv4 ANY TAO_IIOP_Acceptor* iiop_acceptor = dynamic_cast<TAO_IIOP_Acceptor*> (acceptor); if (!iiop_acceptor) return -1; iiop_acceptor->set_default_address (addr); if (this->open_default_i (orb_core, reactor, major, minor, factory, acceptor, options) == 0) { // record the port chosen for the IPv4 acceptor u_short port = iiop_acceptor->default_address ().get_port_number (); // Create second acceptor for IPV6 traffic acceptor = (*factory)->factory ()->make_acceptor (); if (acceptor == 0) { if (TAO_debug_level > 0) { ACE_ERROR (( LM_ERROR, ACE_TEXT ("TAO (%P|%t) unable to create ") ACE_TEXT ("an acceptor for <%s>\n"), ACE_TEXT_CHAR_TO_TCHAR ((*factory)->protocol_name ().c_str ()) )); } throw ::CORBA::NO_MEMORY ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, ENOMEM), CORBA::COMPLETED_NO); } addr.set (port, ACE_IPV6_ANY, AF_INET6); // IPv6 ANY on specified port iiop_acceptor = dynamic_cast<TAO_IIOP_Acceptor*> (acceptor); if (!iiop_acceptor) return -1; iiop_acceptor->set_default_address (addr); if (this->open_default_i (orb_core, reactor, major, minor, factory, acceptor, options) == 0) { continue; } } } else { if (this->open_default_i (orb_core, reactor, major, minor, factory, acceptor, options) == 0) { continue; } } // Could not open a default endpoint, nor an explicit // one. throw ::CORBA::INTERNAL ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, 0), CORBA::COMPLETED_NO); #else /* ACE_WIN32 && ACE_HAS_IPV6 */ if (this->open_default_i (orb_core, reactor, major, minor, factory, acceptor, options) == 0) continue; // Could not open a default endpoint, nor an explicit // one. else { throw ::CORBA::INTERNAL ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, 0), CORBA::COMPLETED_NO); } #endif /* !ACE_WIN32 || !ACE_HAS_IPV6 */ } // An explicit endpoint was provided. else if (acceptor->open (orb_core, reactor, major, minor, address.c_str (), options) == -1) { /* Need to save the errno value from the acceptor->open(), * because errno will get reset when we delete acceptor */ const int errno_value = errno; delete acceptor; if (TAO_debug_level > 0) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("TAO (%P|%t) ") ACE_TEXT ("unable to open acceptor ") ACE_TEXT ("for <%s>%p\n"), ACE_TEXT_CHAR_TO_TCHAR (address.c_str ()), ACE_TEXT (""))); } throw ::CORBA::BAD_PARAM ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, errno_value), CORBA::COMPLETED_NO); } // add acceptor to list this->acceptors_[this->size_++] = acceptor; } else { if (TAO_debug_level > 0) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("TAO (%P|%t) unable to create ") ACE_TEXT ("an acceptor for <%s>.\n"), ACE_TEXT_CHAR_TO_TCHAR (address.c_str ()))); } throw ::CORBA::NO_MEMORY ( CORBA::SystemException::_tao_minor_code ( TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, ENOMEM), CORBA::COMPLETED_NO); } } while (astr != 0 && (astr = ACE_OS::strtok_r (0, ",", &last_addr)) != 0); return 0; }

void TAO_Acceptor_Registry::operator= (  const TAO_Acceptor_Registry &   )  [private]

---

Member Data Documentation

TAO_Acceptor** TAO_Acceptor_Registry::acceptors_ [private]

List of acceptors that are currently open. Definition at line 146 of file Acceptor_Registry.h. Referenced by begin(), end(), open(), open_default(), open_default_i(), open_i(), and ~TAO_Acceptor_Registry().

size_t TAO_Acceptor_Registry::size_ [private]

Number of acceptors that are currently open. Definition at line 149 of file Acceptor_Registry.h.

---

The documentation for this class was generated from the following files:

• Acceptor_Registry.h
• Acceptor_Registry.cpp
• Acceptor_Registry.inl

---