diff options
author | bala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2002-10-31 21:20:51 +0000 |
---|---|---|
committer | bala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2002-10-31 21:20:51 +0000 |
commit | af9f836817c0fd7a1065b6623777e2ccae892422 (patch) | |
tree | 5ffca13d32bfe27961be8b7df487929657d861e4 /TAO/tao/Transport_Connector.cpp | |
parent | 64d1e7e07e1af9220c763ec15a22e2d53dc3d992 (diff) | |
download | ATCD-af9f836817c0fd7a1065b6623777e2ccae892422.tar.gz |
ChangeLogTag:Thu Oct 31 14:48:39 2002 Balachandran Natarajan <bala@isis-server.isis.vanderbilt.edu>
Diffstat (limited to 'TAO/tao/Transport_Connector.cpp')
-rw-r--r-- | TAO/tao/Transport_Connector.cpp | 20 |
1 files changed, 18 insertions, 2 deletions
diff --git a/TAO/tao/Transport_Connector.cpp b/TAO/tao/Transport_Connector.cpp index 665811fe098..2e65ddcd221 100644 --- a/TAO/tao/Transport_Connector.cpp +++ b/TAO/tao/Transport_Connector.cpp @@ -210,15 +210,30 @@ TAO_Connector::make_mprofile (const char *string, int TAO_Connector::connect (TAO_GIOP_Invocation *invocation, TAO_Transport_Descriptor_Interface *desc + ACE_ENV_ARG_DECL) +{ + return this->connect (invocation, + desc, + 0 + ACE_ENV_ARG_PARAMETER); +} + +int +TAO_Connector::connect (TAO_GIOP_Invocation *invocation, + TAO_Transport_Descriptor_Interface *desc, + ACE_Time_Value *timeout ACE_ENV_ARG_DECL_NOT_USED) { if (this->set_validate_endpoint (desc->endpoint ()) == -1) return -1; + TAO_Transport *base_transport = 0; // Check the Cache first for connections // If transport found, reference count is incremented on assignment + // @@todo: We need to send the timeout value to the cache registry + // too. That should be the next step! if (this->orb_core ()->lane_resources ().transport_cache ().find_transport (desc, base_transport) == 0) { @@ -235,7 +250,7 @@ TAO_Connector::connect (TAO_GIOP_Invocation *invocation, // base_transport. transport = base_transport; - // Succesful + // Successfull return 0; } @@ -244,7 +259,8 @@ TAO_Connector::connect (TAO_GIOP_Invocation *invocation, this->orb_core_->lane_resources ().transport_cache ().purge (); return this->make_connection (invocation, - desc); + desc, + timeout); } |