// @(#) $Id$ // // Copyright 1994-1995 by Sun Microsystems Inc. // Copyright 1997-2002 by Washington University // All Rights Reserved // // ORB: CORBA::Object operations #include "tao/Object.h" #include "tao/Stub.h" #include "tao/Profile.h" #include "tao/ORB_Core.h" #include "tao/Invocation.h" #include "tao/Connector_Registry.h" #include "tao/debug.h" #include "tao/Remote_Object_Proxy_Broker.h" #include "tao/Dynamic_Adapter.h" #include "tao/IFR_Client_Adapter.h" #include "ace/Dynamic_Service.h" #if !defined (__ACE_INLINE__) # include "tao/Object.i" #endif /* ! __ACE_INLINE__ */ ACE_RCSID (tao, Object, "$Id$") int CORBA::Object::_tao_class_id = 0; CORBA::Object::~Object (void) { if (this->protocol_proxy_) (void) this->protocol_proxy_->_decr_refcnt (); delete this->refcount_lock_; } CORBA::Object::Object (TAO_Stub * protocol_proxy, CORBA::Boolean collocated, TAO_Abstract_ServantBase * servant, TAO_ORB_Core *orb_core) : servant_ (servant) , is_collocated_ (collocated) , is_local_ (0) , proxy_broker_ (0) , is_evaluated_ (1) , ior_ (0) , orb_core_ (orb_core) , protocol_proxy_ (protocol_proxy) , refcount_ (1) , refcount_lock_ (0) { /// This constructor should not be called when the protocol proxy is /// null ie. when the object is a LocalObject. Assert that /// requirement. ACE_ASSERT (this->protocol_proxy_ != 0); if (this->orb_core_ == 0) this->orb_core_ = this->protocol_proxy_->orb_core (); this->refcount_lock_ = this->orb_core_->resource_factory ()->create_corba_object_lock (); // If the object is collocated then set the broker using the // factory otherwise use the remote proxy broker. if (this->is_collocated_ && _TAO_collocation_Object_Proxy_Broker_Factory_function_pointer != 0) this->proxy_broker_ = _TAO_collocation_Object_Proxy_Broker_Factory_function_pointer (this); else this->proxy_broker_ = the_tao_remote_object_proxy_broker (); } CORBA::Object::Object (IOP::IOR *ior, TAO_ORB_Core *orb_core) : servant_ (0) , is_collocated_ (0) , is_local_ (0) , proxy_broker_ (0) , is_evaluated_ (0) , ior_ (ior) , orb_core_ (orb_core) , protocol_proxy_ (0) , refcount_ (1) , refcount_lock_ (0) { this->refcount_lock_ = this->orb_core_->resource_factory ()->create_corba_object_lock (); } // Too lazy to do this check in every method properly! This is useful // only for lazily evaluated IOR's #define TAO_OBJECT_IOR_EVALUATE \ if (!this->is_evaluated_) \ { \ ACE_GUARD (ACE_Lock , mon, *this->refcount_lock_); \ CORBA::Object::tao_object_initialize (this); \ } #define TAO_OBJECT_IOR_EVALUATE_RETURN \ if (!this->is_evaluated_) \ { \ ACE_GUARD_RETURN (ACE_Lock , mon, *this->refcount_lock_, 0); \ if (!this->is_evaluated_) \ CORBA::Object::tao_object_initialize (this); \ } void CORBA::Object::_add_ref (void) { if (this->is_local_) return; ACE_ASSERT (this->refcount_lock_ != 0); ACE_GUARD (ACE_Lock , mon, *this->refcount_lock_); this->refcount_++; } void CORBA::Object::_remove_ref (void) { if (this->is_local_) return; ACE_ASSERT (this->refcount_lock_ != 0); { ACE_GUARD (ACE_Lock, mon, *this->refcount_lock_); this->refcount_--; if (this->refcount_ != 0) return; } ACE_ASSERT (this->refcount_ == 0); delete this; } void CORBA::Object::_tao_any_destructor (void *x) { CORBA::Object_ptr tmp = ACE_static_cast (CORBA::Object_ptr, x); CORBA::release (tmp); } /*static*/ CORBA::Boolean CORBA::Object::marshal (CORBA::Object_ptr x, TAO_OutputCDR &cdr) { if (x == 0) { // NIL objrefs ... marshal as empty type hint, no elements. cdr.write_ulong (1); cdr.write_char ('\0'); cdr.write_ulong (0); return (CORBA::Boolean) cdr.good_bit (); } return x->marshal (cdr); } TAO_Abstract_ServantBase* CORBA::Object::_servant (void) const { return this->servant_; } // IS_A ... ask the object if it's an instance of the type whose // logical type ID is passed as a parameter. CORBA::Boolean CORBA::Object::_is_a (const char *type_id ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; // NOTE: if istub->type_id is nonzero and we have local knowledge of // it, we can answer this question without a costly remote call. // // That "local knowledge" could come from stubs or skeletons linked // into this process in the best case, or a "near" repository in a // slightly worse case. Or in a trivial case, if the ID being asked // about is the ID we have recorded, we don't need to ask about the // inheritance relationships at all! // // In real systems having local knowledge will be common, though as // the systems built atop ORBs become richer it'll also become // common to have the "real type ID" not be directly understood // because it's more deeply derived than any locally known types. // // XXX if type_id is that of CORBA::Object, "yes, we comply" :-) if (this->protocol_proxy_ == 0) ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), 0); if (this->_stubobj ()->type_id.in () != 0 && ACE_OS::strcmp (type_id, this->_stubobj ()->type_id.in ()) == 0) return 1; CORBA::Boolean _tao_retval = 0; // Get the right Proxy Implementation. TAO_Object_Proxy_Impl &the_proxy = this->proxy_broker_->select_proxy (this ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); // Preform the Call. _tao_retval = the_proxy._is_a (this, type_id ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); return _tao_retval; } const char* CORBA::Object::_interface_repository_id (void) const { return "IDL:omg.org/CORBA/Object:1.0"; } CORBA::Boolean CORBA::Object::_is_collocated (void) const { return this->is_collocated_; } CORBA::Boolean CORBA::Object::_is_local (void) const { return this->is_local_; } TAO_Stub * CORBA::Object::_stubobj (void) { TAO_OBJECT_IOR_EVALUATE_RETURN; return this->protocol_proxy_; } CORBA::ULong CORBA::Object::_hash (CORBA::ULong maximum ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; if (this->protocol_proxy_ != 0) return this->protocol_proxy_->hash (maximum ACE_ENV_ARG_PARAMETER); else { // Locality-constrained object. // Note that we reinterpret_cast to an "unsigned long" instead // of CORBA::ULong since we need to first cast to an integer // large enough to hold an address to avoid compile-time // warnings on some 64-bit platforms. CORBA::ULong hash = ACE_reinterpret_cast (unsigned long, this); return hash % maximum; } } CORBA::Boolean CORBA::Object::_is_equivalent (CORBA::Object_ptr other_obj ACE_ENV_ARG_DECL_NOT_USED) ACE_THROW_SPEC (()) { if (other_obj == this) { return 1; } TAO_OBJECT_IOR_EVALUATE_RETURN; if (this->protocol_proxy_ != 0) return this->protocol_proxy_->is_equivalent (other_obj); return 0; } // TAO's extensions TAO::ObjectKey * CORBA::Object::_key (ACE_ENV_SINGLE_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; if (this->_stubobj () && this->_stubobj ()->profile_in_use ()) return this->_stubobj ()->profile_in_use ()->_key (); if (TAO_debug_level > 2) ACE_ERROR ((LM_ERROR, ACE_TEXT ("TAO (%P|%t) Null object key return from ") ACE_TEXT ("profile in use\n"))); ACE_THROW_RETURN (CORBA::INTERNAL ( CORBA::SystemException::_tao_minor_code ( TAO_DEFAULT_MINOR_CODE, EINVAL), CORBA::COMPLETED_NO), 0); } void * CORBA::Object::_tao_QueryInterface (ptr_arith_t type) { void *retv = 0; if (type == ACE_reinterpret_cast (ptr_arith_t, &CORBA::Object::_tao_class_id)) retv = ACE_reinterpret_cast (void *, this); if (retv) this->_add_ref (); return retv; } void CORBA::Object::_proxy_broker (TAO_Object_Proxy_Broker *proxy_broker) { this->proxy_broker_ = proxy_broker; } TAO_Object_Proxy_Broker * CORBA::Object::_proxy_broker (void) { return this->proxy_broker_; } CORBA::Boolean CORBA::Object::is_nil_i (CORBA::Object_ptr obj) { // To accomodate new definitions. if (obj->orb_core_) { return obj->orb_core_->object_is_nil (obj); } return 0; } #if (TAO_HAS_MINIMUM_CORBA == 0) void CORBA::Object::_create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::Request_ptr &request, CORBA::Flags req_flags ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE; // Since we don't really support Context, anything but a null pointer // is a no-no. // Neither can we create a request object from locality constrained // object references. if (ctx != 0 || this->protocol_proxy_ == 0) { ACE_THROW (CORBA::NO_IMPLEMENT ()); } TAO_Dynamic_Adapter *dynamic_adapter = ACE_Dynamic_Service::instance ( TAO_ORB_Core::dynamic_adapter_name () ); dynamic_adapter->create_request ( this, this->protocol_proxy_->orb_core ()-> orb (), operation, arg_list, result, 0, request, req_flags ACE_ENV_ARG_PARAMETER ); } void CORBA::Object::_create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::ExceptionList_ptr exceptions, CORBA::ContextList_ptr, CORBA::Request_ptr &request, CORBA::Flags req_flags ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE; // Since we don't really support Context, anything but a null pointer // is a no-no. // Neither can we create a request object from locality constrained // object references. if (ctx != 0 || this->protocol_proxy_ == 0) { ACE_THROW (CORBA::NO_IMPLEMENT ()); } TAO_Dynamic_Adapter *dynamic_adapter = ACE_Dynamic_Service::instance ( TAO_ORB_Core::dynamic_adapter_name () ); dynamic_adapter->create_request ( this, this->protocol_proxy_->orb_core ()-> orb (), operation, arg_list, result, exceptions, request, req_flags ACE_ENV_ARG_PARAMETER ); } CORBA::Request_ptr CORBA::Object::_request (const char *operation ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; if (this->protocol_proxy_) { TAO_Dynamic_Adapter *dynamic_adapter = ACE_Dynamic_Service::instance ( TAO_ORB_Core::dynamic_adapter_name () ); return dynamic_adapter->request ( this, this->protocol_proxy_->orb_core ()->orb (), operation ACE_ENV_ARG_PARAMETER ); } else { ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), 0); } } // NON_EXISTENT ... send a simple call to the object, which will // either elicit a FALSE response or a OBJECT_NOT_EXIST exception. In // the latter case, return FALSE. CORBA::Boolean CORBA::Object::_non_existent (ACE_ENV_SINGLE_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; CORBA::Boolean _tao_retval = 0; // Get the right Proxy. TAO_Object_Proxy_Impl &the_proxy = this->proxy_broker_->select_proxy (this ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); // Perform the Call. _tao_retval = the_proxy._non_existent (this ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); return _tao_retval; } CORBA::InterfaceDef_ptr CORBA::Object::_get_interface (ACE_ENV_SINGLE_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; // Get the right Proxy. TAO_Object_Proxy_Impl &the_proxy = this->proxy_broker_->select_proxy (this ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); // Perform the Call. return the_proxy._get_interface (this ACE_ENV_ARG_PARAMETER); } CORBA::ImplementationDef_ptr CORBA::Object::_get_implementation (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) { return 0; } CORBA::Object_ptr CORBA::Object::_get_component (ACE_ENV_SINGLE_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; // Get the right Proxy. TAO_Object_Proxy_Impl &the_proxy = this->proxy_broker_->select_proxy (this ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); // Perform the Call. return the_proxy._get_component (this ACE_ENV_ARG_PARAMETER); } #endif /* TAO_HAS_MINIMUM_CORBA */ // **************************************************************** // @@ Does it make sense to support policy stuff for locality constrained // objects? Also, does it make sense to bind policies with stub object? // - nw. #if (TAO_HAS_CORBA_MESSAGING == 1) CORBA::Policy_ptr CORBA::Object::_get_policy ( CORBA::PolicyType type ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; if (this->protocol_proxy_) return this->protocol_proxy_->get_policy (type ACE_ENV_ARG_PARAMETER); else ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), CORBA::Policy::_nil ()); } CORBA::Policy_ptr CORBA::Object::_get_client_policy ( CORBA::PolicyType type ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; if (this->protocol_proxy_) return this->_stubobj ()->get_client_policy (type ACE_ENV_ARG_PARAMETER); else ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), CORBA::Policy::_nil ()); } CORBA::Object_ptr CORBA::Object::_set_policy_overrides ( const CORBA::PolicyList & policies, CORBA::SetOverrideType set_add ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; if (!this->protocol_proxy_) ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), CORBA::Policy::_nil ()); TAO_Stub* stub = this->protocol_proxy_->set_policy_overrides (policies, set_add ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (CORBA::Object::_nil ()); TAO_Stub_Auto_Ptr safe_stub (stub); CORBA::Object_ptr obj = CORBA::Object::_nil (); ACE_NEW_THROW_EX (obj, CORBA::Object (stub, this->is_collocated_), CORBA::NO_MEMORY ( CORBA::SystemException::_tao_minor_code ( TAO_DEFAULT_MINOR_CODE, ENOMEM), CORBA::COMPLETED_MAYBE)); ACE_CHECK_RETURN (CORBA::Object::_nil ()); (void) safe_stub.release (); return obj; } CORBA::PolicyList * CORBA::Object::_get_policy_overrides (const CORBA::PolicyTypeSeq & types ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; if (this->protocol_proxy_) return this->protocol_proxy_->get_policy_overrides (types ACE_ENV_ARG_PARAMETER); else ACE_THROW_RETURN (CORBA::NO_IMPLEMENT (), 0); } CORBA::Boolean CORBA::Object::_validate_connection ( CORBA::PolicyList_out inconsistent_policies ACE_ENV_ARG_DECL) { TAO_OBJECT_IOR_EVALUATE_RETURN; inconsistent_policies = 0; #if (TAO_HAS_MINIMUM_CORBA == 1) ACE_ENV_ARG_NOT_USED; // FUZZ: ignore check_for_ace_check #else // If the object is collocated then use non_existent to see whether // it's there. if (this->is_collocated_) return !(this->_non_existent (ACE_ENV_SINGLE_ARG_PARAMETER)); if (this->protocol_proxy_) return this->protocol_proxy_->validate_connection (inconsistent_policies ACE_ENV_ARG_PARAMETER); #endif /* TAO_HAS_MINIMUM_CORBA */ return 0; } #endif /* TAO_HAS_CORBA_MESSAGING == 1 */ /***************************************************************** * Global Functions ****************************************************************/ CORBA::Boolean operator<< (TAO_OutputCDR& cdr, const CORBA::Object* x) { if (x == 0) { // NIL objrefs ... marshal as empty type hint, no elements. cdr.write_ulong (1); cdr.write_char ('\0'); cdr.write_ulong (0); return (CORBA::Boolean) cdr.good_bit (); } TAO_Stub *stubobj = x->_stubobj (); if (stubobj == 0) return 0; // STRING, a type ID hint if ((cdr << stubobj->type_id.in ()) == 0) return 0; const TAO_MProfile& mprofile = stubobj->base_profiles (); CORBA::ULong profile_count = mprofile.profile_count (); if ((cdr << profile_count) == 0) return 0; // @@ The MProfile should be locked during this iteration, is there // anyway to achieve that? for (CORBA::ULong i = 0; i < profile_count; ++i) { const TAO_Profile* p = mprofile.get_profile (i); if (p->encode (cdr) == 0) return 0; } return (CORBA::Boolean) cdr.good_bit (); } /*static*/ void CORBA::Object::tao_object_initialize (CORBA::Object *obj) { CORBA::ULong profile_count = obj->ior_->profiles.length (); // Assumption is that after calling this method, folks should test // for protocol_proxy_ or whatever to make sure that things have // been initialized! if (profile_count == 0) return; // get a profile container to store all profiles in the IOR. TAO_MProfile mp (profile_count); TAO_ORB_Core *&orb_core = obj->orb_core_; if (orb_core == 0) { orb_core = TAO_ORB_Core_instance (); if (TAO_debug_level > 0) { ACE_DEBUG ((LM_WARNING, ACE_LIB_TEXT ("TAO (%P|%t) - Object::tao_object_initialize ") ACE_LIB_TEXT ("WARNING: extracting object from ") ACE_LIB_TEXT ("default ORB_Core\n"))); } } TAO_Stub *objdata = 0; ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { TAO_Connector_Registry *connector_registry = orb_core->connector_registry (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; for (CORBA::ULong i = 0; i != profile_count; ++i) { IOP::TaggedProfile &tpfile = obj->ior_->profiles[i]; // NOTE: This is a place for optimizations. Here we have an // 2 allocations and 2 copies. Future optimizations should // target this place. TAO_OutputCDR o_cdr; o_cdr << tpfile; TAO_InputCDR cdr (o_cdr, orb_core->input_cdr_buffer_allocator (), orb_core->input_cdr_dblock_allocator (), orb_core->input_cdr_msgblock_allocator (), orb_core); TAO_Profile *pfile = connector_registry->create_profile (cdr); if (pfile != 0) mp.give_profile (pfile); } // Make sure we got some profiles! if (mp.profile_count () != profile_count) { // @@ This occurs when profile creation fails when decoding the // profile from the IOR. ACE_ERROR ((LM_ERROR, ACE_LIB_TEXT ("TAO (%P|%t) ERROR: XXXXX Could not create all ") ACE_LIB_TEXT ("profiles while extracting object\n") ACE_LIB_TEXT ("TAO (%P|%t) ERROR: reference from the ") ACE_LIB_TEXT ("CDR stream.\n"))); } objdata = orb_core->create_stub (obj->ior_->type_id.in (), mp ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; } ACE_CATCHANY { if (TAO_debug_level > 0) ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, ACE_LIB_TEXT ("TAO (%P|%t) ERROR creating stub ") ACE_LIB_TEXT ("object when demarshaling object ") ACE_LIB_TEXT ("reference.\n")); return; } ACE_ENDTRY; ACE_CHECK; TAO_Stub_Auto_Ptr safe_objdata (objdata); if (orb_core->initialize_object (safe_objdata.get (), obj) == -1) return; obj->protocol_proxy_ = objdata; // If the object is collocated then set the broker using the // factory otherwise use the remote proxy broker. if (obj->is_collocated_ && _TAO_collocation_Object_Proxy_Broker_Factory_function_pointer != 0) obj->proxy_broker_ = _TAO_collocation_Object_Proxy_Broker_Factory_function_pointer (obj); else obj->proxy_broker_ = the_tao_remote_object_proxy_broker (); obj->is_evaluated_ = 1; // Release the contents of the ior to keep memory consumption down. obj->ior_ = 0; // Transfer ownership to the CORBA::Object (void) safe_objdata.release (); return; } CORBA::Boolean operator>> (TAO_InputCDR& cdr, CORBA::Object*& x) { int lazy_strategy = 0; TAO_ORB_Core *orb_core = cdr.orb_core (); if (orb_core == 0) { orb_core = TAO_ORB_Core_instance (); if (TAO_debug_level > 0) { ACE_DEBUG ((LM_WARNING, ACE_LIB_TEXT ("TAO (%P|%t) WARNING: extracting object from ") ACE_LIB_TEXT ("default ORB_Core\n"))); } } else { if (orb_core->resource_factory ()->resource_usage_strategy () == TAO_Resource_Factory::TAO_LAZY) lazy_strategy = 1; } if (!lazy_strategy) { // If the user has set up a eager strategy.. CORBA::String_var type_hint; if ((cdr >> type_hint.inout ()) == 0) return 0; CORBA::ULong profile_count; if ((cdr >> profile_count) == 0) return 0; if (profile_count == 0) { x = CORBA::Object::_nil (); return (CORBA::Boolean) cdr.good_bit (); } // get a profile container to store all profiles in the IOR. TAO_MProfile mp (profile_count); TAO_ORB_Core *orb_core = cdr.orb_core (); if (orb_core == 0) { orb_core = TAO_ORB_Core_instance (); if (TAO_debug_level > 0) { ACE_DEBUG ((LM_WARNING, ACE_LIB_TEXT ("TAO (%P|%t) - Object::tao_object_initialize ") ACE_LIB_TEXT ("WARNING: extracting object from ") ACE_LIB_TEXT ("default ORB_Core\n"))); } } // Ownership of type_hint is given to TAO_Stub // TAO_Stub will make a copy of mp! TAO_Stub *objdata = 0; ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { TAO_Connector_Registry *connector_registry = orb_core->connector_registry (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; for (CORBA::ULong i = 0; i != profile_count && cdr.good_bit (); ++i) { TAO_Profile *pfile = connector_registry->create_profile (cdr); if (pfile != 0) mp.give_profile (pfile); } // Make sure we got some profiles! if (mp.profile_count () != profile_count) { // @@ This occurs when profile creation fails when decoding the // profile from the IOR. ACE_ERROR_RETURN ((LM_ERROR, ACE_LIB_TEXT ("TAO (%P|%t) ERROR: Could not create all ") ACE_LIB_TEXT ("profiles while extracting object\n") ACE_LIB_TEXT ("TAO (%P|%t) ERROR: reference from the ") ACE_LIB_TEXT ("CDR stream.\n")), 0); } objdata = orb_core->create_stub (type_hint.in (), mp ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; } ACE_CATCHANY { if (TAO_debug_level > 0) ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, ACE_LIB_TEXT ("TAO (%P|%t) ERROR creating stub ") ACE_LIB_TEXT ("object when demarshaling object ") ACE_LIB_TEXT ("reference.\n")); return 0; } ACE_ENDTRY; ACE_CHECK_RETURN (0); TAO_Stub_Auto_Ptr safe_objdata (objdata); x = orb_core->create_object (safe_objdata.get ()); if (x == 0) return 0; // Transfer ownership to the CORBA::Object (void) safe_objdata.release (); } else { // Lazy strategy! IOP::IOR *ior = 0; ACE_NEW_RETURN (ior, IOP::IOR (), 0); cdr >> *ior; ACE_NEW_RETURN (x, CORBA::Object (ior, orb_core), 0); } return (CORBA::Boolean) cdr.good_bit (); } TAO_Object_Proxy_Broker * (*_TAO_collocation_Object_Proxy_Broker_Factory_function_pointer) ( CORBA::Object_ptr obj ) = 0; // **************************************************************** #if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) template class TAO_Object_Manager; #elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) #pragma instantiate TAO_Object_Manager #endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */