TAO/tests/Portable_Interceptors/Dynamic/server_interceptor.cpp

   1 #include "tao/AnyTypeCode/TypeCode.h"
   2 #include "tao/AnyTypeCode/AnyTypeCode_Adapter_Impl.h"
   3 #include "tao/AnyTypeCode/DynamicC.h"
   4
   5 #include "server_interceptor.h"
   6 #include "testC.h"
   7
   8 #include "ace/Log_Msg.h"
   9 #include <cstring>
  10
  11 Echo_Server_Request_Interceptor::Echo_Server_Request_Interceptor (int& result)
  12   : result_ (result)
  13 {
  14 }
  15
  16 char *
  17 Echo_Server_Request_Interceptor::name ()
  18 {
  19   return CORBA::string_dup ("Echo_Server_Interceptor");
  20 }
  21
  22 void
  23 Echo_Server_Request_Interceptor::destroy ()
  24 {
  25 }
  26
  27 void
  28 Echo_Server_Request_Interceptor::receive_request_service_contexts (
  29     PortableInterceptor::ServerRequestInfo_ptr ri)
  30 {
  31   bool catched_exception = false;
  32   try
  33     {
  34       CORBA::String_var tmdi = ri->target_most_derived_interface ();
  35     }
  36   catch (const ::CORBA::BAD_INV_ORDER& ex)
  37     {
  38       // BAD_INV_ORDER should be thrown with minor code 14
  39       catched_exception = (ex.minor () == (CORBA::OMGVMCID | 14));
  40     }
  41
  42   if (!catched_exception)
  43     {
  44       ++this->result_;
  45       ACE_ERROR ((LM_ERROR,
  46                   "(%P|%t) ERROR, no exception when calling target_most_derived_interface from receive_request_service_contexts\n"));
  47     }
  48
  49   catched_exception = false;
  50   try
  51     {
  52       CORBA::Boolean const tmdi = ri->target_is_a ("FOO");
  53       ACE_UNUSED_ARG(tmdi);
  54     }
  55   catch (const ::CORBA::BAD_INV_ORDER& ex)
  56     {
  57       // BAD_INV_ORDER should be thrown with minor code 14
  58       catched_exception = (ex.minor () == (CORBA::OMGVMCID | 14));
  59     }
  60
  61   if (!catched_exception)
  62     {
  63       ++this->result_;
  64       ACE_ERROR ((LM_ERROR,
  65                   "(%P|%t) ERROR, no exception when calling target_is_a from receive_request_service_contexts\n"));
  66     }
  67
  68   catched_exception = false;
  69   try
  70     {
  71       PortableInterceptor::ReplyStatus const tmdi = ri->reply_status ();
  72       ACE_UNUSED_ARG(tmdi);
  73     }
  74   catch (const ::CORBA::BAD_INV_ORDER& ex)
  75     {
  76       // BAD_INV_ORDER should be thrown with minor code 14
  77       catched_exception = (ex.minor () == (CORBA::OMGVMCID | 14));
  78     }
  79
  80   if (!catched_exception)
  81     {
  82       ++this->result_;
  83       ACE_ERROR ((LM_ERROR,
  84                   "(%P|%t) ERROR, no exception when calling reply_status from receive_request_service_contexts\n"));
  85     }
  86
  87   catched_exception = false;
  88   try
  89     {
  90       Dynamic::ParameterList_var paramlist = ri->arguments ();
  91     }
  92   catch (const ::CORBA::BAD_INV_ORDER& ex)
  93     {
  94       // BAD_INV_ORDER should be thrown with minor code 14
  95       catched_exception = (ex.minor () == (CORBA::OMGVMCID | 14));
  96     }
  97
  98   if (!catched_exception)
  99     {
 100       ++this->result_;
 101       ACE_ERROR ((LM_ERROR,
 102                   "(%P|%t) ERROR, no exception when calling arguments from receive_request_service_contexts\n"));
 103     }
 104 }
 105
 106 void
 107 Echo_Server_Request_Interceptor::receive_request (
 108   PortableInterceptor::ServerRequestInfo_ptr ri)
 109 {
 110   bool catched_exception = false;
 111   try
 112     {
 113       PortableInterceptor::ReplyStatus rstatus = ri->reply_status ();
 114       ACE_UNUSED_ARG (rstatus);
 115     }
 116   catch (const ::CORBA::BAD_INV_ORDER& ex)
 117     {
 118       // BAD_INV_ORDER should be thrown with minor code 14
 119       catched_exception = (ex.minor () == (CORBA::OMGVMCID | 14));
 120     }
 121
 122   if (!catched_exception)
 123     {
 124       ++this->result_;
 125       ACE_ERROR ((LM_ERROR,
 126                   "(%P|%t) ERROR, no exception when getting reply status\n"));
 127     }
 128
 129   CORBA::String_var op = ri->operation ();
 130
 131   ACE_DEBUG ((LM_DEBUG,
 132               "Echo_Server_Request_Interceptor::receive_request from \"%C\"\n",
 133               op.in ()));
 134
 135   CORBA::Boolean targetisa = ri->target_is_a ("FOO");
 136   if (targetisa)
 137     {
 138       ++this->result_;
 139       ACE_ERROR ((LM_ERROR,
 140                   "(%P|%t) ERROR in receive_request while checking "
 141                   "target_is_a, it is not a FOO\n"));
 142     }
 143   targetisa = ri->target_is_a ("IDL:Test_Interceptors/Visual:1.0");
 144   if (!targetisa)
 145     {
 146       ++this->result_;
 147       ACE_ERROR ((LM_ERROR,
 148                   "(%P|%t) ERROR in receive_request while checking "
 149                   "target_is_a, it should be IDL:Test_Interceptors/Visual:1.0\n"));
 150     }
 151
 152   if (std::strcmp (op.in (), "normal") == 0)
 153     {
 154       Dynamic::ParameterList_var paramlist = ri->arguments ();
 155
 156       CORBA::Long param;
 157       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 158                            // overloaded operator ambiguity.
 159       paramlist[i].argument >>= param;
 160
 161       ACE_DEBUG ((LM_DEBUG,
 162                   "The arg is %d\n",
 163                   param));
 164
 165       i = 1;
 166       CORBA::TypeCode_var second_typecode = paramlist[i].argument.type ();
 167       if (second_typecode->kind () != CORBA::tk_null)
 168         {
 169           ++this->result_;
 170           ACE_ERROR ((LM_ERROR,
 171                       "(%P|%t) ERROR in receive_request while checking "
 172                       "the type of the extracted out"
 173                       "argument\n"));
 174         }
 175      }
 176
 177   CORBA::String_var tmdi = ri->target_most_derived_interface ();
 178
 179   ACE_DEBUG ((LM_DEBUG,
 180               "Target most derived interface: %C\n",
 181               tmdi.in ()));
 182
 183   if (std::strcmp (tmdi.in (), "IDL:Test_Interceptors/Visual:1.0") != 0)
 184     {
 185       ++this->result_;
 186       ACE_ERROR ((LM_ERROR,
 187                   "(%P|%t) ERROR in receive_request while checking "
 188                   "target_most_derived_interface\n"));
 189     }
 190
 191   catched_exception = false;
 192   try
 193     {
 194       PortableInterceptor::ReplyStatus const tmdi = ri->reply_status ();
 195       ACE_UNUSED_ARG(tmdi);
 196     }
 197   catch (const ::CORBA::BAD_INV_ORDER& ex)
 198     {
 199       // BAD_INV_ORDER should be thrown with minor code 14
 200       catched_exception = (ex.minor () == (CORBA::OMGVMCID | 14));
 201     }
 202
 203   if (!catched_exception)
 204     {
 205       ++this->result_;
 206       ACE_ERROR ((LM_ERROR,
 207                   "(%P|%t) ERROR, no exception when calling reply_status from receive_request\n"));
 208     }
 209 }
 210
 211 void
 212 Echo_Server_Request_Interceptor::send_reply (PortableInterceptor::ServerRequestInfo_ptr ri)
 213 {
 214   CORBA::String_var op = ri->operation ();
 215
 216   ACE_DEBUG ((LM_DEBUG,
 217               "Echo_Server_Request_Interceptor::send_reply from \"%C\"\n",
 218               op.in ()));
 219
 220   if (std::strcmp (op.in (), "normal") == 0)
 221     {
 222       Dynamic::ParameterList_var paramlist = ri->arguments ();
 223
 224       CORBA::Long param;
 225       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 226                            // overloaded operator ambiguity.
 227       paramlist[i].argument >>= param;
 228       ACE_DEBUG ((LM_DEBUG,
 229                   "The arg is %d\n",
 230                   param));
 231     }
 232
 233   if (std::strcmp (op.in (), "calculate") == 0)
 234     {
 235       Dynamic::ParameterList_var paramlist = ri->arguments ();
 236
 237       CORBA::Long param1, param2, result = 0;
 238       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 239                            // overloaded operator ambiguity.
 240       paramlist[i++].argument >>= param1;
 241       paramlist[i].argument >>= param2;
 242
 243       CORBA::Any_var result_any = ri->result ();
 244
 245       (result_any.in ()) >>= result;
 246
 247       ACE_DEBUG ((LM_DEBUG,
 248                   "The result of calculate is %d + %d = %d\n",
 249                   param1,
 250                   param2,
 251                   result));
 252     }
 253 }
 254
 255 void
 256 Echo_Server_Request_Interceptor::send_exception (
 257     PortableInterceptor::ServerRequestInfo_ptr ri)
 258 {
 259   CORBA::String_var op = ri->operation ();
 260
 261   ACE_DEBUG ((LM_DEBUG,
 262               "Echo_Server_Request_Interceptor::send_exception "
 263               "from \"%C\"\n",
 264               op.in ()));
 265
 266   CORBA::Any_var any = ri->sending_exception ();
 267
 268   CORBA::TypeCode_var type = any->type ();
 269
 270   CORBA::String_var exception_id = type->id ();
 271
 272   ACE_DEBUG ((LM_DEBUG,
 273               "Exception ID = %C\n",
 274               exception_id.in ()));
 275 }
 276
 277 void
 278 Echo_Server_Request_Interceptor::send_other (
 279     PortableInterceptor::ServerRequestInfo_ptr)
 280 {
 281   // Do Nothing
 282 }