blob: f9e93824f1c6fb98c73e05ab3d374c76cf33cc29 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file FT_ClientPolicy_i.h
*
* $Id$
*
* @author Balachandran Natarajan <bala@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_FT_CLIENTPOLICY_I_H
#define TAO_FT_CLIENTPOLICY_I_H
#include /**/ "ace/pre.h"
#include "orbsvcs/FT_CORBA_ORBC.h"
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
#include "tao/LocalObject.h"
#include "FT_ClientORB_export.h"
/**
* @class TAO_FT_Request_Duration_Policy
*
* @brief FT::RequestDurationPolicy implementation
*
* This policy controls the request duration in the ORB. The
* semantics are like this. On the server side, the server should
* retain the details of the request from the client (and the
* reply sent to it too) atleast for the time period specified by
* this policy value. On the client side, the client uses this
* value to calculate the expiration_id in the RequestService
* context. The expiration_id is a sort of timeout for the client
* to keep trying to connect to server object groups under certain
* conditions.
*/
class TAO_FT_ClientORB_Export TAO_FT_Request_Duration_Policy
: public FT::RequestDurationPolicy,
public TAO_Local_RefCounted_Object
{
public:
/// Constructor.
TAO_FT_Request_Duration_Policy (const TimeBase::TimeT& relative_expiry);
/// Copy constructor.
TAO_FT_Request_Duration_Policy (const TAO_FT_Request_Duration_Policy &rhs);
/// Helper method for the implementation of
/// CORBA::ORB::create_policy.
static CORBA::Policy_ptr create (const CORBA::Any& val
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
/// Returns a copy of <this>.
virtual TAO_FT_Request_Duration_Policy *clone (void) const;
// = The FT::RequestDurationPolicy methods
virtual TimeBase::TimeT request_duration_policy_value (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CORBA::PolicyType policy_type (
ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CORBA::Policy_ptr copy (
ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void destroy (
ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Change the CORBA representation to the ACE representation.
void set_time_value (ACE_Time_Value &time_value);
private:
/// The attribute
TimeBase::TimeT request_duration_;
};
/**
* @class TAO_FT_Heart_Beat_Policy
*
* @brief FT::HeartBeatPolicy
*
* If this policy is set, it enables the client ORB to send
* heartbeats to the server ORB over the open connections.
*/
class TAO_FT_ClientORB_Export TAO_FT_Heart_Beat_Policy
: public FT::HeartbeatPolicy,
public TAO_Local_RefCounted_Object
{
public:
/// Constructor.
TAO_FT_Heart_Beat_Policy (const CORBA::Boolean boolean,
const TimeBase::TimeT &interval,
const TimeBase::TimeT &timeout);
/// Copy constructor.
TAO_FT_Heart_Beat_Policy (const TAO_FT_Heart_Beat_Policy &rhs);
/// Helper method for the implementation of
/// CORBA::ORB::create_policy.
static CORBA::Policy_ptr create (const CORBA::Any& val
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
/// Returns a copy of <this>.
virtual TAO_FT_Heart_Beat_Policy *clone (void) const;
// = The FT::HeartBeatPolicy methods
virtual FT::HeartbeatPolicyValue heartbeat_policy_value (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CORBA::PolicyType policy_type (
ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CORBA::Policy_ptr copy (
ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void destroy (
ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Change the CORBA representation to the ACE representation.
void set_time_value (ACE_Time_Value &time_value,
const TimeBase::TimeT &timebase);
private:
// The attributes
/// <heartbeat_> indicates whether heartbeating is enabled or not.
CORBA::Boolean heartbeat_;
/// Intervals in which heartbeat messages need to be sent
TimeBase::TimeT heartbeat_interval_;
/// The timeouts for the heartbeats
TimeBase::TimeT heartbeat_timeout_;
};
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */
#if defined (__ACE_INLINE__)
#include "FT_ClientPolicy_i.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_FT_CLIENTPOLICY_I_H */
|
