1 files changed, 139 insertions, 0 deletions
diff --git a/TAO/tao/Object_T.cpp b/TAO/tao/Object_T.cpp
new file mode 100644
index 00000000000..20904814ab4
--- /dev/null
+++ b/TAO/tao/Object_T.cpp
@@ -0,0 +1,139 @@
+// $Id$
+#ifndef TAO_OBJECT_T_C
+#define TAO_OBJECT_T_C
+
+#include "tao/Object_T.h"
+
+ACE_RCSID (tao,
+           Object_T,
+           "$Id$")
+
+namespace TAO
+{
+  template<typename T>
+  T *
+  Narrow_Utils<T>::narrow (CORBA::Object_ptr obj,
+                           const char *repo_id,
+                           Proxy_Broker_Factory pbf
+                           ACE_ENV_ARG_DECL)
+  {
+    if (CORBA::is_nil (obj))
+      {
+        return T::_nil ();
+      }
+  
+    CORBA::Boolean is_it = obj->_is_a (repo_id
+                                       ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (T::_nil ());
+  
+    if (is_it == 0)
+      {
+        return T::_nil ();
+      }
+  
+    return TAO::Narrow_Utils<T>::unchecked_narrow (obj, pbf);
+  }
+
+  template<typename T>
+  T *
+  Narrow_Utils<T>::narrow (CORBA::AbstractBase_ptr obj,
+                           const char *repo_id
+                           ACE_ENV_ARG_DECL)
+  {
+    if (CORBA::is_nil (obj))
+      {
+        return T::_nil ();
+      }
+  
+    CORBA::Boolean is_it =
+      obj->_is_a (
+          repo_id
+          ACE_ENV_ARG_PARAMETER
+        );
+    ACE_CHECK_RETURN (T::_nil ());
+  
+    if (is_it == 0)
+      {
+        return T::_nil ();
+      }
+  
+    return Narrow_Utils<T>::unchecked_narrow (obj);
+  }
+
+  template<typename T>
+  T *
+  Narrow_Utils<T>::unchecked_narrow (CORBA::Object_ptr obj,
+                                     Proxy_Broker_Factory pbf)
+  {  
+    T_ptr proxy = Narrow_Utils<T>::lazy_evaluation (obj);
+
+    if (!CORBA::is_nil (proxy))
+      {
+        return proxy;
+      }
+
+    TAO_Stub* stub = obj->_stubobj ();
+    
+    if (stub != 0)
+      {
+        stub->_incr_refcnt ();
+      }
+
+    bool collocated =
+      !CORBA::is_nil (stub->servant_orb_var ().ptr ())
+      && stub->servant_orb_var ()->orb_core ()->optimize_collocation_objects ()
+      && obj->_is_collocated ()
+      && pbf != 0;
+    
+    ACE_NEW_RETURN (proxy,
+                    T (stub,
+                       collocated ? 1 : 0,
+                       obj->_servant ()),
+                    T::_nil ());
+    
+    return proxy;
+  }
+
+  template<typename T>
+  T *
+  Narrow_Utils<T>::unchecked_narrow (CORBA::AbstractBase_ptr obj)
+  {
+    T_ptr proxy = T::_nil ();
+  
+    if (obj->_is_objref ())
+      {
+        ACE_NEW_RETURN (proxy,
+                        T (obj->_stubobj (),
+                           0,
+                           obj->_servant ()),
+                        T::_nil ());
+      }
+    else
+      {
+        proxy = T::_downcast (obj);
+        proxy->_add_ref ();
+      }
+  
+    return proxy;
+  }
+
+  template<typename T>
+  T *
+  Narrow_Utils<T>::lazy_evaluation (CORBA::Object_ptr obj)
+  {
+    T_ptr default_proxy = T::_nil ();
+  
+    // Code for lazily evaluated IORs.
+    if (!obj->is_evaluated ())
+      {
+        ACE_NEW_RETURN (default_proxy,
+                        T (obj->steal_ior (),
+                           obj->orb_core ()),
+                        T::_nil ());
+      }
+      
+    return default_proxy;
+  }
+}
+
+#endif /* TAO_OBJECT_T_C */