blob: 828438a8316cd4f7fd82188617e8b67468271001 (
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
|
// -*- 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 "corbafwd.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if TAO_HAS_INTERCEPTORS == 1
#include "ClientRequestInfo.h"
#include "Interceptor_List.h"
// Forward declarations
class TAO_ClientRequestInfo;
/**
* @class TAO_ClientRequestInterceptor_Adapter
*
* @brief TAO_ClientRequestInterceptor_Adapter
*
* A convenient helper class to invoke registered client request
* interceptor(s) in tao_idl generated code.
*/
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 *ri
TAO_ENV_ARG_DECL_NOT_USED);
/// This method implements one of the "ending" client side
/// interception point.
void receive_reply (TAO_ClientRequestInfo *ri
TAO_ENV_ARG_DECL_NOT_USED);
/// This method implements one of the "ending" client side
/// interception point.
void receive_exception (TAO_ClientRequestInfo *ri
TAO_ENV_ARG_DECL_NOT_USED);
/// This method implements one of the "ending" client side
/// interception point.
void receive_other (TAO_ClientRequestInfo *ri
TAO_ENV_ARG_DECL_NOT_USED);
//@}
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 *ri,
PortableInterceptor::ForwardRequest &exc
TAO_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.
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_;
};
#if defined (__ACE_INLINE__)
#include "ClientInterceptorAdapter.inl"
#endif /* __ACE_INLINE__ */
#endif /* TAO_HAS_INTERCEPTORS */
#include "ace/post.h"
#endif /* TAO_CLIENT_INTERCEPTOR_ADAPTER_H */
|
