diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/FaultTolerance/FT_ClientPolicy_i.cpp')
| -rwxr-xr-x | TAO/orbsvcs/orbsvcs/FaultTolerance/FT_ClientPolicy_i.cpp | 193 |
1 files changed, 0 insertions, 193 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_ClientPolicy_i.cpp b/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_ClientPolicy_i.cpp deleted file mode 100755 index b53265cbfa5..00000000000 --- a/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_ClientPolicy_i.cpp +++ /dev/null @@ -1,193 +0,0 @@ -//$Id$ -#include "orbsvcs/FaultTolerance/FT_ClientPolicy_i.h" - -#include "tao/debug.h" -#include "ace/Log_Msg.h" -#include "tao/ORB_Constants.h" -#include "tao/AnyTypeCode/Any.h" - -#if !defined (__ACE_INLINE__) -#include "orbsvcs/FaultTolerance/FT_ClientPolicy_i.inl" -#endif /* __ACE_INLINE__ */ - -ACE_RCSID(FaultTolerance, FT_ClientPolicy_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_VALUE), - CORBA::Policy::_nil ()); - - TAO_FT_Request_Duration_Policy *tmp = 0; - 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 = 0; - 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 = 0; - if ((val >>= value) == 0) - ACE_THROW_RETURN (CORBA::PolicyError (CORBA::BAD_POLICY_VALUE), - CORBA::Policy::_nil ()); - - TAO_FT_Heart_Beat_Policy *tmp = 0; - 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 = 0; - 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)); - } -} - -TAO_END_VERSIONED_NAMESPACE_DECL |