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