diff options
Diffstat (limited to 'TAO/tao/Strategies/DIOP_Connector.cpp')
| -rw-r--r-- | TAO/tao/Strategies/DIOP_Connector.cpp | 242 |
1 files changed, 242 insertions, 0 deletions
diff --git a/TAO/tao/Strategies/DIOP_Connector.cpp b/TAO/tao/Strategies/DIOP_Connector.cpp new file mode 100644 index 00000000000..b7fd7318cef --- /dev/null +++ b/TAO/tao/Strategies/DIOP_Connector.cpp @@ -0,0 +1,242 @@ +// This may look like C, but it's really -*- C++ -*- +// $Id$ + +#include "tao/Strategies/DIOP_Connector.h" + +#if defined (TAO_HAS_DIOP) && (TAO_HAS_DIOP != 0) + +#include "ace/Connector.h" + +#include "tao/debug.h" +#include "tao/ORB_Core.h" +#include "tao/Environment.h" +#include "tao/Base_Transport_Property.h" +#include "tao/Protocols_Hooks.h" +#include "ace/OS_NS_strings.h" +#include "ace/OS_NS_string.h" + +#include "tao/Strategies/DIOP_Profile.h" + + +ACE_RCSID (Strategies, + DIOP_Connector, + "$Id$") + + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +TAO_DIOP_Connector::TAO_DIOP_Connector (CORBA::Boolean flag) + : TAO_Connector (TAO_TAG_DIOP_PROFILE), + lite_flag_ (flag) +{ +} + +TAO_DIOP_Connector::~TAO_DIOP_Connector (void) +{ +} + +int +TAO_DIOP_Connector::open (TAO_ORB_Core *orb_core) +{ + this->orb_core (orb_core); + + // Create our connect strategy + if (this->create_connect_strategy () == -1) + return -1; + + // @@ Michael: We do not use regular connection management. + + return 0; +} + +int +TAO_DIOP_Connector::close (void) +{ + // The list of service handlers cleans itself?? + SvcHandlerIterator iter (svc_handler_table_); + + while (!iter.done ()) + { + (*iter).int_id_->remove_reference (); + iter++; + } + + // @@ Michael: We do not use regular connection management. + return 0; +} + +int +TAO_DIOP_Connector::set_validate_endpoint (TAO_Endpoint *endpoint) +{ + TAO_DIOP_Endpoint *diop_endpoint = + this->remote_endpoint (endpoint); + + if (diop_endpoint == 0) + return -1; + + const ACE_INET_Addr &remote_address = + diop_endpoint->object_addr (); + + // Verify that the remote ACE_INET_Addr was initialized properly. + // Failure can occur if hostname lookup failed when initializing the + // remote ACE_INET_Addr. + if (remote_address.get_type () != AF_INET) + { + if (TAO_debug_level > 0) + { + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("TAO (%P|%t) DIOP connection failed.\n") + ACE_TEXT ("TAO (%P|%t) This is most likely ") + ACE_TEXT ("due to a hostname lookup ") + ACE_TEXT ("failure.\n"))); + } + + return -1; + } + + return 0; +} + +TAO_Transport * +TAO_DIOP_Connector::make_connection (TAO::Profile_Transport_Resolver *, + TAO_Transport_Descriptor_Interface &desc, + ACE_Time_Value * /*max_wait_time*/) +{ + TAO_DIOP_Endpoint *diop_endpoint = + this->remote_endpoint (desc.endpoint ()); + + if (diop_endpoint == 0) + return 0; + + const ACE_INET_Addr &remote_address = + diop_endpoint->object_addr (); + + TAO_DIOP_Connection_Handler *svc_handler = 0; + + if (svc_handler_table_.find (remote_address, svc_handler) == -1) + { + TAO_DIOP_Connection_Handler *svc_handler_i = 0; + ACE_NEW_RETURN (svc_handler_i, + TAO_DIOP_Connection_Handler (this->orb_core (), + this->lite_flag_), + 0); + + svc_handler_i->local_addr (ACE_sap_any_cast (ACE_INET_Addr &)); + svc_handler_i->addr (remote_address); + + svc_handler_i->open (0); + + svc_handler_table_.bind (remote_address, + svc_handler_i); + svc_handler = svc_handler_i; + + if (TAO_debug_level > 2) + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("(%P|%t) DIOP_Connector::connect - ") + ACE_TEXT ("new connection on HANDLE %d\n"), + svc_handler->get_handle ())); + } + + // @@ Michael: We do not use regular connection management. + svc_handler->add_reference (); + TAO_Transport *transport = + svc_handler->transport (); + + return transport; +} + +TAO_Profile * +TAO_DIOP_Connector::create_profile (TAO_InputCDR& cdr) +{ + TAO_Profile *pfile = 0; + ACE_NEW_RETURN (pfile, + TAO_DIOP_Profile (this->orb_core ()), + 0); + + int const r = pfile->decode (cdr); + if (r == -1) + { + pfile->_decr_refcnt (); + pfile = 0; + } + + return pfile; +} + +TAO_Profile * +TAO_DIOP_Connector::make_profile (ACE_ENV_SINGLE_ARG_DECL) +{ + // The endpoint should be of the form: + // N.n@host:port/object_key + // or: + // host:port/object_key + + TAO_Profile *profile = 0; + ACE_NEW_THROW_EX (profile, + TAO_DIOP_Profile (this->orb_core ()), + CORBA::NO_MEMORY ( + CORBA::SystemException::_tao_minor_code ( + TAO::VMCID, + ENOMEM), + CORBA::COMPLETED_NO)); + ACE_CHECK_RETURN (0); + + return profile; +} + +int +TAO_DIOP_Connector::check_prefix (const char *endpoint) +{ + // Check for a valid string + if (!endpoint || !*endpoint) + return -1; // Failure + + const char *protocol[] = { "diop", "dioploc" }; + + size_t const slot = ACE_OS::strchr (endpoint, ':') - endpoint; + + size_t const len0 = ACE_OS::strlen (protocol[0]); + size_t const len1 = ACE_OS::strlen (protocol[1]); + + // Check for the proper prefix in the IOR. If the proper prefix + // isn't in the IOR then it is not an IOR we can use. + if (slot == len0 + && ACE_OS::strncasecmp (endpoint, protocol[0], len0) == 0) + return 0; + else if (slot == len1 + && ACE_OS::strncasecmp (endpoint, protocol[1], len1) == 0) + return 0; + + return -1; + // Failure: not an DIOP IOR + // DO NOT throw an exception here. +} + +char +TAO_DIOP_Connector::object_key_delimiter (void) const +{ + return TAO_DIOP_Profile::object_key_delimiter_; +} + +TAO_DIOP_Endpoint * +TAO_DIOP_Connector::remote_endpoint (TAO_Endpoint *endpoint) +{ + if (endpoint->tag () != TAO_TAG_DIOP_PROFILE) + return 0; + + TAO_DIOP_Endpoint *diop_endpoint = + dynamic_cast<TAO_DIOP_Endpoint *> (endpoint ); + + return diop_endpoint; +} + +int +TAO_DIOP_Connector::cancel_svc_handler ( + TAO_Connection_Handler * /* svc_handler */) +{ + return 0; +} + +TAO_END_VERSIONED_NAMESPACE_DECL + +#endif /* TAO_HAS_DIOP && TAO_HAS_DIOP != 0 */ |