blob: 9b5cf34fc05d00f8ae5bc404fcb35a4f5710cde6 (
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
|
/* -*- 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 "tao/orbconf.h"
#if (TAO_HAS_CORBA_MESSAGING == 1)
#include "tao/MessagingS.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 TAO_RefCountServantBase,
public POA_Messaging::RelativeRoundtripTimeoutPolicy
{
// = TITLE
// Messaging::RelativeRoundtripTimeoutPolicy implementation
//
// = DESCRIPTION
// This policy controls the total (round-trip) timeout time for a
// request.
//
public:
TAO_RelativeRoundtripTimeoutPolicy (PortableServer::POA_ptr poa,
const TimeBase::TimeT& relative_expiry);
// Constructor.
TAO_RelativeRoundtripTimeoutPolicy (const TAO_RelativeRoundtripTimeoutPolicy &rhs);
// Copy constructor.
static CORBA::Policy_ptr create (PortableServer::POA_ptr poa,
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);
virtual TimeBase::TimeT relative_expiry (void);
virtual CORBA::PolicyType policy_type (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ());
virtual CORBA::Policy_ptr copy (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ());
virtual void destroy (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ());
virtual PortableServer::POA_ptr _default_POA (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ());
void set_time_value (ACE_Time_Value &time_value);
// Change the CORBA representation to the ACE representation.
private:
PortableServer::POA_var poa_;
// The default poa
TimeBase::TimeT relative_expiry_;
// The attribute
};
////////////////////////////////////////////////////////////////////////////////
class TAO_Export TAO_Sync_Scope_Policy : public TAO_RefCountServantBase,
public POA_Messaging::SyncScopePolicy
{
// = 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,
PortableServer::POA_ptr poa);
// Constructor.
TAO_Sync_Scope_Policy (const TAO_Sync_Scope_Policy &rhs);
// Copy constructor.
static CORBA::Policy_ptr create (PortableServer::POA_ptr poa,
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);
virtual Messaging::SyncScope synchronization (void);
virtual CORBA::PolicyType policy_type (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ());
virtual CORBA::Policy_ptr copy (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ());
virtual void destroy (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ());
virtual PortableServer::POA_ptr _default_POA (CORBA_Environment &ACE_TRY_ENV = TAO_default_environment ());
private:
Messaging::SyncScope synchronization_;
// The attribute
PortableServer::POA_var poa_;
// The default poa.
};
#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 */
#endif /* TAO_HAS_CORBA_MESSAGING == 1 */
#endif /* TAO_MESSAGING_POLICY_I_H */
|
