blob: 2ec52a987aae10eafccb6c35ad4962568e976455 (
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
|
// -*- C++ -*-
//=============================================================================
/**
* @file ClientRequestInterceptor_Adapter_Impl.h
*
* $Id$
*
* 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 "Interceptor_List_T.h"
#include "ClientRequestInterceptorC.h"
#include "tao/ClientRequestInterceptor_Adapter.h"
namespace TAO
{
typedef Interceptor_List< ::PortableInterceptor::ClientRequestInterceptor>
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:
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
ACE_ENV_ARG_DECL);
/// This method implements one of the "ending" client side
/// interception point.
virtual void receive_reply (Invocation_Base &invocation
ACE_ENV_ARG_DECL);
/// This method implements one of the "ending" client side
/// interception point.
virtual void receive_exception (Invocation_Base &invocation
ACE_ENV_ARG_DECL);
/// This method implements one of the "ending" client side
/// interception point.
virtual void receive_other (Invocation_Base &invocation
ACE_ENV_ARG_DECL);
//@}
/// Register an interceptor.
virtual void add_interceptor (
PortableInterceptor::ClientRequestInterceptor_ptr interceptor
ACE_ENV_ARG_DECL);
virtual void destroy_interceptors (ACE_ENV_SINGLE_ARG_DECL);
virtual PortableInterceptor::ReplyStatus reply_status (
TAO::Invocation_Base const &invocation_base);
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,
PortableInterceptor::ForwardRequest &exc
ACE_ENV_ARG_DECL);
private:
/// List of registered interceptors.
ClientRequestInterceptor_List interceptor_list_;
};
}
#if defined (__ACE_INLINE__)
#include "ClientRequestInterceptor_Adapter_Impl.inl"
#endif /* __ACE_INLINE__ */
#endif /* TAO_HAS_INTERCEPTORS == 1 */
#include /**/ "ace/post.h"
#endif /* TAO_CLIENT_REQUEST_INTERCEPTOR_ADAPTER_IMPL_H */
|
