TAO/tests/Portable_Interceptors/Benchmark/client_interceptors.cpp

   1 #include "client_interceptors.h"
   2
   3 #include "tao/AnyTypeCode/DynamicC.h"
   4 #include "tao/AnyTypeCode/TypeCode.h"
   5 #include "ace/OS_NS_string.h"
   6 #include "ace/Log_Msg.h"
   7
   8 const CORBA::ULong request_ctx_id = 0xdead;
   9 //const CORBA::ULong reply_ctx_id = 0xbeef;   // Never used.
  10
  11 Vault_Client_Request_Interceptor::Vault_Client_Request_Interceptor ()
  12   : myname_ ("Vault_Client_Interceptor")
  13 {
  14 }
  15
  16 Vault_Client_Request_Interceptor::~Vault_Client_Request_Interceptor ()
  17 {
  18 }
  19
  20 char *
  21 Vault_Client_Request_Interceptor::name ()
  22 {
  23   return CORBA::string_dup (this->myname_);
  24 }
  25
  26 void
  27 Vault_Client_Request_Interceptor::destroy ()
  28 {
  29 }
  30
  31 void
  32 Vault_Client_Request_Interceptor::send_poll (
  33     PortableInterceptor::ClientRequestInfo_ptr)
  34 {
  35   // Do nothing
  36 }
  37
  38 void
  39 Vault_Client_Request_Interceptor::send_request (
  40     PortableInterceptor::ClientRequestInfo_ptr ri)
  41 {
  42   CORBA::String_var op = ri->operation ();
  43
  44   if (ACE_OS::strcmp (op.in (), "authenticate") == 0)
  45     {
  46       // Make the context to send the context to the target.
  47       IOP::ServiceContext sc;
  48       sc.context_id = request_ctx_id;
  49
  50       const char passwd[] = "root123";
  51       CORBA::ULong string_len = sizeof (passwd) + 1;
  52       CORBA::Octet *buf = 0;
  53       ACE_NEW (buf,
  54                CORBA::Octet [string_len]);
  55       ACE_OS::strcpy (reinterpret_cast<char *> (buf), passwd);
  56
  57       sc.context_data.replace (string_len, string_len, buf, 1);
  58
  59       // Add this context to the service context list.
  60       ri->add_request_service_context (sc, 0);
  61     }
  62
  63   if (ACE_OS::strcmp (op.in (), "update_records") == 0)
  64     {
  65       Dynamic::ParameterList_var paramlist =
  66         ri->arguments ();
  67
  68       const Test_Interceptors::Secure_Vault::Record *record = 0;
  69       CORBA::Long id;
  70       CORBA::ULong i = 0;  // index -- explicitly used to avoid
  71                            // overloaded operator ambiguity.
  72       paramlist[i++].argument >>= id;
  73       paramlist[i].argument >>= record;
  74     }
  75 }
  76
  77 void
  78 Vault_Client_Request_Interceptor::receive_reply (
  79     PortableInterceptor::ClientRequestInfo_ptr ri)
  80 {
  81   CORBA::String_var op = ri->operation ();
  82
  83   if (ACE_OS::strcmp (op.in (), "update_records") == 0)
  84     {
  85       CORBA::Long result;
  86       CORBA::Any_var result_any = ri->result ();
  87
  88       (result_any.in ()) >>= result;
  89     }
  90 }
  91
  92 void
  93 Vault_Client_Request_Interceptor::receive_other (
  94     PortableInterceptor::ClientRequestInfo_ptr)
  95 {
  96   // Do nothing
  97 }
  98
  99 void
 100 Vault_Client_Request_Interceptor::receive_exception (
 101     PortableInterceptor::ClientRequestInfo_ptr ri)
 102 {
 103   CORBA::Any_var any = ri->received_exception ();
 104
 105   CORBA::TypeCode_var tc = any->type ();
 106
 107   const char *id = tc->id ();
 108
 109   CORBA::String_var exception_id =
 110     ri->received_exception_id ();
 111
 112   if (ACE_OS::strcmp (id, exception_id.in ()) != 0)
 113     ACE_ERROR ((LM_ERROR,
 114                 "Mismatched exception IDs: %s != %s\n",
 115                 id,
 116                 exception_id.in ()));
 117 }
 118
 119
 120 //////////////////////////////////  Context /////////////////////////
 121
 122 Vault_Client_Request_Context_Interceptor::Vault_Client_Request_Context_Interceptor ()
 123   : myname_ ("Vault_Client_Context_Interceptor")
 124 {
 125 }
 126
 127 Vault_Client_Request_Context_Interceptor::~Vault_Client_Request_Context_Interceptor ()
 128 {
 129 }
 130
 131 char *
 132 Vault_Client_Request_Context_Interceptor::name ()
 133 {
 134   return CORBA::string_dup (this->myname_);
 135 }
 136
 137 void
 138 Vault_Client_Request_Context_Interceptor::destroy ()
 139 {
 140 }
 141
 142 void
 143 Vault_Client_Request_Context_Interceptor::send_poll (
 144     PortableInterceptor::ClientRequestInfo_ptr)
 145 {
 146   // Do nothing
 147 }
 148
 149 void
 150 Vault_Client_Request_Context_Interceptor::send_request (
 151     PortableInterceptor::ClientRequestInfo_ptr ri)
 152 {
 153   // MAke the context to send the context to the target
 154   IOP::ServiceContext sc;
 155   sc.context_id = request_ctx_id;
 156
 157   const char passwd[] = "root123";
 158   CORBA::ULong string_len = sizeof (passwd) + 1;
 159   CORBA::Octet *buf = 0;
 160   ACE_NEW_THROW_EX (buf,
 161                     CORBA::Octet [string_len],
 162                     CORBA::NO_MEMORY ());
 163
 164   ACE_OS::strcpy (reinterpret_cast<char *> (buf), passwd);
 165
 166   sc.context_data.replace (string_len, string_len, buf, 1);
 167
 168   // Add this context to the service context list.
 169   ri->add_request_service_context (sc, 0);
 170 }
 171
 172 void
 173 Vault_Client_Request_Context_Interceptor::receive_other (
 174     PortableInterceptor::ClientRequestInfo_ptr)
 175 {
 176   // Do nothing
 177 }
 178
 179 void
 180 Vault_Client_Request_Context_Interceptor::receive_reply (
 181     PortableInterceptor::ClientRequestInfo_ptr)
 182 {
 183 }
 184
 185 void
 186 Vault_Client_Request_Context_Interceptor::receive_exception (
 187     PortableInterceptor::ClientRequestInfo_ptr ri)
 188 {
 189   CORBA::Any_var any = ri->received_exception ();
 190
 191   CORBA::TypeCode_var tc = any->type ();
 192
 193   const char *id = tc->id ();
 194
 195   CORBA::String_var exception_id =
 196     ri->received_exception_id ();
 197
 198   if (ACE_OS::strcmp (id, exception_id.in ()) != 0)
 199     ACE_ERROR ((LM_ERROR,
 200                 "Mismatched exception IDs %s != %s\n",
 201                 id,
 202                 exception_id.in ()));
 203 }
 204
 205
 206 ///////////////////////////////////Dynamic ////////////////////////////////////
 207
 208 Vault_Client_Request_Dynamic_Interceptor::Vault_Client_Request_Dynamic_Interceptor ()
 209   : myname_ ("Vault_Client_Dynamic_Interceptor")
 210 {
 211 }
 212
 213 Vault_Client_Request_Dynamic_Interceptor::~Vault_Client_Request_Dynamic_Interceptor ()
 214 {
 215 }
 216
 217 char *
 218 Vault_Client_Request_Dynamic_Interceptor::name ()
 219 {
 220   return CORBA::string_dup (this->myname_);
 221 }
 222
 223 void
 224 Vault_Client_Request_Dynamic_Interceptor::destroy ()
 225 {
 226 }
 227
 228 void
 229 Vault_Client_Request_Dynamic_Interceptor::send_poll (
 230     PortableInterceptor::ClientRequestInfo_ptr)
 231 {
 232   // Do nothing
 233 }
 234
 235 void
 236 Vault_Client_Request_Dynamic_Interceptor::send_request (
 237     PortableInterceptor::ClientRequestInfo_ptr ri)
 238 {
 239   CORBA::String_var op = ri->operation ();
 240
 241  if (ACE_OS::strcmp (op.in (), "authenticate") == 0)
 242     {
 243       Dynamic::ParameterList_var paramlist =
 244         ri->arguments ();
 245
 246       const char *user;
 247       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 248                            // overloaded operator ambiguity.
 249       paramlist[i].argument >>= user;
 250     }
 251
 252  if (ACE_OS::strcmp (op.in (), "update_records") == 0)
 253     {
 254       Dynamic::ParameterList_var paramlist =
 255         ri->arguments ();
 256
 257       const Test_Interceptors::Secure_Vault::Record *record = 0;
 258       CORBA::Long id;
 259       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 260                            // overloaded operator ambiguity.
 261       paramlist[i++].argument >>= id;
 262       paramlist[i].argument >>= record;
 263     }
 264 }
 265
 266 void
 267 Vault_Client_Request_Dynamic_Interceptor::receive_reply (
 268     PortableInterceptor::ClientRequestInfo_ptr ri)
 269 {
 270   CORBA::String_var op = ri->operation ();
 271
 272   if (ACE_OS::strcmp (op.in (), "ready") == 0)
 273     {
 274       CORBA::Short result;
 275
 276       CORBA::Any_var result_any = ri->result ();
 277
 278       (result_any.in ()) >>= result;
 279     }
 280
 281   if (ACE_OS::strcmp (op.in (), "update_records") == 0)
 282     {
 283       CORBA::Long result;
 284
 285       CORBA::Any_var result_any = ri->result ();
 286
 287       (result_any.in ()) >>= result;
 288     }
 289 }
 290
 291 void
 292 Vault_Client_Request_Dynamic_Interceptor::receive_other (
 293     PortableInterceptor::ClientRequestInfo_ptr)
 294 {
 295   // Do nothing
 296 }
 297
 298 void
 299 Vault_Client_Request_Dynamic_Interceptor::receive_exception (
 300     PortableInterceptor::ClientRequestInfo_ptr ri)
 301 {
 302   CORBA::Any_var any = ri->received_exception ();
 303
 304   CORBA::TypeCode_var tc = any->type ();
 305
 306   const char *id = tc->id ();
 307
 308   CORBA::String_var exception_id =
 309     ri->received_exception_id ();
 310
 311   if (ACE_OS::strcmp (id, exception_id.in ()) != 0)
 312     ACE_ERROR ((LM_ERROR,
 313                 "Mismatched exception IDs %s != %s\n",
 314                 id,
 315                 exception_id.in ()));
 316 }
 317
 318
 319 //////////////////////////////NOOP///////////////////////////////////////
 320
 321 Vault_Client_Request_NOOP_Interceptor::Vault_Client_Request_NOOP_Interceptor ()
 322   : myname_ ("Vault_Client_NOOP_Interceptor")
 323 {
 324 }
 325
 326 Vault_Client_Request_NOOP_Interceptor::~Vault_Client_Request_NOOP_Interceptor ()
 327 {
 328 }
 329
 330 char *
 331 Vault_Client_Request_NOOP_Interceptor::name ()
 332 {
 333   return CORBA::string_dup (this->myname_);
 334 }
 335
 336 void
 337 Vault_Client_Request_NOOP_Interceptor::destroy ()
 338 {
 339 }
 340
 341 void
 342 Vault_Client_Request_NOOP_Interceptor::send_poll (
 343     PortableInterceptor::ClientRequestInfo_ptr)
 344 {
 345   // Do nothing
 346 }
 347
 348 void
 349 Vault_Client_Request_NOOP_Interceptor::send_request (
 350     PortableInterceptor::ClientRequestInfo_ptr)
 351 {
 352 }
 353
 354 void
 355 Vault_Client_Request_NOOP_Interceptor::receive_other (
 356     PortableInterceptor::ClientRequestInfo_ptr)
 357 {
 358   // Do nothing
 359 }
 360
 361 void
 362 Vault_Client_Request_NOOP_Interceptor::receive_reply (
 363     PortableInterceptor::ClientRequestInfo_ptr)
 364 {
 365 }
 366
 367 void
 368 Vault_Client_Request_NOOP_Interceptor::receive_exception (
 369     PortableInterceptor::ClientRequestInfo_ptr ri)
 370 {
 371   CORBA::Any_var any = ri->received_exception ();
 372
 373   CORBA::TypeCode_var tc = any->type ();
 374
 375   const char *id = tc->id ();
 376
 377   CORBA::String_var exception_id =
 378     ri->received_exception_id ();
 379
 380   if (ACE_OS::strcmp (id, exception_id.in ()) != 0)
 381     ACE_ERROR ((LM_ERROR,
 382                 "Mismatched exception IDs %s != %s\n",
 383                 id,
 384                 exception_id.in ()));
 385 }
 386
 387