diff options
Diffstat (limited to 'ACE/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp')
| -rw-r--r-- | ACE/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp | 234 |
1 files changed, 234 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp b/ACE/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp new file mode 100644 index 00000000000..de34ec90dd8 --- /dev/null +++ b/ACE/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Policy_i.cpp @@ -0,0 +1,234 @@ +//$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 (void) +{ + return this->request_duration_; +} + +CORBA::PolicyType +TAO_FT_Request_Duration_Policy::policy_type (void) +{ + return FT::REQUEST_DURATION_POLICY; +} + +CORBA::Policy_ptr +TAO_FT_Request_Duration_Policy::create (const CORBA::Any& val) +{ + TimeBase::TimeT value; + if ((val >>= value) == 0) + throw CORBA::PolicyError (CORBA::BAD_POLICY_TYPE); + + 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)); + + 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 (void) +{ + 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)); + + return tmp; +} + +void +TAO_FT_Request_Duration_Policy::destroy (void) +{ +} + +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 (void) +{ + 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) +{ + FT::HeartbeatPolicyValue *value; + if ((val >>= value) == 0) + throw CORBA::PolicyError (CORBA::BAD_POLICY_TYPE); + + 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)); + + return tmp; +} + + +CORBA::PolicyType +TAO_FT_Heart_Beat_Policy::policy_type (void) +{ + return FT::HEARTBEAT_POLICY; +} + + +CORBA::Policy_ptr +TAO_FT_Heart_Beat_Policy::copy (void) +{ + 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)); + + 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 (void) +{ +} + +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 () +{ + return this->heartbeat_enabled_value_; +} + + +CORBA::Policy_ptr +TAO_FT_Heart_Beat_Enabled_Policy::create (const CORBA::Any& val) +{ + CORBA::Boolean value; + + if ((val >>= CORBA::Any::to_boolean (value)) == 0) + throw CORBA::PolicyError (CORBA::BAD_POLICY_TYPE); + + 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)); + + return tmp; +} + +CORBA::PolicyType +TAO_FT_Heart_Beat_Enabled_Policy::policy_type (void) +{ + return FT::HEARTBEAT_ENABLED_POLICY; +} + + +CORBA::Policy_ptr +TAO_FT_Heart_Beat_Enabled_Policy::copy (void) +{ + 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)); + + 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 (void) +{ +} + +TAO_END_VERSIONED_NAMESPACE_DECL |