diff options
author | Phil Mesnier <mesnier_p@ociweb.com> | 2006-04-26 17:12:48 +0000 |
---|---|---|
committer | Phil Mesnier <mesnier_p@ociweb.com> | 2006-04-26 17:12:48 +0000 |
commit | deaa7a203fb9a4db2f3b01eaf2995ccb87e5944d (patch) | |
tree | 05a08d17ed7b625832acb49896659fb0beda830b /TAO/tao/Profile_Transport_Resolver.h | |
parent | 4274f7f32351550bc6b3f8b346488f1b0a993bb4 (diff) | |
download | ATCD-deaa7a203fb9a4db2f3b01eaf2995ccb87e5944d.tar.gz |
ChangeLog tag: Wed Apr 26 16:42:45 UTC 2006 Phil Mesnier <mesnier_p@ociweb.com>
Diffstat (limited to 'TAO/tao/Profile_Transport_Resolver.h')
-rw-r--r-- | TAO/tao/Profile_Transport_Resolver.h | 22 |
1 files changed, 20 insertions, 2 deletions
diff --git a/TAO/tao/Profile_Transport_Resolver.h b/TAO/tao/Profile_Transport_Resolver.h index 5ec4889a76b..34cef016395 100644 --- a/TAO/tao/Profile_Transport_Resolver.h +++ b/TAO/tao/Profile_Transport_Resolver.h @@ -130,13 +130,27 @@ namespace TAO /// released back to the cache. void transport_released (void) const; - /// This is a callback method used by the endpoint selectors, to + /// This is a callback method used by the endpoint selectors to /// delegate the responsibility of reserving a transport from the - /// connection cache for this invocation. + /// connection cache for this invocation. When the descriptor + /// contains more than one endpoint (as part of a linked list) and + /// the parallel flag is true then the connector will look for a + /// connection on any of the endpoints if it supports that + /// behavior, otherwise an ENOTSUP errno will be set and the + /// method will return false. bool try_connect (TAO_Transport_Descriptor_Interface *desc, ACE_Time_Value *val ACE_ENV_ARG_DECL); + bool try_parallel_connect (TAO_Transport_Descriptor_Interface *desc, + ACE_Time_Value *val + ACE_ENV_ARG_DECL); + + /// This method wraps a call to the orb core to see if parallel + /// connection attempts are even desired. This is controlled by + /// the -ORBUseParallelConnects 1|0 commandline option. + bool use_parallel_connect (void) const; + /// Initialize the inconsistent policy list that this object has /// cached. void init_inconsistent_policies (ACE_ENV_SINGLE_ARG_DECL) @@ -152,6 +166,10 @@ namespace TAO bool get_connection_timeout (ACE_Time_Value &max_wait_time); private: + bool try_connect_i (TAO_Transport_Descriptor_Interface *desc, + ACE_Time_Value *val, + bool parallel + ACE_ENV_ARG_DECL); /// Target object mutable CORBA::Object *obj_; |