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
|
/* -*- C++ -*- */
// $Id$
//
// ============================================================================
//
// = LIBRARY
// TAO
//
// = DESCRIPTION
// Implementation classes for the Messaging related policies
//
// = FILENAME
// Messaging_Policy_i.h
//
// = AUTHOR
// Carlos O'Ryan (coryan@cs.wustl.edu)
//
// ============================================================================
#ifndef TAO_MESSAGING_POLICY_I_H
#define TAO_MESSAGING_POLICY_I_H
#include "ace/pre.h"
#include "tao/orbconf.h"
#include "tao/MessagingC.h"
#include "tao/LocalObject.h"
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class TAO_Export TAO_RelativeRoundtripTimeoutPolicy
: public Messaging::RelativeRoundtripTimeoutPolicy,
public TAO_Local_RefCounted_Object
{
// = TITLE
// Messaging::RelativeRoundtripTimeoutPolicy implementation
//
// = DESCRIPTION
// This policy controls the total (round-trip) timeout time for a
// request.
//
public:
TAO_RelativeRoundtripTimeoutPolicy (const TimeBase::TimeT& relative_expiry);
// Constructor.
TAO_RelativeRoundtripTimeoutPolicy (const TAO_RelativeRoundtripTimeoutPolicy &rhs);
// Copy constructor.
/// Implement the timeout hook, this is set in the ORB_Core at
/// initialization time.
static void hook (TAO_ORB_Core *orb_core,
TAO_Stub *stub,
int &has_timeout,
ACE_Time_Value &time_value);
static CORBA::Policy_ptr create (const CORBA::Any& val,
CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ());
// Helper method for the implementation of
// CORBA::ORB::create_policy.
virtual TAO_RelativeRoundtripTimeoutPolicy *clone (void) const;
// Returns a copy of <this>.
// = The Messaging::RelativeRoundtripTimeoutPolicy methods
virtual TimeBase::TimeT relative_expiry (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC (());
virtual CORBA::PolicyType policy_type (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CORBA::Policy_ptr copy (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void destroy (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
void set_time_value (ACE_Time_Value &time_value);
// Change the CORBA representation to the ACE representation.
private:
TimeBase::TimeT relative_expiry_;
// The attribute
};
////////////////////////////////////////////////////////////////////////////////
class TAO_Export TAO_Sync_Scope_Policy
: public Messaging::SyncScopePolicy,
public TAO_Local_RefCounted_Object
{
// = TITLE
// Messaging::SyncScopePolicy implementation.
//
// = DESCRIPTION
// This policy controls the sync strategy used by the ORB to
// transport requests.
//
public:
TAO_Sync_Scope_Policy (Messaging::SyncScope synchronization);
// Constructor.
TAO_Sync_Scope_Policy (const TAO_Sync_Scope_Policy &rhs);
// Copy constructor.
/// Implement the Sync_Scope hook, this is set in the ORB_Core at
/// initialization time.
static void hook (TAO_ORB_Core *orb_core,
TAO_Stub *stub,
int &has_synchronization,
int &scope);
static CORBA::Policy_ptr create (const CORBA::Any& val,
CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ());
// Helper method for the implementation of
// CORBA::ORB::create_policy.
virtual TAO_Sync_Scope_Policy *clone (void) const;
// Returns a copy of <this>.
// = The Messaging::SyncScopePolicy methods.
virtual Messaging::SyncScope synchronization (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
void get_synchronization (Messaging::SyncScope &synchronization) const;
virtual CORBA::PolicyType policy_type (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CORBA::Policy_ptr copy (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void destroy (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
private:
Messaging::SyncScope synchronization_;
// The attribute
};
#if defined (__ACE_INLINE__)
#include "tao/Messaging_Policy_i.i"
#endif /* __ACE_INLINE__ */
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */
#include "ace/post.h"
#endif /* TAO_MESSAGING_POLICY_I_H */
|
