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 CSD_FW_Server_Request_Wrapper.h
*
* $Id$
*
* @author Tim Bradley <bradley_t@ociweb.com>
*/
//=============================================================================
#ifndef TAO_CSD_FW_SERVER_REQUEST_WRAPPER_H
#define TAO_CSD_FW_SERVER_REQUEST_WRAPPER_H
#include /**/ "ace/pre.h"
#include "tao/CSD_Framework/CSD_FW_Export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/TAO_Server_Request.h"
#include "tao/operation_details.h"
#include "tao/PortableServer/Servant_Base.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
namespace TAO
{
namespace CSD
{
/**
* @class FW_Server_Request_Wrapper
*
* @brief Wrapper around a TAO_Server_Request that will be cloned
* at the proper time.
*
* This CSD Framework class is used to provide an interface to a
* TAO_ServerRequest object such that it can be used for CSD strategies
* that need to clone TAO_Server_Requests (ie, so that they may be
* placed on a queue to be dispatched by another thread).
*
* There are several purposes for this class, with the main thing being
* that the TAO_ServerRequest object is not used directly by the
* CSD Strategies since it is, after all, an internal TAO class that was
* never meant to be exposed. Future changes to TAO's internal design
* may cause disruption in the TAO_ServerRequest class. These changes
* would only need to be accounted for here in this
* FW_Server_Request_Wrapper class' implementation, and all CSD
* Strategies will work again. It's a maintenance issue.
*
* @note: The CSD namespace is inside of TAO namespace in current
* implementation. This can be changed but, at least for now, it's
* already been delivered to some customs, we leave it as-is. If it
* needs to change, we will make this change.
*/
class TAO_CSD_FW_Export FW_Server_Request_Wrapper
{
public:
/// Constructor.
FW_Server_Request_Wrapper(TAO_ServerRequest& server_request);
/// Destructor.
~FW_Server_Request_Wrapper();
/// Perform the clone operation.
void clone();
/// Dispatch the request to the servant.
void dispatch(PortableServer::Servant servant ACE_ENV_ARG_DECL);
/// Cancel the request.
void cancel();
private:
/// Create a deep copy of the request_ object.
/// The other clone methods are used to support the TAO_ServerRequest clone.
TAO_ServerRequest* clone (TAO_ServerRequest*& from);
/// Clone an input cdr stream.
TAO_InputCDR* clone (TAO_InputCDR*& from);
/// Create a deep copy of a TAO_Operation_Details object and marshall
/// the arguments into a TAO_InputCDR stream. The cloned TAO_Operation_Details
/// object is created without any arguments. This would help the skeleton
/// code to determine whether the arguments are in the operation_details_
/// object or should be demarshalled from the incoming_ stream in the request_
/// object.
bool clone (TAO_Operation_Details const *& from,
TAO_Operation_Details const *& to,
TAO_InputCDR* & cdr);
/// Clone the TAO_Tagged_Profile object.
void clone (TAO_Tagged_Profile& from, TAO_Tagged_Profile& to);
/// Clone the TAO_Service_Context object.
void clone (TAO_Service_Context& from, TAO_Service_Context& to);
/// Create a new TAO_ServerRequest with default initial values.
TAO_ServerRequest* create_new_request ();
/// Create a TAO_OutputCDR stream initialized with a heap allocated
/// buffer.
TAO_OutputCDR* create_new_output_cdr ();
/// A flag that indicates that the TAO_ServerRequest object
/// is already cloned.
bool is_clone_;
/// Pointer to the underlying TAO_ServerRequest object.
TAO_ServerRequest* request_;
};
}
}
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
# include "tao/CSD_Framework/CSD_FW_Server_Request_Wrapper.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_CSD_FW_SERVER_REQUEST_WRAPPER_H */
|
