blob: 4f47a01e1924fcb487e84859977dc10925fcbb0e (
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
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
|
// -*- C++ -*-
//
//=============================================================================
/**
* @file Synch_Invocation.h
*
* $Id$
*
*
* @author Balachandran Natarajan <bala@dre.vanderbilt.edu>
*/
//=============================================================================
#ifndef TAO_SYNCH_INVOCATION_H
#define TAO_SYNCH_INVOCATION_H
#include /**/ "ace/pre.h"
#include "tao/Remote_Invocation.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/SystemException.h"
class TAO_Operation_Details;
class TAO_Synch_Reply_Dispatcher;
class TAO_InputCDR;
class ACE_Time_Value;
class TAO_Bind_Dispatcher_Guard;
namespace TAO
{
class Profile_Transport_Resolver;
/**
* @class Synch_Twoway_Invocation
*
* @brief All the action for a synchronous twoway invocation happen
* here.
*
* An object of this is type is created by TAO::Invocation_Adapter
* and invokes a method on this class. The method takes care of
* creating and sending a request, waiting for a reply and
* demarshalling the reply for the client.
*
*/
class TAO_Export Synch_Twoway_Invocation : public Remote_Invocation
{
public:
/// Constructor used by TAO::Invocation_Adapter
/**
* @param otarget The original target on which this invocation
* was started. This is there to be passed up to its parent
* class.
*
* @param resolver The profile and transport holder.
*
* @param detail Operation details of the invocation on the target
*
* @param response_expected Flag to indicate whether the
* operation encapsulated by @a op returns a response or not.
*/
Synch_Twoway_Invocation (CORBA::Object_ptr otarget,
Profile_Transport_Resolver &resolver,
TAO_Operation_Details &detail,
bool response_expected = true);
/// Method used by the adapter to kickstart an invocation to the
/// remote object.
/**
* There is a exception declaration in this method which ensures
* that the exceptions propogated by the remote objects are
* converted a CORBA exceptions for the clients. This method does
* a bunch of things necessary to create and send the
* invocation. This method is also nerve centre for the
* interceptor invocation points.
*/
Invocation_Status remote_twoway (ACE_Time_Value *max_wait_time
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::Exception));
protected:
/**
* This method is selectively made virtual, so that inherited
* classes can overload the user exception handling type. For
* example the DII needs a totally different method of
* user exception exception handling
*/
virtual Invocation_Status handle_user_exception (TAO_InputCDR &cdr
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::Exception));
/// Helper method used to handle location forwarded replies.
Invocation_Status location_forward (TAO_InputCDR &cdr
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Helper method used to handle system exceptions from the remote
/// objects.
Invocation_Status handle_system_exception (TAO_InputCDR &cdr
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
/// As the name suggests waits for a reply from the remote ORB.
/**
* This method returns an exception when there is an error.
*/
Invocation_Status wait_for_reply (ACE_Time_Value *max_wait_time,
TAO_Synch_Reply_Dispatcher &rd,
TAO_Bind_Dispatcher_Guard &bd
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
private:
/// Helper method that checks the reply status of the
/// replies and takes appropriate action.
/**
* This method returns an exception when there is an error.
*/
Invocation_Status check_reply_status (
TAO_Synch_Reply_Dispatcher &rd
ACE_ENV_ARG_DECL);
};
/**
* @class Synch_Oneway_Invocation
*
* @brief All the action for a synchronous oneway invocation happen
* here.
*
* This class inherits from twoway invocation for the following
* reasons
*
* - We deal with oneway invocation in more or less the same way as
* two but for waiting for the reply
*
* - For some SYNC_SCOPE policies namely SYNC_WITH_TARGET and
* SYNC_WITH_SERVER the invocation classes have to treat the
* invocation as a twoway invocation (more or less)
*
*/
class TAO_Export Synch_Oneway_Invocation
: public Synch_Twoway_Invocation
{
public:
/// Constructor used by TAO::Invocation_Adapter
/**
* @param otarget The original target on which this invocation
* was started. This is there to be passed up to its parent
* class.
*
* @param resolver The profile and transport holder.
*
* @param detail Operation details of the invocation on the target
*/
Synch_Oneway_Invocation (CORBA::Object_ptr otarget,
Profile_Transport_Resolver &resolver,
TAO_Operation_Details &detail);
/// Method used by the adapter to kickstart an oneway invocation
/// to the remote object.
Invocation_Status remote_oneway (ACE_Time_Value *max_wait_time
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::Exception));
};
/**
* @class Reply_Guard
*
* @brief A guard class used for storing and forwarding the reply
* status to the portable interceptors.
*/
class TAO_Export Reply_Guard
{
public:
Reply_Guard (Invocation_Base *s,
Invocation_Status is);
/// The destructor calls Invocation_Base::reply_received with the
/// right reply status, which is useful for PI's.
~Reply_Guard (void);
/// Mutator to set the invocation status.
void set_status (Invocation_Status s);
private:
Invocation_Base *invocation_;
Invocation_Status status_;
};
}
#if defined (__ACE_INLINE__)
# include "tao/Synch_Invocation.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /*TAO_SYNCH_INVOCATION_H*/
|
