summaryrefslogtreecommitdiff
path: root/TAO/tao/Profile_Transport_Resolver.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Profile_Transport_Resolver.cpp')
-rw-r--r--TAO/tao/Profile_Transport_Resolver.cpp62
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)
{