TAO/tests/Portable_Interceptors/Collocated/Dynamic/interceptors.cpp

   1 #include "interceptors.h"
   2 #include "tao/AnyTypeCode/AnyTypeCode_Adapter_Impl.h"
   3 #include "tao/AnyTypeCode/DynamicC.h"
   4 #include "tao/AnyTypeCode/TypeCode.h"
   5 #include "ace/Log_Msg.h"
   6 #include "ace/OS_NS_string.h"
   7
   8 const char *request_msg = "The Echo_Request_Interceptor request message";
   9 const char *reply_msg = "The Echo_Request_Interceptor reply message";
  10 CORBA::ULong Echo_Client_Request_Interceptor::client_interceptor_check_ = 0;
  11 CORBA::ULong Echo_Server_Request_Interceptor::server_interceptor_check_ = 0;
  12
  13 Echo_Client_Request_Interceptor::Echo_Client_Request_Interceptor ()
  14   : myname_ ("Echo_Client_Interceptor")
  15 {
  16 }
  17
  18 Echo_Client_Request_Interceptor::~Echo_Client_Request_Interceptor ()
  19 {
  20 }
  21
  22 char *
  23 Echo_Client_Request_Interceptor::name ()
  24 {
  25   return CORBA::string_dup (this->myname_);
  26 }
  27
  28 void
  29 Echo_Client_Request_Interceptor::destroy ()
  30 {
  31 }
  32
  33 void
  34 Echo_Client_Request_Interceptor::send_poll (
  35     PortableInterceptor::ClientRequestInfo_ptr
  36     )
  37 {
  38   // Do nothing
  39 }
  40
  41 void
  42 Echo_Client_Request_Interceptor::send_request (
  43     PortableInterceptor::ClientRequestInfo_ptr ri)
  44 {
  45   client_interceptor_check_++;
  46
  47   CORBA::String_var op =
  48     ri->operation ();
  49
  50 #if 0
  51   ACE_DEBUG ((LM_DEBUG,
  52               "Echo_Client_Request_Interceptor::send_request\n"));
  53
  54   ACE_DEBUG ((LM_DEBUG,
  55               "Echo_Client_Request_Interceptor::send_request from "
  56               "\"%C\"\n",
  57               op.in ()));
  58
  59 #endif /*if 0*/
  60
  61   if (ACE_OS::strcmp (op.in (), "normal") == 0)
  62     {
  63       Dynamic::ParameterList_var paramlist =
  64         ri->arguments ();
  65
  66       CORBA::Long param;
  67       CORBA::ULong i = 0;  // index -- explicitly used to avoid
  68                            // overloaded operator ambiguity.
  69       paramlist[i].argument >>= param;
  70
  71 #if 0
  72       ACE_DEBUG ((LM_DEBUG,
  73                   "The arg is %d\n",
  74                   param));
  75 #endif /*if 0*/
  76     }
  77 }
  78
  79 void
  80 Echo_Client_Request_Interceptor::receive_other (
  81   PortableInterceptor::ClientRequestInfo_ptr ri)
  82 {
  83   client_interceptor_check_++;
  84
  85   CORBA::String_var op = ri->operation ();
  86
  87 #if 0
  88   ACE_DEBUG ((LM_DEBUG,
  89               "Echo_Client_Request_Interceptor::receive_other "
  90               "from \"%C\"\n",
  91               op.in ()));
  92 #endif /*if 0*/
  93 }
  94
  95 void
  96 Echo_Client_Request_Interceptor::receive_reply (
  97     PortableInterceptor::ClientRequestInfo_ptr ri)
  98 {
  99   client_interceptor_check_++;
 100
 101   CORBA::String_var op = ri->operation ();
 102
 103 #if 0
 104   ACE_DEBUG ((LM_DEBUG,
 105               "Echo_Client_Request_Interceptor::receive_reply "
 106               "from \"%C\"\n",
 107               op.in ()));
 108 #endif /*if 0*/
 109
 110   if (ACE_OS::strcmp (op.in (), "normal") == 0)
 111     {
 112       Dynamic::ParameterList_var paramlist =
 113         ri->arguments ();
 114
 115       CORBA::Long param;
 116       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 117                            // overloaded operator ambiguity.
 118       paramlist[i].argument >>= param;
 119     }
 120   else if (ACE_OS::strcmp (op.in (), "calculate") == 0)
 121     {
 122       Dynamic::ParameterList_var paramlist =
 123         ri->arguments ();
 124
 125       CORBA::Long param1, param2, result;
 126       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 127                            // overloaded operator ambiguity.
 128       paramlist[i++].argument >>= param1;
 129       paramlist[i].argument >>= param2;
 130
 131       CORBA::Any_var result_any = ri->result ();
 132
 133       (result_any.in ()) >>= result;
 134
 135 #if 0
 136       ACE_DEBUG ((LM_DEBUG,
 137                   "The result of calculate is %d + %d = %d\n",
 138                   param1,
 139                   param2,
 140                   result));
 141 #endif /*if 0*/
 142     }
 143 }
 144
 145 void
 146 Echo_Client_Request_Interceptor::receive_exception (
 147     PortableInterceptor::ClientRequestInfo_ptr ri)
 148 {
 149   client_interceptor_check_++;
 150
 151   CORBA::String_var op = ri->operation ();
 152
 153   CORBA::String_var exception_id =
 154     ri->received_exception_id ();
 155
 156   ACE_DEBUG ((LM_DEBUG,
 157               "Echo_Client_Request_Interceptor::received_exception "
 158               "from \"%C\"\n",
 159               op.in ()));
 160
 161   ACE_DEBUG ((LM_DEBUG,
 162               "Exception ID = %C\n",
 163               exception_id.in ()));
 164 }
 165
 166 Echo_Server_Request_Interceptor::Echo_Server_Request_Interceptor ()
 167   : myname_ ("Echo_Server_Interceptor")
 168 {
 169 }
 170
 171 Echo_Server_Request_Interceptor::~Echo_Server_Request_Interceptor ()
 172 {
 173 }
 174
 175 char *
 176 Echo_Server_Request_Interceptor::name ()
 177 {
 178   return CORBA::string_dup (this->myname_);
 179 }
 180
 181 void
 182 Echo_Server_Request_Interceptor::destroy ()
 183 {
 184 }
 185
 186 void
 187 Echo_Server_Request_Interceptor::receive_request_service_contexts (
 188     PortableInterceptor::ServerRequestInfo_ptr)
 189 {
 190 }
 191
 192 void
 193 Echo_Server_Request_Interceptor::receive_request (
 194   PortableInterceptor::ServerRequestInfo_ptr ri)
 195 {
 196   ++server_interceptor_check_;
 197
 198   CORBA::String_var op = ri->operation ();
 199
 200   PortableInterceptor::ObjectId_var test_oid =
 201     ri->object_id ();
 202
 203   ACE_DEBUG ((LM_DEBUG,
 204               "Echo_Server_Request_Interceptor::receive_request from \"%C\"\n",
 205               op.in ()));
 206
 207   if (ACE_OS::strcmp (op.in (), "normal") == 0)
 208     {
 209       Dynamic::ParameterList_var paramlist =
 210         ri->arguments ();
 211
 212       CORBA::Long param;
 213       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 214                            // overloaded operator ambiguity.
 215       paramlist[i].argument >>= param;
 216
 217       ACE_DEBUG ((LM_DEBUG,
 218                   "The arg is %d\n",
 219                   param));
 220      }
 221
 222   CORBA::String_var tmdi =
 223     ri->target_most_derived_interface ();
 224
 225   ACE_DEBUG ((LM_DEBUG,
 226               "Target most derived interface: %C\n",
 227               tmdi.in ()));
 228 }
 229
 230 void
 231 Echo_Server_Request_Interceptor::send_reply (
 232     PortableInterceptor::ServerRequestInfo_ptr ri)
 233 {
 234   ++server_interceptor_check_;
 235
 236   CORBA::String_var op = ri->operation ();
 237
 238   ACE_DEBUG ((LM_DEBUG,
 239               "Echo_Server_Request_Interceptor::send_reply from \"%C\"\n",
 240               op.in ()));
 241
 242   if (ACE_OS::strcmp (op.in (), "normal") == 0)
 243     {
 244       Dynamic::ParameterList_var paramlist =
 245         ri->arguments ();
 246
 247       CORBA::Long param;
 248       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 249                            // overloaded operator ambiguity.
 250       paramlist[i].argument >>= param;
 251       ACE_DEBUG ((LM_DEBUG,
 252                   "The arg is %d\n",
 253                   param));
 254     }
 255
 256   if (ACE_OS::strcmp (op.in (), "calculate") == 0)
 257     {
 258       Dynamic::ParameterList_var paramlist =
 259         ri->arguments ();
 260
 261       CORBA::Long param1, param2, result = 0;
 262       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 263                            // overloaded operator ambiguity.
 264       paramlist[i++].argument >>= param1;
 265       paramlist[i].argument >>= param2;
 266
 267       CORBA::Any_var result_any = ri->result ();
 268
 269       (result_any.in ()) >>= result;
 270
 271       ACE_DEBUG ((LM_DEBUG,
 272                   "The result of calculate is %d + %d = %d\n",
 273                   param1,
 274                   param2,
 275                   result));
 276     }
 277 }
 278
 279 void
 280 Echo_Server_Request_Interceptor::send_exception (
 281     PortableInterceptor::ServerRequestInfo_ptr ri)
 282 {
 283   ++server_interceptor_check_;
 284
 285   CORBA::String_var op = ri->operation ();
 286
 287   ACE_DEBUG ((LM_DEBUG,
 288               "Echo_Server_Request_Interceptor::send_exception "
 289               "from \"%C\"\n",
 290               op.in ()));
 291
 292
 293   CORBA::Any_var any =
 294     ri->sending_exception ();
 295
 296   CORBA::TypeCode_var type = any->type ();
 297
 298   const char *exception_id = type->id ();
 299
 300   ACE_DEBUG ((LM_DEBUG,
 301               "Exception ID = %C\n",
 302               exception_id));
 303 }
 304
 305 void
 306 Echo_Server_Request_Interceptor::send_other (
 307     PortableInterceptor::ServerRequestInfo_ptr)
 308 {
 309   ++server_interceptor_check_;
 310
 311   // Do Nothing
 312 }