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
|
// $Id$
#include "tao/DynamicInterface/DII_Arguments_Converter_Impl.h"
#include "tao/DynamicInterface/DII_Arguments.h"
#include "tao/AnyTypeCode/NVList.h"
#include "tao/AnyTypeCode/Any_Impl.h"
#include "tao/operation_details.h"
#include "tao/SystemException.h"
#include "tao/CDR.h"
ACE_RCSID (DynamicInterface,
DII_Arguments_Converter_Impl,
"$Id$")
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
void
TAO_DII_Arguments_Converter_Impl::convert_request (
TAO_ServerRequest & server_request,
TAO::Argument * const args[],
size_t nargs)
{
// The DII requests on client side always have two arguments
// - one is the return argument and the other is NVList_Argument.
// Since the argument list in the client side is used by server side
// in collocation case and the server expects the list of arguments
// and not the NVList_Argument, we need expand the NVList_Argument
// to be list of Arguments.
// Before expanding NVList_Argument logic was added, the
// $TAO_ROOT/tests/DII_Collocated_Tests/run_test.pl should fail.
// The servant will get incorrect "IN" parameter from the oneway
// operation with single "IN" parameter and get access violation on
// get_in_arg () from the oneway operation with multiple "IN"
// parameters.
CORBA::NVList_ptr lst
= static_cast<TAO::NVList_Argument *> (
server_request.operation_details ()->args()[1])->arg ();
CORBA::ULong const sz = lst->count ();
if (sz != nargs - 1)
{
throw ::CORBA::BAD_PARAM ();
}
// To avoid the use of extraction operators on CORBA::Any, we will
// marshal the arguments in the NVList into an output cdr and then
// demarshal them into the TAO::Argument array.
TAO_OutputCDR output;
for (CORBA::ULong i = 0; i < sz; ++i)
{
CORBA::NamedValue_ptr theitem = lst->item (i);
if (!(theitem->value ()->impl ()->marshal_value (output)))
{
throw ::CORBA::BAD_PARAM ();
}
}
TAO_InputCDR input (output);
for (CORBA::ULong j = 0; j < sz; ++j)
{
if (!(args[j + 1]->demarshal (input)))
{
throw ::CORBA::BAD_PARAM ();
}
}
TAO_Operation_Details* details
= const_cast <TAO_Operation_Details*> (server_request.operation_details ());
// The NVList_Argument in operation details is converted to skel
// args, the invocation of the dii collocation requests should use
// the skel args and not use the stub args.
details->use_stub_args (false);
}
void
TAO_DII_Arguments_Converter_Impl::convert_reply (
TAO_ServerRequest & /* server_request */,
TAO::Argument * const /*args*/[],
size_t /*nargs*/)
{
}
void
TAO_DII_Arguments_Converter_Impl::handle_corba_exception (
TAO_ServerRequest & /*server_request*/,
CORBA::Exception *exception)
{
exception->_raise ();
}
// *********************************************************************
// Initialization and registration of dynamic service object.
int
TAO_DII_Arguments_Converter_Impl::Initializer (void)
{
return ACE_Service_Config::process_directive (
ace_svc_desc_TAO_DII_Arguments_Converter_Impl);
}
TAO_END_VERSIONED_NAMESPACE_DECL
ACE_STATIC_SVC_DEFINE (
TAO_DII_Arguments_Converter_Impl,
ACE_TEXT ("DII_Arguments_Converter"),
ACE_SVC_OBJ_T,
&ACE_SVC_NAME (TAO_DII_Arguments_Converter_Impl),
ACE_Service_Type::DELETE_THIS | ACE_Service_Type::DELETE_OBJ,
0
)
ACE_FACTORY_DEFINE (TAO_DynamicInterface, TAO_DII_Arguments_Converter_Impl)
|
