blob: b626c0f7f16bde25b20cf7c27560021dfbdccde8 (
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
|
/* -*- 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 defined (TAO_HAS_CORBA_MESSAGING)
#include "tao/MessagingS.h"
#if defined(_MSC_VER)
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class TAO_Export TAO_RelativeRoundtripTimeoutPolicy_i : public PortableServer::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_i (PortableServer::POA_ptr poa,
const TimeBase::TimeT& relative_expiry);
// Constructor.
#if !defined (ACE_WIN32) // @@ TODO: Temporary Fix
TAO_RelativeRoundtripTimeoutPolicy_i (const TAO_RelativeRoundtripTimeoutPolicy_i &rhs);
// Copy constructor.
#endif /* ACE_WIN32 */
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_i *clone (void) const;
// Returns a copy of <this>.
// = The Messaging::RelativeRoundtripTimeoutPolicy methods
virtual TimeBase::TimeT relative_expiry (
CORBA::Environment &ACE_TRY_ENV =
CORBA::Environment::default_environment ()
);
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:
PortableServer::POA_var poa_;
// The default poa
TimeBase::TimeT relative_expiry_;
// The attribute
};
////////////////////////////////////////////////////////////////////////////////
class TAO_Export TAO_Sync_Scope_Policy : public PortableServer::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.
#if !defined (ACE_WIN32) // @@ TODO: Temporary Fix
TAO_Sync_Scope_Policy (const TAO_Sync_Scope_Policy &rhs);
// Copy constructor.
#endif /* ACE_WIN32 */
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 = CORBA::Environment::default_environment ());
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)
#pragma warning(default:4250)
#endif /* _MSC_VER */
#endif /* TAO_HAS_CORBA_MESSAGING */
#endif /* TAO_MESSAGING_POLICY_I_H */
|
