diff options
Diffstat (limited to 'trunk/TAO/orbsvcs/orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.cpp')
| -rw-r--r-- | trunk/TAO/orbsvcs/orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.cpp | 191 |
1 files changed, 191 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.cpp b/trunk/TAO/orbsvcs/orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.cpp new file mode 100644 index 00000000000..a22594ca04b --- /dev/null +++ b/trunk/TAO/orbsvcs/orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.cpp @@ -0,0 +1,191 @@ +// $Id$ + +#include "orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.h" +#include "tao/ORB_Core.h" +#include "tao/Profile.h" +#include "tao/Protocol_Factory.h" +#include "tao/GIOP_Message_State.h" +#include "tao/debug.h" +#include "tao/Endpoint.h" +#include "tao/Thread_Lane_Resources.h" +#include "tao/Leader_Follower.h" + +ACE_RCSID (PortableGroup, + PortableGroup_Acceptor_Registry, + "$Id$") + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +TAO_PortableGroup_Acceptor_Registry::TAO_PortableGroup_Acceptor_Registry (void) +{ +} + +TAO_PortableGroup_Acceptor_Registry::~TAO_PortableGroup_Acceptor_Registry (void) +{ + // Free the memory for the endpoints. + Entry *entry; + Acceptor_Registry_Iterator iter (this->registry_); + + while (iter.next (entry)) + { + delete entry->endpoint; + delete entry->acceptor; + iter.advance (); + } +} + + +void +TAO_PortableGroup_Acceptor_Registry::open (const TAO_Profile* profile, + TAO_ORB_Core &orb_core + ACE_ENV_ARG_DECL) +{ + Entry *entry; + + if (this->find (profile, entry) == 1) + { + // Found it. Increment the reference count. + ++entry->cnt; + } + else + { + // Not found. Open a new acceptor. + + // Now get the list of available protocol factories. + TAO_ProtocolFactorySetItor end = + orb_core.protocol_factories ()->end (); + + // int found = 0; + // If usable protocol (factory) is found then this will be + // set equal to 1. + + for (TAO_ProtocolFactorySetItor factory = + orb_core.protocol_factories ()->begin (); + factory != end; + ++factory) + { + if ((*factory)->factory ()->tag () == profile->tag ()) + { + this->open_i (profile, + orb_core, + factory + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + // found = 1; // A usable protocol was found. + } + else + continue; + } + } +} + +#define MAX_ADDR_LENGTH (32) + +void +TAO_PortableGroup_Acceptor_Registry::open_i (const TAO_Profile* profile, + TAO_ORB_Core &orb_core, + TAO_ProtocolFactorySetItor &factory + ACE_ENV_ARG_DECL) +{ + TAO_Acceptor *acceptor = (*factory)->factory ()->make_acceptor (); + + if (acceptor != 0) + { + // Extract the desired endpoint/protocol version if one + // exists. + const TAO_GIOP_Message_Version &version = profile->version (); + char buffer [MAX_ADDR_LENGTH]; + + // Removed the constness of profile. We're not changing + // anything, but need to call a nonconst function. + TAO_Profile* nc_profile = const_cast<TAO_Profile *> (profile); + nc_profile->endpoint ()->addr_to_string (buffer, MAX_ADDR_LENGTH); + + if (acceptor->open (&orb_core, + orb_core.lane_resources ().leader_follower ().reactor(), + version.major, + version.minor, + buffer, + 0) == -1) + { + 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"), + buffer, + "")); + + ACE_THROW (CORBA::BAD_PARAM ( + CORBA::SystemException::_tao_minor_code ( + TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, + EINVAL), + CORBA::COMPLETED_NO)); + } + + // Add acceptor to list. + Entry tmp_entry; + tmp_entry.acceptor = acceptor; + tmp_entry.endpoint = nc_profile->endpoint ()->duplicate (); + tmp_entry.cnt = 1; + + if (this->registry_.enqueue_tail (tmp_entry) == -1) + { + delete acceptor; + + if (TAO_debug_level > 0) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("TAO (%P|%t) ") + ACE_TEXT ("unable to add acceptor to registry") + ACE_TEXT ("for <%s>%p\n"), + buffer, + "")); + + ACE_THROW (CORBA::BAD_PARAM ( + CORBA::SystemException::_tao_minor_code ( + TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, + EINVAL), + CORBA::COMPLETED_NO)); + } + } + else + { + if (TAO_debug_level > 0) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("TAO (%P|%t) ") + ACE_TEXT ("unable to create acceptor ") + )); + + ACE_THROW (CORBA::BAD_PARAM ( + CORBA::SystemException::_tao_minor_code ( + TAO_ACCEPTOR_REGISTRY_OPEN_LOCATION_CODE, + EINVAL), + CORBA::COMPLETED_NO)); + } +} + +int +TAO_PortableGroup_Acceptor_Registry::find (const TAO_Profile* profile, + Entry *&entry) +{ + Acceptor_Registry_Iterator iter (this->registry_); + + while (iter.next (entry)) + { + // Since the endpoint routine is nonconst, need to + // cast away the constness even though we're not + // changing anything. + TAO_Profile *nc_profile = const_cast<TAO_Profile *> (profile); + if (entry->endpoint->is_equivalent (nc_profile->endpoint ())) + return 1; + + iter.advance (); + } + + return 0; +} + +TAO_END_VERSIONED_NAMESPACE_DECL |