blob: 5e888a0e4129b8ea3b2096bcee78afef056f429a (
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 Server_Request_Interceptor.h
*
* $Id$
*
* Implementation header for the server request interceptor for the
* PortableInterceptor::ForwardRequest test.
*
* @author Ossama Othman <ossama@uci.edu>
*/
//=============================================================================
#ifndef SERVER_REQUEST_INTERCEPTOR_H
#define SERVER_REQUEST_INTERCEPTOR_H
#include "ace/config-all.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/PortableInterceptorC.h"
#include "tao/LocalObject.h"
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
/**
* @class Server_Request_Interceptor
*
* @brief Simple concrete server request interceptor.
*
* This server request interceptor forwards an initial client request
* to the primary server since the client request interceptor should
* have attempted to forward a request to the secondary server. That
* request will then be forwarded back to the primary server, at which
* point the request will be handled.
*
* The PortableInterceptor::ForwardRequest code for the
* receive_request_service_contexts() interception point (which is not
* in the servant skeleton) is slightly different from the
* corresponding code in the server skeleton. Hence,
* PortableInterceptor::ForwardRequest support is tested for both
* cases by throwing that exception in the
* receive_request_service_contexts() and the receive_request()
* interception points.
*
* See the README file for test details.
*/
class Server_Request_Interceptor
: public virtual PortableInterceptor::ServerRequestInterceptor,
public virtual TAO_Local_RefCounted_Object
{
public:
/// Constructorl
Server_Request_Interceptor (void);
/// Destructor.
~Server_Request_Interceptor (void);
/// Set the references to which requests will be forwarded.
void forward_references (CORBA::Object_ptr obj1,
CORBA::Object_ptr obj2,
CORBA::Environment &ACE_TRY_ENV);
/**
* @name Methods Required by the Server Request Interceptor
* Interface
*
* These are methods that must be implemented since they are pure
* virtual in the abstract base class. They are the canonical
* methods required for all server request interceptors.
*/
//@{
/// Return the name of this ServerRequestinterceptor.
virtual char * name (TAO_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void receive_request_service_contexts (
PortableInterceptor::ServerRequestInfo_ptr ri
TAO_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void receive_request (
PortableInterceptor::ServerRequestInfo_ptr ri
TAO_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void send_reply (
PortableInterceptor::ServerRequestInfo_ptr ri
TAO_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void send_exception (
PortableInterceptor::ServerRequestInfo_ptr ri
TAO_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void send_other (
PortableInterceptor::ServerRequestInfo_ptr ri
TAO_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
//@}
private:
/// The number of requests intercepted by this interceptor.
CORBA::ULong request_count_;
/// References to the two objects used in this test.
CORBA::Object_ptr obj_[2];
};
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */
#endif /* SERVER_REQUEST_INTERCEPTOR_H */
|
