summaryrefslogtreecommitdiff
path: root/TAO/tao/Policy_Manager.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Policy_Manager.cpp')
-rw-r--r--TAO/tao/Policy_Manager.cpp289
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 &current)
-{
- TAO_TSS_Resources *tss =
- TAO_TSS_RESOURCES::instance ();
-
- TAO_Policy_Current_Impl *old = tss->policy_current_;
- tss->policy_current_ = &current;
- return *old;
-}
-
-TAO_Policy_Current_Impl &
-TAO_Policy_Current::implementation (void) const
-{
- return *TAO_TSS_RESOURCES::instance ()->policy_current_;
-}
-
-#endif /* TAO_HAS_CORBA_MESSAGING */
View Lorry Controller Status