diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp | 259 |
1 files changed, 0 insertions, 259 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp b/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp deleted file mode 100644 index c24aa921d17..00000000000 --- a/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp +++ /dev/null @@ -1,259 +0,0 @@ -//$Id$ -#include "orbsvcs/FaultTolerance/FT_Policy_i.h" - -#include "tao/debug.h" - -#if !defined (__ACE_INLINE__) -#include "orbsvcs/FaultTolerance/FT_Policy_i.inl" -#endif /* __ACE_INLINE__ */ - -ACE_RCSID(FaultTolerance, FT_Policy_i, "$Id$") - -TAO_BEGIN_VERSIONED_NAMESPACE_DECL - -TimeBase::TimeT -TAO_FT_Request_Duration_Policy::request_duration_policy_value (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - return this->request_duration_; -} - -CORBA::PolicyType -TAO_FT_Request_Duration_Policy::policy_type (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - return FT::REQUEST_DURATION_POLICY; -} - -CORBA::Policy_ptr -TAO_FT_Request_Duration_Policy::create (const CORBA::Any& val - ACE_ENV_ARG_DECL) -{ - TimeBase::TimeT value; - if ((val >>= value) == 0) - ACE_THROW_RETURN (CORBA::PolicyError (CORBA::BAD_POLICY_TYPE), - CORBA::Policy::_nil ()); - - TAO_FT_Request_Duration_Policy *tmp; - ACE_NEW_THROW_EX (tmp, - TAO_FT_Request_Duration_Policy (value), - CORBA::NO_MEMORY (TAO::VMCID, - CORBA::COMPLETED_NO)); - ACE_CHECK_RETURN (CORBA::Policy::_nil ()); - - return tmp; -} - -TAO_FT_Request_Duration_Policy * -TAO_FT_Request_Duration_Policy::clone (void) const -{ - TAO_FT_Request_Duration_Policy *copy = 0; - ACE_NEW_RETURN (copy, - TAO_FT_Request_Duration_Policy (*this), - 0); - return copy; -} - -CORBA::Policy_ptr -TAO_FT_Request_Duration_Policy::copy (ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - TAO_FT_Request_Duration_Policy* tmp; - ACE_NEW_THROW_EX (tmp, TAO_FT_Request_Duration_Policy (*this), - CORBA::NO_MEMORY (TAO::VMCID, - CORBA::COMPLETED_NO)); - ACE_CHECK_RETURN (CORBA::Policy::_nil ()); - - return tmp; -} - -void -TAO_FT_Request_Duration_Policy::destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ -} - -void -TAO_FT_Request_Duration_Policy::set_time_value (ACE_Time_Value &time_value) -{ - TimeBase::TimeT t = this->request_duration_; - TimeBase::TimeT seconds = t / 10000000u; - TimeBase::TimeT microseconds = (t % 10000000u) / 10; - time_value.set (ACE_U64_TO_U32 (seconds), - ACE_U64_TO_U32 (microseconds)); - - if (TAO_debug_level > 0) - { - CORBA::ULong msecs = - static_cast<CORBA::ULong> (microseconds / 1000); - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("TAO_FT (%P|%t) - Timeout is <%u>\n"), - msecs)); - } -} - - -/*****************************************************************/ - -FT::HeartbeatPolicyValue -TAO_FT_Heart_Beat_Policy::heartbeat_policy_value (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - FT::HeartbeatPolicyValue val; - val.heartbeat = this->heartbeat_; - val.heartbeat_interval = this->heartbeat_interval_; - val.heartbeat_timeout = this->heartbeat_timeout_; - - return val; -} - - -CORBA::Policy_ptr -TAO_FT_Heart_Beat_Policy::create (const CORBA::Any& val - ACE_ENV_ARG_DECL) -{ - FT::HeartbeatPolicyValue *value; - if ((val >>= value) == 0) - ACE_THROW_RETURN (CORBA::PolicyError (CORBA::BAD_POLICY_TYPE), - CORBA::Policy::_nil ()); - - TAO_FT_Heart_Beat_Policy *tmp; - ACE_NEW_THROW_EX (tmp, - TAO_FT_Heart_Beat_Policy (value->heartbeat, - value->heartbeat_interval, - value->heartbeat_timeout), - CORBA::NO_MEMORY (TAO::VMCID, - CORBA::COMPLETED_NO)); - ACE_CHECK_RETURN (CORBA::Policy::_nil ()); - - return tmp; -} - - -CORBA::PolicyType -TAO_FT_Heart_Beat_Policy::policy_type (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - return FT::HEARTBEAT_POLICY; -} - - -CORBA::Policy_ptr -TAO_FT_Heart_Beat_Policy::copy (ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - TAO_FT_Heart_Beat_Policy * tmp; - ACE_NEW_THROW_EX (tmp, TAO_FT_Heart_Beat_Policy (*this), - CORBA::NO_MEMORY (TAO::VMCID, - CORBA::COMPLETED_NO)); - ACE_CHECK_RETURN (CORBA::Policy::_nil ()); - - return tmp; -} - -TAO_FT_Heart_Beat_Policy * -TAO_FT_Heart_Beat_Policy::clone (void) const -{ - TAO_FT_Heart_Beat_Policy *copy = 0; - ACE_NEW_RETURN (copy, - TAO_FT_Heart_Beat_Policy (*this), - 0); - return copy; -} - -void -TAO_FT_Heart_Beat_Policy::destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ -} - -void -TAO_FT_Heart_Beat_Policy::set_time_value (ACE_Time_Value &time_value, - const TimeBase::TimeT &timebase) -{ - TimeBase::TimeT t = timebase; - TimeBase::TimeT seconds = t / 10000000u; - TimeBase::TimeT microseconds = (t % 10000000u) / 10; - time_value.set (ACE_U64_TO_U32 (seconds), - ACE_U64_TO_U32 (microseconds)); - - if (TAO_debug_level > 0) - { - CORBA::ULong msecs = - static_cast<CORBA::ULong> (microseconds / 1000); - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("TAO_FT (%P|%t) - Timeout is <%u>\n"), - msecs)); - } -} - -/******************************************************************/ - -CORBA::Boolean -TAO_FT_Heart_Beat_Enabled_Policy::heartbeat_enabled_policy_value ( - ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - return this->heartbeat_enabled_value_; -} - - -CORBA::Policy_ptr -TAO_FT_Heart_Beat_Enabled_Policy::create (const CORBA::Any& val - ACE_ENV_ARG_DECL) -{ - CORBA::Boolean value; - - if ((val >>= CORBA::Any::to_boolean (value)) == 0) - ACE_THROW_RETURN (CORBA::PolicyError (CORBA::BAD_POLICY_TYPE), - CORBA::Policy::_nil ()); - - TAO_FT_Heart_Beat_Enabled_Policy *tmp; - ACE_NEW_THROW_EX (tmp, - TAO_FT_Heart_Beat_Enabled_Policy (value), - CORBA::NO_MEMORY (TAO::VMCID, - CORBA::COMPLETED_NO)); - ACE_CHECK_RETURN (CORBA::Policy::_nil ()); - - return tmp; -} - -CORBA::PolicyType -TAO_FT_Heart_Beat_Enabled_Policy::policy_type (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - return FT::HEARTBEAT_ENABLED_POLICY; -} - - -CORBA::Policy_ptr -TAO_FT_Heart_Beat_Enabled_Policy::copy (ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - TAO_FT_Heart_Beat_Enabled_Policy * tmp; - ACE_NEW_THROW_EX (tmp, TAO_FT_Heart_Beat_Enabled_Policy (*this), - CORBA::NO_MEMORY (TAO::VMCID, - CORBA::COMPLETED_NO)); - ACE_CHECK_RETURN (CORBA::Policy::_nil ()); - - return tmp; -} - -TAO_FT_Heart_Beat_Enabled_Policy * -TAO_FT_Heart_Beat_Enabled_Policy::clone (void) const -{ - TAO_FT_Heart_Beat_Enabled_Policy *copy = 0; - ACE_NEW_RETURN (copy, - TAO_FT_Heart_Beat_Enabled_Policy (*this), - 0); - return copy; -} - - -void -TAO_FT_Heart_Beat_Enabled_Policy::destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ -} - -TAO_END_VERSIONED_NAMESPACE_DECL |