diff options
Diffstat (limited to 'TAO/tao/PortableServer/IORInfo.cpp')
| -rw-r--r-- | TAO/tao/PortableServer/IORInfo.cpp | 210 |
1 files changed, 210 insertions, 0 deletions
diff --git a/TAO/tao/PortableServer/IORInfo.cpp b/TAO/tao/PortableServer/IORInfo.cpp new file mode 100644 index 00000000000..df689cc906b --- /dev/null +++ b/TAO/tao/PortableServer/IORInfo.cpp @@ -0,0 +1,210 @@ +#include "tao/PortableServer/IORInfo.h" +#include "tao/PortableServer/POA.h" + +#include "tao/PolicyC.h" +#include "tao/IOPC.h" +#include "tao/ORB_Constants.h" + + +ACE_RCSID (PortableServer, + IORInfo, + "$Id$") + + +#if !defined (__ACE_INLINE__) +# include "IORInfo.inl" +#endif /* __ACE_INLINE__ */ + + +TAO_IORInfo::TAO_IORInfo (TAO_POA *poa) + : poa_ (poa), + components_established_ (0) +{ +} + +TAO_IORInfo::~TAO_IORInfo (void) +{ +} + +CORBA::Policy_ptr +TAO_IORInfo::get_effective_policy (CORBA::PolicyType type + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK_RETURN (CORBA::Policy::_nil ()); + + TAO_POA_Policy_Set &policies = + this->poa_->policies (); + + // @@ This brain damaged implementation exists due to the fact + // neither TAO_POA nor TAO_POA_Policy_Set exposes any methods + // useful for retrieving a given Policy in the POA's PolicyList. + // So, I use the lame interfaces for now. + // -Ossama + const CORBA::ULong num_policies = policies.num_policies (); + for (CORBA::ULong i = 0; i < num_policies; ++i) + { + // @@ This incurs at least two locks per loop iteration due + // to the reference counting found within the policy + // object reference!!! + CORBA::Policy_var policy = policies.get_policy_by_index (i); + + CORBA::PolicyType ptype = + policy->policy_type (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK_RETURN (CORBA::Policy::_nil ()); + + if (ptype == type) + return policy._retn (); + } + + // TODO: Now check the global ORB policies. + // ........ + + // No policy matching the given PolicyType was found. + ACE_THROW_RETURN (CORBA::INV_POLICY (CORBA::OMGVMCID | 3, + CORBA::COMPLETED_NO), + CORBA::Policy::_nil ()); +} + +void +TAO_IORInfo::add_ior_component (const IOP::TaggedComponent &component + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + if (this->components_established_) + ACE_THROW (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14, + CORBA::COMPLETED_NO)); + + // Add the given tagged component to all profiles. + this->poa_->save_ior_component (component + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} + +void +TAO_IORInfo::add_ior_component_to_profile ( + const IOP::TaggedComponent &component, + IOP::ProfileId profile_id + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + if (this->components_established_) + ACE_THROW (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14, + CORBA::COMPLETED_NO)); + + this->poa_->save_ior_component_and_profile_id (component, + profile_id + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} + +PortableInterceptor::AdapterManagerId +TAO_IORInfo::manager_id (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK_RETURN (0); + + return this->poa_->get_manager_id (ACE_ENV_SINGLE_ARG_PARAMETER); +} + +PortableInterceptor::AdapterState +TAO_IORInfo::state (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK_RETURN (PortableInterceptor::NON_EXISTENT); + + return this->poa_->get_adapter_state (ACE_ENV_SINGLE_ARG_PARAMETER); +} + +PortableInterceptor::ObjectReferenceTemplate * +TAO_IORInfo::adapter_template (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK_RETURN (0); + + // Return the Object Reference Template whenever an IOR Interceptor + // is invoked. Its value is the template created for the adapter + // policies and the IOR Interceptor calls to add_ior_component and + // add_ior_component_to_profile. It's a const value and its value + // never changes. + PortableInterceptor::ObjectReferenceTemplate *adapter_template = + this->poa_->get_adapter_template (); + + if (adapter_template == 0) + { + ACE_THROW_RETURN (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14, + CORBA::COMPLETED_NO), + 0); + } + + CORBA::add_ref (adapter_template); + + return adapter_template; +} + +PortableInterceptor::ObjectReferenceFactory * +TAO_IORInfo::current_factory (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK_RETURN (0); + + // Return the current_factory that is used to create the object + // references by the adapter. Though initially, its value is the + // same as the adapter_template, unlike adapter_template, its value + // can be changed. The value of the current_factory can be changed + // only during the call to components_established method. + PortableInterceptor::ObjectReferenceFactory *adapter_factory = + this->poa_->get_obj_ref_factory (); + + if (adapter_factory == 0) + { + ACE_THROW_RETURN (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14, + CORBA::COMPLETED_NO), + 0); + } + + CORBA::add_ref (adapter_factory); + + return adapter_factory; +} + +void +TAO_IORInfo::current_factory ( + PortableInterceptor::ObjectReferenceFactory * current_factory + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + this->poa_->set_obj_ref_factory (current_factory + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} + +void +TAO_IORInfo::check_validity (ACE_ENV_SINGLE_ARG_DECL) +{ + if (this->poa_ == 0) + { + // Although not defined by the spec, duplicate the behavior used + // by the ORBInitInfo object once CORBA::ORB_init() has been + // called. Specifically, the IORInfo object is no longer valid + // once the POA has invoked all IORInterceptor interception + // points. This also prevents memory access violations from + // occuring if the POA is destroyed before this IORInfo object. + ACE_THROW (CORBA::OBJECT_NOT_EXIST (TAO_DEFAULT_MINOR_CODE, + CORBA::COMPLETED_NO)); + } +} |