diff options
Diffstat (limited to 'TAO/tao/Policy_Manager.cpp')
-rw-r--r-- | TAO/tao/Policy_Manager.cpp | 289 |
1 files changed, 0 insertions, 289 deletions
diff --git a/TAO/tao/Policy_Manager.cpp b/TAO/tao/Policy_Manager.cpp deleted file mode 100644 index d693805fd4d..00000000000 --- a/TAO/tao/Policy_Manager.cpp +++ /dev/null @@ -1,289 +0,0 @@ -// $Id$ - -#include "tao/orbconf.h" - -#if defined (TAO_HAS_CORBA_MESSAGING) - -#include "tao/Policy_Manager.h" -#include "tao/Environment.h" -#include "tao/ORB_Core.h" - -#if !defined (__ACE_INLINE__) -# include "tao/Policy_Manager.i" -#endif /* ! __ACE_INLINE__ */ - -ACE_RCSID(tao, Policy_Manager, "$Id$") - -void -TAO_Policy_Manager_Impl::set_policy_overrides ( - const CORBA::PolicyList & policies, - CORBA::SetOverrideType set_add, - CORBA::Environment &ACE_TRY_ENV) -{ - // @@ The spec does not say what to do on this case. - if (set_add != CORBA::SET_OVERRIDE - && set_add != CORBA::ADD_OVERRIDE) - ACE_THROW (CORBA::BAD_PARAM (TAO_DEFAULT_MINOR_CODE, - CORBA::COMPLETED_NO)); - - if (set_add == CORBA::SET_OVERRIDE) - { - for (CORBA::ULong i = 0; i < this->other_policies_.length (); ++i) - { - this->other_policies_[i]->destroy (ACE_TRY_ENV); - ACE_CHECK; - this->other_policies_[i] = CORBA::Policy::_nil (); - } - this->other_policies_.length (0); - if (this->relative_roundtrip_timeout_ != 0) - { - this->relative_roundtrip_timeout_->destroy (ACE_TRY_ENV); - ACE_CHECK; - this->relative_roundtrip_timeout_->_remove_ref (ACE_TRY_ENV); - ACE_CHECK; - this->relative_roundtrip_timeout_ = 0; - } - this->count_ = 0; - } - - for (CORBA::ULong i = 0; i < policies.length (); ++i) - { - CORBA::Policy_ptr policy = policies[i]; - if (CORBA::is_nil (policy)) - continue; - - CORBA::ULong slot = policy->policy_type (ACE_TRY_ENV); - ACE_CHECK; - - switch (slot) - { - case TAO_MESSAGING_RELATIVE_RT_TIMEOUT_POLICY_TYPE: - { - CORBA::Policy_var copy = policy->copy (ACE_TRY_ENV); - ACE_CHECK; - - TAO_ServantBase* servant = copy->_servant (); - if (servant == 0) - ACE_THROW (CORBA::INTERNAL ()); - - POA_Messaging::RelativeRoundtripTimeoutPolicy *tmp = - ACE_static_cast(POA_Messaging::RelativeRoundtripTimeoutPolicy*, - servant->_downcast ("IDL:Messaging/RelativeRoundtripTimeoutPolicy:1.0")); - if (tmp == 0) - ACE_THROW (CORBA::INTERNAL ()); - - if (this->relative_roundtrip_timeout_ != 0) - { - this->relative_roundtrip_timeout_->destroy (ACE_TRY_ENV); - ACE_CHECK; - this->relative_roundtrip_timeout_->_remove_ref (ACE_TRY_ENV); - ACE_CHECK; - } - this->relative_roundtrip_timeout_ = tmp; - this->relative_roundtrip_timeout_->_add_ref (ACE_TRY_ENV); - ACE_CHECK; - this->count_++; - } - break; - - case TAO_MESSAGING_REBIND_POLICY_TYPE: - case TAO_MESSAGING_SYNC_SCOPE_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_PRIORITY_POLICY_TYPE: - case TAO_MESSAGING_REPLY_PRIORITY_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_START_TIME_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_END_TIME_POLICY_TYPE: - case TAO_MESSAGING_REPLY_START_TIME_POLICY_TYPE: - case TAO_MESSAGING_REPLY_END_TIME_POLICY_TYPE: - case TAO_MESSAGING_RELATIVE_REQ_TIMEOUT_POLICY_TYPE: - case TAO_MESSAGING_ROUTING_POLICY_TYPE: - case TAO_MESSAGING_MAX_HOPS_POLICY_TYPE: - case TAO_MESSAGING_QUEUE_ORDER_POLICY_TYPE: - default: - { - CORBA::Policy_var copy = policy->copy (ACE_TRY_ENV); - ACE_CHECK; - - CORBA::ULong j = 0; - CORBA::ULong length = this->other_policies_.length (); - while (j != length) - { - CORBA::ULong current = - this->other_policies_[j]->policy_type (ACE_TRY_ENV); - ACE_CHECK; - - if (current == slot) - { - this->other_policies_[j]->destroy (ACE_TRY_ENV); - ACE_CHECK; - this->other_policies_[j] = copy._retn (); - break; - } - ++j; - } - if (j == length) - { - this->other_policies_.length (length + 1); - this->other_policies_[j] = copy._retn (); - } - } - break; - } - } -} - -CORBA::PolicyList * -TAO_Policy_Manager_Impl::get_policy_overrides ( - const CORBA::PolicyTypeSeq & types, - CORBA::Environment &ACE_TRY_ENV) -{ - CORBA::ULong types_length = types.length (); - - CORBA::ULong slots = types_length; - if (slots == 0) - slots = this->count_; - - CORBA::PolicyList_var policy_list = - new CORBA::PolicyList (slots); - policy_list->length (slots); - - CORBA::ULong n = 0; - if (types_length == 0) - { - if (this->relative_roundtrip_timeout_ != 0) - { - policy_list[n++] = - relative_roundtrip_timeout_->_this (ACE_TRY_ENV); - ACE_CHECK_RETURN (0); - } - CORBA::ULong length = this->other_policies_.length (); - for (CORBA::ULong i = 0; i != length; ++i) - { - if (CORBA::is_nil (this->other_policies_[i].in ())) - continue; - policy_list[n++] = - CORBA::Policy::_duplicate (this->other_policies_[i].in ()); - } - } - else - { - for (CORBA::ULong j = 0; j < types.length (); ++j) - { - CORBA::ULong slot = types[j]; - - switch (slot) - { - case TAO_MESSAGING_RELATIVE_RT_TIMEOUT_POLICY_TYPE: - if (this->relative_roundtrip_timeout_ != 0) - { - policy_list[n++] = - relative_roundtrip_timeout_->_this (ACE_TRY_ENV); - ACE_CHECK_RETURN (0); - } - break; - - case TAO_MESSAGING_REBIND_POLICY_TYPE: - case TAO_MESSAGING_SYNC_SCOPE_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_PRIORITY_POLICY_TYPE: - case TAO_MESSAGING_REPLY_PRIORITY_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_START_TIME_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_END_TIME_POLICY_TYPE: - case TAO_MESSAGING_REPLY_START_TIME_POLICY_TYPE: - case TAO_MESSAGING_REPLY_END_TIME_POLICY_TYPE: - case TAO_MESSAGING_RELATIVE_REQ_TIMEOUT_POLICY_TYPE: - case TAO_MESSAGING_ROUTING_POLICY_TYPE: - case TAO_MESSAGING_MAX_HOPS_POLICY_TYPE: - case TAO_MESSAGING_QUEUE_ORDER_POLICY_TYPE: - default: - { - CORBA::ULong length = this->other_policies_.length (); - for (CORBA::ULong i = 0; - i != length; - ++i) - { - CORBA::ULong current = - this->other_policies_[i]->policy_type (ACE_TRY_ENV); - ACE_CHECK_RETURN (0); - - if (current != slot) - continue; - - policy_list[n++] = - CORBA::Policy::_duplicate (this->other_policies_[i].in ()); - break; - } - } - } - } - } - - policy_list->length (n); - return policy_list._retn (); -} - -CORBA::Policy_ptr -TAO_Policy_Manager_Impl::get_policy ( - CORBA::PolicyType type, - CORBA::Environment &ACE_TRY_ENV) -{ - switch (type) - { - case TAO_MESSAGING_RELATIVE_RT_TIMEOUT_POLICY_TYPE: - if (this->relative_roundtrip_timeout_ != 0) - { - return this->relative_roundtrip_timeout_->_this (ACE_TRY_ENV); - } - return CORBA::Policy::_nil (); - - case TAO_MESSAGING_REBIND_POLICY_TYPE: - case TAO_MESSAGING_SYNC_SCOPE_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_PRIORITY_POLICY_TYPE: - case TAO_MESSAGING_REPLY_PRIORITY_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_START_TIME_POLICY_TYPE: - case TAO_MESSAGING_REQUEST_END_TIME_POLICY_TYPE: - case TAO_MESSAGING_REPLY_START_TIME_POLICY_TYPE: - case TAO_MESSAGING_REPLY_END_TIME_POLICY_TYPE: - case TAO_MESSAGING_RELATIVE_REQ_TIMEOUT_POLICY_TYPE: - case TAO_MESSAGING_ROUTING_POLICY_TYPE: - case TAO_MESSAGING_MAX_HOPS_POLICY_TYPE: - case TAO_MESSAGING_QUEUE_ORDER_POLICY_TYPE: - default: - { - CORBA::ULong length = this->other_policies_.length (); - for (CORBA::ULong i = 0; - i != length; - ++i) - { - CORBA::ULong current = - this->other_policies_[i]->policy_type (ACE_TRY_ENV); - ACE_CHECK_RETURN (0); - - if (current != type) - continue; - - return CORBA::Policy::_duplicate (this->other_policies_[i].in ()); - } - } - } - return CORBA::Policy::_nil (); -} - -// **************************************************************** - -TAO_Policy_Current_Impl & -TAO_Policy_Current::implementation (TAO_Policy_Current_Impl ¤t) -{ - TAO_TSS_Resources *tss = - TAO_TSS_RESOURCES::instance (); - - TAO_Policy_Current_Impl *old = tss->policy_current_; - tss->policy_current_ = ¤t; - return *old; -} - -TAO_Policy_Current_Impl & -TAO_Policy_Current::implementation (void) const -{ - return *TAO_TSS_RESOURCES::instance ()->policy_current_; -} - -#endif /* TAO_HAS_CORBA_MESSAGING */ |