TAO/tests/Portable_Interceptors/Benchmark/server_interceptors.cpp

   1 #include "server_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_Server_Request_Interceptor::Vault_Server_Request_Interceptor (void)
  12   : myname_ ("Vault_Server_Interceptor")
  13 {
  14 }
  15
  16 Vault_Server_Request_Interceptor::~Vault_Server_Request_Interceptor ()
  17 {
  18 }
  19
  20 char *
  21 Vault_Server_Request_Interceptor::name (void)
  22 {
  23   return CORBA::string_dup (this->myname_);
  24 }
  25
  26 void
  27 Vault_Server_Request_Interceptor::destroy (void)
  28 {
  29 }
  30
  31 void
  32 Vault_Server_Request_Interceptor::receive_request_service_contexts (
  33     PortableInterceptor::ServerRequestInfo_ptr)
  34 {
  35   // Do nothing
  36 }
  37
  38 void
  39 Vault_Server_Request_Interceptor::receive_request (
  40     PortableInterceptor::ServerRequestInfo_ptr ri)
  41 {
  42
  43   CORBA::String_var op = ri->operation ();
  44
  45   if (ACE_OS::strcmp (op.in (), "authenticate") == 0)
  46     {
  47       IOP::ServiceId id = request_ctx_id;
  48       IOP::ServiceContext_var sc =
  49         ri->get_request_service_context (id);
  50
  51       const char *buf =
  52         reinterpret_cast<const char *> (sc->context_data.get_buffer ());
  53
  54       if (ACE_OS::strcmp (buf, "root123") != 0)
  55         throw CORBA::NO_PERMISSION ();
  56     }
  57
  58   if (ACE_OS::strcmp (op.in (), "update_records") == 0)
  59     {
  60       Dynamic::ParameterList_var paramlist =
  61         ri->arguments ();
  62
  63       const Test_Interceptors::Secure_Vault::Record *record = 0;
  64       CORBA::Long id;
  65       CORBA::ULong i = 0;  // index -- explicitly used to avoid
  66                            // overloaded operator ambiguity.
  67       paramlist[i++].argument >>= id;
  68       paramlist[i].argument >>= record;
  69     }
  70 }
  71
  72 void
  73 Vault_Server_Request_Interceptor::send_reply (
  74     PortableInterceptor::ServerRequestInfo_ptr ri)
  75 {
  76
  77   CORBA::String_var op = ri->operation ();
  78
  79   if (ACE_OS::strcmp (op.in (), "update_records") == 0)
  80     {
  81       CORBA::Long result;
  82       CORBA::Any_var result_any = ri->result ();
  83
  84       (result_any.in ()) >>= result;
  85     }
  86 }
  87
  88 void
  89 Vault_Server_Request_Interceptor::send_exception (
  90     PortableInterceptor::ServerRequestInfo_ptr)
  91 {
  92   // Do Nothing
  93 }
  94
  95 void
  96 Vault_Server_Request_Interceptor::send_other (
  97     PortableInterceptor::ServerRequestInfo_ptr)
  98 {
  99   // Do Nothing
 100 }
 101
 102
 103 //////////////////////////////////  Context /////////////////////////
 104
 105 Vault_Server_Request_Context_Interceptor::Vault_Server_Request_Context_Interceptor (void)
 106   : myname_ ("Vault_Server_Context_Interceptor")
 107 {
 108 }
 109
 110 Vault_Server_Request_Context_Interceptor::~Vault_Server_Request_Context_Interceptor ()
 111 {
 112 }
 113
 114 char *
 115 Vault_Server_Request_Context_Interceptor::name ()
 116 {
 117   return CORBA::string_dup (this->myname_);
 118 }
 119
 120 void
 121 Vault_Server_Request_Context_Interceptor::destroy ()
 122 {
 123 }
 124
 125 void
 126 Vault_Server_Request_Context_Interceptor::receive_request_service_contexts(
 127     PortableInterceptor::ServerRequestInfo_ptr)
 128 {
 129   // Do nothing
 130 }
 131
 132 void
 133 Vault_Server_Request_Context_Interceptor::receive_request (
 134     PortableInterceptor::ServerRequestInfo_ptr ri)
 135 {
 136
 137   IOP::ServiceId id = request_ctx_id;
 138   IOP::ServiceContext_var sc =
 139     ri->get_request_service_context (id);
 140
 141   const char *buf = reinterpret_cast<const char *> (sc->context_data.get_buffer ());
 142
 143   if (ACE_OS::strcmp (buf, "root123") !=0)
 144     throw CORBA::NO_PERMISSION ();
 145 }
 146
 147 void
 148 Vault_Server_Request_Context_Interceptor::send_reply (
 149     PortableInterceptor::ServerRequestInfo_ptr)
 150 {
 151
 152 }
 153
 154 void
 155 Vault_Server_Request_Context_Interceptor::send_exception (
 156     PortableInterceptor::ServerRequestInfo_ptr)
 157 {
 158 }
 159
 160 void
 161 Vault_Server_Request_Context_Interceptor::send_other (
 162     PortableInterceptor::ServerRequestInfo_ptr)
 163 {
 164   // Do Nothing
 165 }
 166
 167 ///////////////////////////////////Dynamic ////////////////////////////////////
 168
 169 Vault_Server_Request_Dynamic_Interceptor::Vault_Server_Request_Dynamic_Interceptor (void)
 170   : myname_ ("Vault_Server_Dynamic_Interceptor")
 171 {
 172 }
 173
 174 Vault_Server_Request_Dynamic_Interceptor::~Vault_Server_Request_Dynamic_Interceptor ()
 175 {
 176 }
 177
 178 char *
 179 Vault_Server_Request_Dynamic_Interceptor::name ()
 180 {
 181   return CORBA::string_dup (this->myname_);
 182 }
 183
 184 void
 185 Vault_Server_Request_Dynamic_Interceptor::destroy ()
 186 {
 187 }
 188
 189 void
 190 Vault_Server_Request_Dynamic_Interceptor::receive_request (
 191     PortableInterceptor::ServerRequestInfo_ptr ri)
 192 {
 193
 194   CORBA::String_var op = ri->operation ();
 195
 196   if (ACE_OS::strcmp (op.in (), "authenticate") == 0)
 197     {
 198       Dynamic::ParameterList_var paramlist =
 199         ri->arguments ();
 200
 201       const char *user;
 202       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 203                            // overloaded operator ambiguity.
 204       paramlist[i].argument >>= user;
 205     }
 206
 207   if (ACE_OS::strcmp (op.in (), "update_records") == 0)
 208     {
 209       Dynamic::ParameterList_var paramlist =
 210         ri->arguments ();
 211
 212       const Test_Interceptors::Secure_Vault::Record *record = 0;
 213       CORBA::Long id;
 214       CORBA::ULong i = 0;  // index -- explicitly used to avoid
 215                            // overloaded operator ambiguity.
 216       paramlist[i++].argument >>= id;
 217       paramlist[i].argument >>= record;
 218     }
 219 }
 220
 221 void
 222 Vault_Server_Request_Dynamic_Interceptor::receive_request_service_contexts(
 223     PortableInterceptor::ServerRequestInfo_ptr)
 224 {
 225   // Do nothing
 226 }
 227
 228 void
 229 Vault_Server_Request_Dynamic_Interceptor::send_reply (
 230     PortableInterceptor::ServerRequestInfo_ptr ri)
 231 {
 232
 233   CORBA::String_var op = ri->operation ();
 234
 235   if (ACE_OS::strcmp (op.in (), "ready") == 0)
 236     {
 237       CORBA::Short result;
 238       CORBA::Any_var result_any = ri->result ();
 239
 240       (result_any.in ()) >>= result;
 241     }
 242
 243   if (ACE_OS::strcmp (op.in (), "update_records") == 0)
 244     {
 245       CORBA::Long result;
 246       CORBA::Any_var result_any = ri->result ();
 247
 248       (result_any.in ()) >>= result;
 249     }
 250 }
 251
 252 void
 253 Vault_Server_Request_Dynamic_Interceptor::send_exception (
 254     PortableInterceptor::ServerRequestInfo_ptr)
 255 {
 256 }
 257
 258 void
 259 Vault_Server_Request_Dynamic_Interceptor::send_other (
 260     PortableInterceptor::ServerRequestInfo_ptr)
 261 {
 262   // Do Nothing
 263 }
 264
 265 //////////////////////////////NOOP///////////////////////////////////////
 266
 267 Vault_Server_Request_NOOP_Interceptor::Vault_Server_Request_NOOP_Interceptor (void)
 268   : myname_ ("Vault_Server_NOOP_Interceptor")
 269 {
 270 }
 271
 272 Vault_Server_Request_NOOP_Interceptor::~Vault_Server_Request_NOOP_Interceptor ()
 273 {
 274 }
 275
 276 char *
 277 Vault_Server_Request_NOOP_Interceptor::name (void)
 278 {
 279   return CORBA::string_dup (this->myname_);
 280 }
 281
 282 void
 283 Vault_Server_Request_NOOP_Interceptor::destroy ()
 284 {
 285 }
 286
 287 void
 288 Vault_Server_Request_NOOP_Interceptor::receive_request (
 289     PortableInterceptor::ServerRequestInfo_ptr)
 290 {
 291 }
 292
 293 void
 294 Vault_Server_Request_NOOP_Interceptor::receive_request_service_contexts(
 295     PortableInterceptor::ServerRequestInfo_ptr)
 296 {
 297   // Do nothing
 298 }
 299
 300 void
 301 Vault_Server_Request_NOOP_Interceptor::send_reply (
 302     PortableInterceptor::ServerRequestInfo_ptr)
 303 {
 304
 305 }
 306
 307 void
 308 Vault_Server_Request_NOOP_Interceptor::send_exception (
 309     PortableInterceptor::ServerRequestInfo_ptr)
 310 {
 311 }
 312
 313 void
 314 Vault_Server_Request_NOOP_Interceptor::send_other (
 315     PortableInterceptor::ServerRequestInfo_ptr)
 316 {
 317   // Do Nothing
 318 }