summaryrefslogtreecommitdiff
path: root/TAO/tao/Strategies/UIOP_Connector.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Strategies/UIOP_Connector.cpp')
-rw-r--r--TAO/tao/Strategies/UIOP_Connector.cpp18
1 files changed, 8 insertions, 10 deletions
diff --git a/TAO/tao/Strategies/UIOP_Connector.cpp b/TAO/tao/Strategies/UIOP_Connector.cpp
index ded09d4721d..176d1d0e721 100644
--- a/TAO/tao/Strategies/UIOP_Connector.cpp
+++ b/TAO/tao/Strategies/UIOP_Connector.cpp
@@ -1,7 +1,5 @@
-// This may look like C, but it's really -*- C++ -*-
// $Id$
-
#include "UIOP_Connector.h"
#if TAO_HAS_UIOP == 1
@@ -15,12 +13,12 @@
#include "tao/Base_Transport_Property.h"
#include "tao/Transport_Cache_Manager.h"
#include "tao/Invocation.h"
+#include "tao/Thread_Lane_Resources.h"
ACE_RCSID(Strategies,
UIOP_Connector,
"$Id$")
-
#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
template class ACE_Node<ACE_UNIX_Addr>;
@@ -158,8 +156,8 @@ TAO_UIOP_Connector::connect (TAO_GIOP_Invocation *invocation,
// Check the Cache first for connections
// If transport found, reference count is incremented on assignment
- if (this->orb_core ()->transport_cache ()->find_transport (desc,
- base_transport) == 0)
+ if (this->orb_core ()->lane_resources ().transport_cache ().find_transport (desc,
+ base_transport) == 0)
{
if (TAO_debug_level > 5)
ACE_DEBUG ((LM_DEBUG,
@@ -175,7 +173,7 @@ TAO_UIOP_Connector::connect (TAO_GIOP_Invocation *invocation,
ACE_TEXT ("making a new connection \n")));
// Purge connections (if necessary)
- this->orb_core ()->transport_cache ()->purge ();
+ this->orb_core ()->lane_resources ().transport_cache ().purge ();
// @@ This needs to change in the next round when we implement a
// policy that will not allow new connections when a connection
@@ -225,8 +223,8 @@ TAO_UIOP_Connector::connect (TAO_GIOP_Invocation *invocation,
base_transport = TAO_Transport::_duplicate (svc_handler->transport ());
// Add the handler to Cache
int retval =
- this->orb_core ()->transport_cache ()->cache_transport (desc,
- base_transport);
+ this->orb_core ()->lane_resources ().transport_cache ().cache_transport (desc,
+ base_transport);
if (retval != 0 && TAO_debug_level > 0)
{
@@ -346,8 +344,8 @@ TAO_UIOP_Connector::preconnect (const char *preconnects)
// Add the handler to Cache
int retval =
- this->orb_core ()->transport_cache ()->cache_transport (&prop,
- handlers[slot]->transport ());
+ this->orb_core ()->lane_resources ().transport_cache ().cache_transport (&prop,
+ handlers[slot]->transport ());
++successes;
if (retval != 0 && TAO_debug_level > 4)