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
|
// -*- C++ -*-
//=============================================================================
/**
* @file ServerInterceptorAdapter.h
*
* This file contains a helper class to simplify the support of
* interceptors in TAO_IDL generated skeletons.
*
* @author Nanbor Wang <nanbor@cs.wustl.edu>
* @author Ossama Othman <ossama@uci.edu>
* @author Kirthika Parameswaran <kirthika@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_SERVER_INTERCEPTOR_ADAPTER_H
#define TAO_SERVER_INTERCEPTOR_ADAPTER_H
#include /**/ "ace/pre.h"
#include "tao/orbconf.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if TAO_HAS_INTERCEPTORS == 1
#include "tao/PI_Server/PI_Server_includeC.h"
#include "tao/PI/Interceptor_List_T.h"
#include "tao/ServerRequestInterceptor_Adapter.h"
#include "tao/PI/RequestInterceptor_Adapter_Impl.h"
#include "tao/Basic_Types.h"
#include "tao/PI_Server/ServerRequestDetails.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
namespace TAO
{
typedef Interceptor_List< ::PortableInterceptor::ServerRequestInterceptor,
ServerRequestDetails>
ServerRequestInterceptor_List;
}
namespace CORBA
{
class PolicyList;
}
class TAO_ServerRequest;
namespace TAO
{
class ServerRequestInfo;
/**
* @class ServerRequestInterceptor_Adapter_Impl
*
* @brief ServerRequestInterceptor_Adapter_Impl
*
* A convenient helper class to invoke registered server request
* interceptor(s).
*/
class ServerRequestInterceptor_Adapter_Impl
: public ServerRequestInterceptor_Adapter
, public TAO_RequestInterceptor_Adapter_Impl
{
public:
/// Constructor.
ServerRequestInterceptor_Adapter_Impl ();
/**
* @name PortableInterceptor Server Side Interception Points
*
* Each of these methods corresponds to a server side interception
* point.
*/
//@{
#if TAO_HAS_EXTENDED_FT_INTERCEPTORS == 1
/// This method implements the "starting" server side interception
/// point. It will be used as the first interception point and it is
/// proprietary to TAO.
void tao_ft_interception_point (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
TAO::Portable_Server::Servant_Upcall *servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions,
CORBA::OctetSeq_out oc);
#endif /*TAO_HAS_EXTENDED_FT_INTERCEPTORS*/
/// This method implements the "intermediate" server side
/// interception point if the above #ifdef is set to 1 and a
/// starting interception point if it is not set to 1.
///
/// @note This method should have been the "starting" interception
/// point according to the interceptor spec. This will be
/// fixed once Bug 1369 is completely done.
void receive_request_service_contexts (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
TAO::Portable_Server::Servant_Upcall *servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions);
/// This method an "intermediate" server side interception point.
void receive_request (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
TAO::Portable_Server::Servant_Upcall *servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions);
/// This method implements one of the "ending" server side
/// interception points.
void send_reply (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
TAO::Portable_Server::Servant_Upcall *servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions);
/// This method implements one of the "ending" server side
/// interception points.
void send_exception (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
TAO::Portable_Server::Servant_Upcall *servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions);
/// This method implements one of the "ending" server side
/// interception points.
void send_other (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
TAO::Portable_Server::Servant_Upcall *servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions);
//@}
/// Register an interceptor.
virtual void add_interceptor (
PortableInterceptor::ServerRequestInterceptor_ptr interceptor);
virtual void add_interceptor (
PortableInterceptor::ServerRequestInterceptor_ptr interceptor,
const CORBA::PolicyList& policies);
virtual void destroy_interceptors ();
virtual TAO::PICurrent_Impl *allocate_pi_current ();
virtual void deallocate_pi_current (TAO::PICurrent_Impl *picurrent);
virtual void execute_command (
TAO_ServerRequest &server_request,
TAO::Upcall_Command &command);
void popTSC (TAO_ORB_Core *orb_core)
{TAO_RequestInterceptor_Adapter_Impl::popTSC (orb_core);}
void pushTSC (TAO_ORB_Core *orb_core)
{TAO_RequestInterceptor_Adapter_Impl::pushTSC (orb_core);}
private:
/// List of registered interceptors.
ServerRequestInterceptor_List interceptor_list_;
};
} // End namespace TAO
TAO_END_VERSIONED_NAMESPACE_DECL
#endif /* TAO_HAS_INTERCEPTORS */
#include /**/ "ace/post.h"
#endif /* TAO_SERVER_INTERCEPTOR_ADAPTER_H */
|
