blob: de01f6487f1ed8a54dfbd7e3e640f1fb1e3e4f0c (
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
|
// -*- C++ -*-
//=============================================================================
/**
* @file ClientRequestInterceptor_Adapter_Impl.h
*
* This file an adapter class to simplify the support of
* interceptors.
*
* @author Nanbor Wang <nanbor@cs.wustl.edu>
* @author Ossama Othman <ossama@uci.edu>
* @author Kirthika Parameswaran <kirthika@cs.wustl.edu>
* @author Johnny Willemsen <jwillemsen@remedy.nl>
*/
//=============================================================================
#ifndef TAO_CLIENT_REQUEST_INTERCEPTOR_ADAPTER_IMPL_H
#define TAO_CLIENT_REQUEST_INTERCEPTOR_ADAPTER_IMPL_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/Interceptor_List_T.h"
#include "tao/PI/PI_includeC.h"
#include "tao/PI/ClientRequestDetails.h"
#include "tao/PI/RequestInterceptor_Adapter_Impl.h"
#include "tao/ClientRequestInterceptor_Adapter.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
namespace TAO
{
typedef Interceptor_List< ::PortableInterceptor::ClientRequestInterceptor,
ClientRequestDetails>
ClientRequestInterceptor_List;
}
class TAO_ClientRequestInfo;
namespace TAO
{
class Invocation_Base;
/**
* @class ClientRequestInterceptor_Adapter
*
* @brief A convenient helper class to invoke registered client request
* interceptors
*
* This class invokes all registered interceptors at interception
* point, and enforces flow rules dictated by the Portable Interceptor
* specification/chapter.
*/
class ClientRequestInterceptor_Adapter_Impl
: public ClientRequestInterceptor_Adapter
, public TAO_RequestInterceptor_Adapter_Impl
{
public:
ClientRequestInterceptor_Adapter_Impl (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.
*
*/
//@{
/// This method implements one of the "starting" client side
/// interception points.
virtual void send_request (Invocation_Base &invocation);
/// This method implements one of the "ending" client side
/// interception point.
virtual void receive_reply (Invocation_Base &invocation);
/// This method implements one of the "ending" client side
/// interception point.
virtual void receive_exception (Invocation_Base &invocation);
/// This method implements one of the "ending" client side
/// interception point.
virtual void receive_other (Invocation_Base &invocation);
//@}
/// Register an interceptor.
virtual void add_interceptor (
PortableInterceptor::ClientRequestInterceptor_ptr interceptor);
/// Register an interceptor with policies.
virtual void add_interceptor (
PortableInterceptor::ClientRequestInterceptor_ptr interceptor,
const CORBA::PolicyList& policies);
virtual void destroy_interceptors (void);
virtual PortableInterceptor::ReplyStatus pi_reply_status (
TAO::Invocation_Base const &invocation_base);
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);}
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 (Invocation_Base &invocation,
const PortableInterceptor::ForwardRequest &exc);
private:
/// List of registered interceptors.
ClientRequestInterceptor_List interceptor_list_;
};
}
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "tao/PI/ClientRequestInterceptor_Adapter_Impl.inl"
#endif /* __ACE_INLINE__ */
#endif /* TAO_HAS_INTERCEPTORS == 1 */
#include /**/ "ace/post.h"
#endif /* TAO_CLIENT_REQUEST_INTERCEPTOR_ADAPTER_IMPL_H */
|
