diff options
Diffstat (limited to 'TAO/tao/Profile_Transport_Resolver.cpp')
-rw-r--r-- | TAO/tao/Profile_Transport_Resolver.cpp | 62 |
1 files changed, 12 insertions, 50 deletions
diff --git a/TAO/tao/Profile_Transport_Resolver.cpp b/TAO/tao/Profile_Transport_Resolver.cpp index 8f87bb6f619..123dc6c1425 100644 --- a/TAO/tao/Profile_Transport_Resolver.cpp +++ b/TAO/tao/Profile_Transport_Resolver.cpp @@ -14,7 +14,6 @@ #include "tao/Transport_Connector.h" #include "tao/Endpoint.h" #include "tao/SystemException.h" -#include "tao/Client_Strategy_Factory.h" #include "ace/Countdown_Time.h" @@ -120,6 +119,7 @@ namespace TAO } } + bool Profile_Transport_Resolver::try_connect ( TAO_Transport_Descriptor_Interface *desc, @@ -127,28 +127,6 @@ namespace TAO ACE_ENV_ARG_DECL ) { - return this->try_connect_i (desc,max_time_value,0 ACE_ENV_ARG_PARAMETER); - }; - - bool - Profile_Transport_Resolver::try_parallel_connect ( - TAO_Transport_Descriptor_Interface *desc, - ACE_Time_Value *max_time_value - ACE_ENV_ARG_DECL - ) - { - return this->try_connect_i (desc,max_time_value,1 ACE_ENV_ARG_PARAMETER); - }; - - - bool - Profile_Transport_Resolver::try_connect_i ( - TAO_Transport_Descriptor_Interface *desc, - ACE_Time_Value *max_time_value, - bool parallel - ACE_ENV_ARG_DECL - ) - { TAO_Connector_Registry *conn_reg = this->stub_->orb_core ()->connector_registry ( ACE_ENV_SINGLE_ARG_PARAMETER); @@ -169,30 +147,28 @@ namespace TAO bool const is_conn_timeout = this->get_connection_timeout (connection_timeout); - ACE_Time_Value *max_wait_time = - is_conn_timeout ? &connection_timeout : max_time_value; - if (parallel) + ACE_Time_Value *max_wait_time = 0; + + if (is_conn_timeout == true) { - this->transport_ = - conn_reg->get_connector (desc->endpoint ()->tag ())-> - parallel_connect (this, - desc, - max_wait_time - ACE_ENV_ARG_PARAMETER); - ACE_CHECK_RETURN (false); + max_wait_time = &connection_timeout; } else { + max_wait_time = max_time_value; + } + + // Obtain a connection. this->transport_ = - conn_reg->get_connector (desc->endpoint ()->tag ())-> - connect (this, + conn_reg->get_connector (desc->endpoint ()->tag ())->connect ( + this, desc, max_wait_time ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (false); - } + // A timeout error occurred. // If the user has set a roundtrip timeout policy, throw a timeout // exception. Otherwise, just fall through and return false to @@ -217,20 +193,6 @@ namespace TAO } bool - Profile_Transport_Resolver::use_parallel_connect (void) const - { - TAO_ORB_Core *oc = this->stub_->orb_core(); - return (oc->orb_params()->use_parallel_connects() -#if 0 // it was decided that even with blocked connects - // parallel connects could be useful, at least for cache - // processing. - oc->client_factory()->connect_strategy() != - TAO_Client_Strategy_Factory::TAO_BLOCKED_CONNECT -#endif /* 0 */ - ); - } - - bool Profile_Transport_Resolver::get_connection_timeout ( ACE_Time_Value &max_wait_time) { |