summaryrefslogtreecommitdiff
path: root/TAO/tao/Transport_Connector.cpp
diff options
context:
space:
mode:
authorbala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2002-10-31 21:20:51 +0000
committerbala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2002-10-31 21:20:51 +0000
commitaf9f836817c0fd7a1065b6623777e2ccae892422 (patch)
tree5ffca13d32bfe27961be8b7df487929657d861e4 /TAO/tao/Transport_Connector.cpp
parent64d1e7e07e1af9220c763ec15a22e2d53dc3d992 (diff)
downloadATCD-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.cpp20
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);
}