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
|
// -*- C++ -*-
//=============================================================================
/**
* @file ServerRequestInterceptor_Adapter.h
*
* $Id$
*
* This file an adapter class to simplify the support of
* interceptors.
*
* @author Johnny Willemsen <jwillemsen@remedy.nl>
*/
//=============================================================================
#ifndef TAO_SERVER_REQUEST_INTERCEPTOR_ADAPTER_H
#define TAO_SERVER_REQUEST_INTERCEPTOR_ADAPTER_H
#include /**/ "ace/pre.h"
#include "tao/TAO_Export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/CORBA_macros.h"
#include "tao/SystemException.h"
#if TAO_HAS_EXTENDED_FT_INTERCEPTORS == 1
# include "tao/OctetSeqC.h"
#endif /*TAO_HAS_EXTENDED_FT_INTERCEPTORS*/
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
namespace PortableInterceptor
{
class ServerRequestInterceptor;
typedef ServerRequestInterceptor *ServerRequestInterceptor_ptr;
typedef CORBA::Short ReplyStatus;
}
namespace CORBA
{
class PolicyList;
}
class TAO_ServerRequest;
namespace TAO
{
class ServerRequestInfo;
class Argument;
class PICurrent_Impl;
class PICurrent_Copy_Callback;
class Upcall_Command;
/**
* @class ServerRequestInterceptor_Adapter
*/
class TAO_Export ServerRequestInterceptor_Adapter
{
public:
virtual ~ServerRequestInterceptor_Adapter (void);
/**
* @name PortableInterceptor Server Side Interception Points
*
* Each of these methods corresponds to a client 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.
/// @@ Will go away once Bug 1369 is fixed
virtual void tao_ft_interception_point (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
void * servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions,
CORBA::OctetSeq_out oc
ACE_ENV_ARG_DECL) = 0;
#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 intercetion 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.
virtual void receive_request_service_contexts (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
void * servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions
ACE_ENV_ARG_DECL) = 0;
/// This method an "intermediate" server side interception point.
virtual void receive_request (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
void * servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions
ACE_ENV_ARG_DECL) = 0;
/// This method implements one of the "ending" server side
/// interception points.
virtual void send_reply (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
void * servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions
ACE_ENV_ARG_DECL) = 0;
/// This method implements one of the "ending" server side
/// interception points.
virtual void send_exception (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
void * servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions
ACE_ENV_ARG_DECL) = 0;
/// This method implements one of the "ending" server side
/// interception points.
virtual void send_other (
TAO_ServerRequest &server_request,
TAO::Argument * const args[],
size_t nargs,
void * servant_upcall,
CORBA::TypeCode_ptr const * exceptions,
CORBA::ULong nexceptions
ACE_ENV_ARG_DECL) = 0;
//@}
/// Register an interceptor.
virtual void add_interceptor (
PortableInterceptor::ServerRequestInterceptor_ptr interceptor
ACE_ENV_ARG_DECL) = 0;
/// Register an interceptor with policies.
virtual void add_interceptor (
PortableInterceptor::ServerRequestInterceptor_ptr interceptor,
const CORBA::PolicyList& policies
ACE_ENV_ARG_DECL) = 0;
virtual void destroy_interceptors (ACE_ENV_SINGLE_ARG_DECL) = 0;
virtual TAO::PICurrent_Impl *allocate_pi_current (void) = 0;
virtual TAO::PICurrent_Copy_Callback *
allocate_pi_current_callback (void) = 0;
virtual void deallocate_pi_current (
TAO::PICurrent_Impl *picurrent) = 0;
virtual void deallocate_pi_current_callback (
TAO::PICurrent_Copy_Callback *callback) = 0;
virtual void execute_command (
TAO_ServerRequest &server_request,
TAO::Upcall_Command &command
ACE_ENV_ARG_DECL) = 0;
};
}
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif /* TAO_SERVER_REQUEST_INTERCEPTOR_ADAPTER_H */
|
