diff options
Diffstat (limited to 'TAO/tao/IIOP_Connector.cpp')
| -rw-r--r-- | TAO/tao/IIOP_Connector.cpp | 251 |
1 files changed, 0 insertions, 251 deletions
diff --git a/TAO/tao/IIOP_Connector.cpp b/TAO/tao/IIOP_Connector.cpp deleted file mode 100644 index 07ade298ef1..00000000000 --- a/TAO/tao/IIOP_Connector.cpp +++ /dev/null @@ -1,251 +0,0 @@ -// This may look like C, but it's really -*- C++ -*- -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// -// = FILENAME -// -// = DESCRIPTION -// -// = AUTHOR -// -// ============================================================================ - -#include "tao/IIOP_Connector.h" -#include "tao/IIOP_Profile.h" -#include "tao/GIOP.h" -#include "tao/debug.h" -#include "tao/ORB_Core.h" -#include "tao/Environment.h" - -CORBA::ULong -TAO_IIOP_Connector::tag (void) -{ - return this->tag_; -} - -TAO_IIOP_Connector::TAO_IIOP_Connector (void) - : tag_(TAO_IOP_TAG_INTERNET_IOP), - base_connector_ () -{ -} - -TAO_Transport * -TAO_IIOP_Connector::connect (TAO_Profile *profile, - CORBA::Environment &env) -{ - if (profile->tag () != TAO_IOP_TAG_INTERNET_IOP) - TAO_THROW_ENV_RETURN (CORBA::INTERNAL (CORBA::COMPLETED_NO), - env, - 0); - TAO_IIOP_Profile *iiop_profile = - ACE_dynamic_cast (TAO_IIOP_Profile *, - profile); - - if (iiop_profile == 0) - TAO_THROW_ENV_RETURN (CORBA::INTERNAL (CORBA::COMPLETED_NO), - env, - 0); - -// Establish the connection and get back a <Client_Connection_Handler>. -// @@ We do not have the ORB core -// #if defined (TAO_ARL_USES_SAME_CONNECTOR_PORT) -// if (this->orb_core_->arl_same_port_connect ()) -// { -// ACE_INET_Addr local_addr (this->orb_core_->orb_params ()->addr ()); -// local_addr.set_port_number (server_addr_p->get_port_number ()); -// -// // Set the local port number to use. -// if (con->connect (iiop_profile->hint (), -// iiop_profile->object_addr (), -// 0, -// local_addr, -// 1) == -1); -// { -// // Give users a clue to the problem. -// ACE_DEBUG ((LM_ERROR, "(%P|%t) %s:%u, connection to " -// "%s failed (%p)\n", -// __FILE__, -// __LINE__, -// iiop_profile->addr_to_string (), -// "errno")); -// -// TAO_THROW_ENV_RETURN_VOID (CORBA::TRANSIENT (CORBA::COMPLETED_NO), env); -// } -// } -// else -//#endif /* TAO_ARL_USES_SAME_CONNECTOR_PORT */ - - // @@ think about making this a friend class! FRED - const ACE_INET_Addr &oa = - ACE_dynamic_cast (const ACE_INET_Addr &, - iiop_profile->object_addr ()); - - if (base_connector_.connect (iiop_profile->hint (), oa) == -1) - { // Give users a clue to the problem. - if (TAO_orbdebug) - ACE_DEBUG ((LM_ERROR, "(%P|%t) %s:%u, connection to " - "%s failed (%p)\n", - __FILE__, - __LINE__, - profile->addr_to_string (), - "errno")); - - TAO_THROW_ENV_RETURN (CORBA::TRANSIENT (CORBA::COMPLETED_NO), - env, - 0); - } - - // the connect call will set the hint () stored in the Profile - // object. - - return iiop_profile->transport (); -} - -int -TAO_IIOP_Connector::open(TAO_Resource_Factory *trf, ACE_Reactor *reactor) -{ - if (this->base_connector_.open (reactor, - trf->get_null_creation_strategy (), - trf->get_cached_connect_strategy (), - trf->get_null_activation_strategy ()) != 0) - return -1; - return 0; -} - -int -TAO_IIOP_Connector::close (void) -{ - this->base_connector_.close (); - return 0; -} - -int -TAO_IIOP_Connector::preconnect (char *preconnections) -{ -#if 0 - if (preconnections) - { - ACE_INET_Addr dest; - TAO_Client_Connection_Handler *handler; - ACE_Unbounded_Stack<TAO_Client_Connection_Handler *> handlers; - - char *nextptr = 0; - char *where = 0; - - for (where = ACE::strsplit_r (preconnections, ",", nextptr); - where != 0; - where = ACE::strsplit_r (0, ",", nextptr)) - { - char *tport = 0; - char *thost = where; - char *sep = ACE_OS::strchr (where, ':'); - - if (sep) - { - *sep = '\0'; - tport = sep + 1; - - dest.set (ACE_OS::atoi (tport), - thost); - - // Try to establish the connection - handler = 0; - if (this->base_connector_.connect (handler, dest) == 0) - // Save it for later so we can mark it as idle - handlers.push (handler); - else - ACE_ERROR ((LM_ERROR, - "(%P|%t) Unable to preconnect to host '%s', port %d.\n", - dest.get_host_name (), - dest.get_port_number ())); - } - else - ACE_ERROR ((LM_ERROR, - "(%P|%t) Yow! Couldn't find a ':' separator in '%s' spec.\n", - where)); - } - - // Walk the stack of handlers and mark each one as idle now. - handler = 0; - while (handlers.pop (handler) == 0) - handler->idle (); - - } -#else - int successes = 0; - if (preconnections) - { - ACE_INET_Addr dest; - ACE_Unbounded_Stack<ACE_INET_Addr> dests; - - char *nextptr = 0; - char *where = 0; - for (where = ACE::strsplit_r (preconnections, ",", nextptr); - where != 0; - where = ACE::strsplit_r (0, ",", nextptr)) - { - char *tport = 0; - char *thost = where; - char *sep = ACE_OS::strchr (where, ':'); - - if (sep) - { - *sep = '\0'; - tport = sep + 1; - - dest.set (ACE_OS::atoi (tport), thost); - dests.push (dest); - } - else - ACE_ERROR ((LM_ERROR, - "(%P|%t) Yow! Couldn't find a ':' separator in '%s' spec.\n", - where)); - } - - // Create an array of addresses from the stack, as well as an - // array of eventual handlers. - size_t num_connections = dests.size (); - ACE_INET_Addr *remote_addrs = 0; - TAO_Client_Connection_Handler **handlers = 0; - char *failures = 0; - - ACE_NEW_RETURN (remote_addrs, - ACE_INET_Addr[num_connections], - -1); - ACE_NEW_RETURN (handlers, - TAO_Client_Connection_Handler *[num_connections], - -1); - ACE_NEW_RETURN (failures, - char[num_connections], - -1); - - size_t index = 0; - - // Fill in the remote address array - while (dests.pop (remote_addrs[index]) == 0) - handlers[index++] = 0; - - // Finally, try to connect. - this->base_connector_.connect_n (num_connections, - handlers, - remote_addrs, - failures); - // Loop over all the failures and set the handlers that - // succeeded to idle state. - for (index = 0; - index < num_connections; - index++) - { - if (!failures[index]) - { - handlers[index]->idle (); - successes++; - } - } - } -#endif /* 0 */ - return successes; -} |