TAO/tao/DynamicInterface/DII_Arguments_Converter_Impl.cpp

   1 #include "tao/DynamicInterface/DII_Arguments_Converter_Impl.h"
   2 #include "tao/DynamicInterface/DII_Arguments.h"
   3 #include "tao/AnyTypeCode/NVList.h"
   4 #include "tao/AnyTypeCode/Any_Impl.h"
   5 #include "tao/operation_details.h"
   6 #include "tao/SystemException.h"
   7 #include "tao/CDR.h"
   8
   9 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  10
  11 void
  12 TAO_DII_Arguments_Converter_Impl::convert_request (
  13     TAO_ServerRequest & server_request,
  14     TAO::Argument * const args[],
  15     size_t nargs)
  16 {
  17   // The DII requests on client side always have two arguments
  18   // - one is the return argument and the other is NVList_Argument.
  19   // Since the argument list in the client side is used by server side
  20   // in collocation case and the server expects the list of arguments
  21   // and not the NVList_Argument, we need expand the NVList_Argument
  22   // to be list of Arguments.
  23
  24   // Before expanding NVList_Argument logic was added, the
  25   // $TAO_ROOT/tests/DII_Collocated_Tests/run_test.pl should fail.
  26   // The servant will get incorrect "IN" parameter from the oneway
  27   // operation with single "IN" parameter and get access violation on
  28   // get_in_arg () from the oneway operation with multiple "IN"
  29   // parameters.
  30   CORBA::NVList_ptr lst
  31     = static_cast<TAO::NVList_Argument *> (
  32         server_request.operation_details ()->args()[1])->arg ();
  33
  34   CORBA::ULong const sz = lst->count ();
  35
  36   if (sz != nargs - 1)
  37     {
  38       throw ::CORBA::BAD_PARAM ();
  39     }
  40
  41   // To avoid the use of extraction operators on CORBA::Any, we will
  42   // marshal the arguments in the NVList into an output cdr and then
  43   // demarshal them into the TAO::Argument array.
  44   TAO_OutputCDR output;
  45   for (CORBA::ULong i = 0; i < sz; ++i)
  46     {
  47       CORBA::NamedValue_ptr theitem = lst->item (i);
  48
  49       if (!(theitem->value ()->impl ()->marshal_value (output)))
  50         {
  51           throw ::CORBA::BAD_PARAM ();
  52         }
  53     }
  54
  55   TAO_InputCDR input (output);
  56   for (CORBA::ULong j = 0; j < sz; ++j)
  57     {
  58       if (!(args[j + 1]->demarshal (input)))
  59         {
  60           throw ::CORBA::BAD_PARAM ();
  61         }
  62     }
  63
  64   TAO_Operation_Details* details
  65     = const_cast <TAO_Operation_Details*> (server_request.operation_details ());
  66
  67   // The NVList_Argument in operation details is converted to skel
  68   // args, the invocation of the dii collocation requests should use
  69   // the skel args and not use the stub args.
  70   details->use_stub_args (false);
  71 }
  72
  73 void
  74 TAO_DII_Arguments_Converter_Impl::dsi_convert_request (
  75     TAO_ServerRequest & server_request,
  76     TAO_OutputCDR & output)
  77 {
  78   // The DII requests on client side always have two arguments
  79   // - one is the return argument and the other is NVList_Argument.
  80   CORBA::NVList_ptr lst
  81     = static_cast<TAO::NVList_Argument *> (
  82         server_request.operation_details ()->args()[1])->arg ();
  83
  84   // Only marshal the in(out) arguments since we use this to demarshal
  85   // these values in the serverside argument list.
  86   lst->_tao_encode (output, CORBA::ARG_IN | CORBA::ARG_INOUT);
  87 }
  88
  89 void
  90 TAO_DII_Arguments_Converter_Impl::convert_reply (
  91     TAO_ServerRequest & server_request,
  92     TAO::Argument * const args[],
  93     size_t nargs)
  94 {
  95   TAO_OutputCDR output;
  96   errno = 0;
  97   for (CORBA::ULong j = 0; j < nargs; ++j)
  98     {
  99       if (!(args[j]->marshal (output)))
 100         {
 101           TAO_OutputCDR::throw_skel_exception (errno);
 102         }
 103     }
 104   TAO_InputCDR input (output);
 105   this->dsi_convert_reply (server_request, input);
 106 }
 107
 108 void
 109 TAO_DII_Arguments_Converter_Impl::dsi_convert_reply (
 110     TAO_ServerRequest & server_request,
 111     TAO_InputCDR & input)
 112 {
 113   TAO::NamedValue_Argument * _ret_val
 114     = static_cast<TAO::NamedValue_Argument *> (
 115         server_request.operation_details ()->args()[0]);
 116
 117   _ret_val->demarshal (input);
 118
 119   CORBA::NVList_ptr lst
 120     = static_cast<TAO::NVList_Argument *> (
 121         server_request.operation_details ()->args()[1])->arg ();
 122
 123   lst->_tao_decode (input,
 124                     CORBA::ARG_INOUT | CORBA::ARG_OUT);
 125 }
 126
 127 void
 128 TAO_DII_Arguments_Converter_Impl::handle_corba_exception (
 129   TAO_ServerRequest & /*server_request*/,
 130   CORBA::Exception *exception)
 131 {
 132   exception->_raise ();
 133 }
 134
 135 // *********************************************************************
 136
 137 // Initialization and registration of dynamic service object.
 138
 139 int
 140 TAO_DII_Arguments_Converter_Impl::Initializer ()
 141 {
 142   return ACE_Service_Config::process_directive (
 143     ace_svc_desc_TAO_DII_Arguments_Converter_Impl);
 144 }
 145
 146
 147 TAO_END_VERSIONED_NAMESPACE_DECL
 148
 149 ACE_STATIC_SVC_DEFINE (
 150   TAO_DII_Arguments_Converter_Impl,
 151   ACE_TEXT ("DII_Arguments_Converter"),
 152   ACE_SVC_OBJ_T,
 153   &ACE_SVC_NAME (TAO_DII_Arguments_Converter_Impl),
 154   ACE_Service_Type::DELETE_THIS | ACE_Service_Type::DELETE_OBJ,
 155   0
 156   )
 157
 158 ACE_FACTORY_DEFINE (TAO_DynamicInterface, TAO_DII_Arguments_Converter_Impl)
 159