blob: 9b40b9bcb2500c9f28d67059d828b9528c2a21f3 (
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
|
// -*- C++ -*-
//=============================================================================
/**
* @file ClientInterceptorAdapter.h
*
* $Id$
*
* This file an adapter class to simplify the support of
* interceptors in tao_idl generated stubs.
*
* @author Nanbor Wang <nanbor@cs.wustl.edu>
* @author Ossama Othman <ossama@uci.edu>
* @author Kirthika Parameswaran <kirthika@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_CLIENT_INTERCEPTOR_ADAPTER_H
#define TAO_CLIENT_INTERCEPTOR_ADAPTER_H
#include "ace/pre.h"
#include "orbconf.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if TAO_HAS_INTERCEPTORS == 1
#include "Interceptor_List.h"
// Forward declarations
class TAO_GIOP_Invocation;
class TAO_ClientRequestInfo;
class TAO_ClientRequestInfo_i;
/**
* @class TAO_ClientRequestInterceptor_Adapter
*
* @brief A convenient helper class to invoke registered client request
* interceptors in client stubs.
*
* This class invokes all registered interceptors at interception
* point, and enforces flow rules dictated by the Portable Interceptor
* specification/chapter.
*/
class TAO_Export TAO_ClientRequestInterceptor_Adapter
{
public:
TAO_ClientRequestInterceptor_Adapter (
TAO_ClientRequestInterceptor_List::TYPE & interceptors,
TAO_GIOP_Invocation * invocation,
int & _invoke_status);
~TAO_ClientRequestInterceptor_Adapter (void);
/**
* @name PortableInterceptor Client Side Interception Points
*
* Each of these methods corresponds to a client side interception
* point. There are no "intermediate" interception points on the
* client side, only "starting" and "ending" interception points.
*
* @todo
* The "send_poll()" and "receive_other()" (for AMI)
* PortableInterceptor interception points are missing.
*/
//@{
/// This method implements one of the "starting" client side
/// interception points.
void send_request (TAO_ClientRequestInfo_i * ri
ACE_ENV_ARG_DECL);
/// This method implements one of the "ending" client side
/// interception point.
void receive_reply (TAO_ClientRequestInfo_i * ri
ACE_ENV_ARG_DECL);
/// This method implements one of the "ending" client side
/// interception point.
void receive_exception (TAO_ClientRequestInfo_i * ri
ACE_ENV_ARG_DECL);
/// This method implements one of the "ending" client side
/// interception point.
void receive_other (TAO_ClientRequestInfo_i * ri
ACE_ENV_ARG_DECL);
//@}
protected:
/// Process the given PortableInterceptor::ForwardRequest exception,
/// i.e. invoke the receive_other() interception point, in addition
/// to notifying the Invocation object of the LOCATION_FORWARD.
void process_forward_request (TAO_ClientRequestInfo_i * ri,
PortableInterceptor::ForwardRequest & exc
ACE_ENV_ARG_DECL);
private:
/// Reference to the list of registered interceptors.
TAO_ClientRequestInterceptor_List::TYPE & interceptors_;
/// Pointer to the GIOP invocation object for the current request.
TAO_GIOP_Invocation * invocation_;
/// Reference to the invocation status obtained from and returned to
/// the stub. Needed to support the
/// PortableInterceptor::ForwardRequest exception.
int & invoke_status_;
/// Cache the length of the interceptor list so that we don't have
/// to compute it at each stage of the current interception.
const size_t len_;
/// The number of interceptors "pushed" onto the logical flow
/// stack. This is used when unwinding the flow stack.
size_t stack_size_;
/// Pointer to the PortableInterceptor::ClientRequestInfo
/// implementation.
/**
* @note The fact that a pointer to the
* PortableInterceptor::ClientRequestInfo object in TSS is
* cached here assumes that all client side interception
* points are invoked in the same thread. This may not be the
* case for AMI! In that case, we'll have to perform a TSS
* access in each interception point.
*/
TAO_ClientRequestInfo * info_;
};
#if defined (__ACE_INLINE__)
#include "ClientInterceptorAdapter.inl"
#endif /* __ACE_INLINE__ */
#endif /* TAO_HAS_INTERCEPTORS */
#include "ace/post.h"
#endif /* TAO_CLIENT_INTERCEPTOR_ADAPTER_H */
|
