TAO/orbsvcs/tests/Bug_3216_Regression/ServerRequest_Interceptor.cpp

   1 // -*- C++ -*-
   2 #include "ServerRequest_Interceptor.h"
   3 #include "orbsvcs/FT_CORBA_ORBC.h"
   4 #include "tao/IOPC.h"
   5 #include "tao/ORB_Constants.h"
   6 #include "tao/AnyTypeCode/DynamicC.h"
   7 #include "tao/AnyTypeCode/TypeCode.h"
   8 #include "tao/CDR.h"
   9 #include "ace/Log_Msg.h"
  10 #include "ace/OS_NS_string.h"
  11 #include "Hello.h"
  12
  13 TAO249_ServerRequest_Interceptor::TAO249_ServerRequest_Interceptor (void)
  14 : orb_ (0),
  15   client_id_ (0)
  16 {
  17 }
  18
  19 TAO249_ServerRequest_Interceptor::~TAO249_ServerRequest_Interceptor (void)
  20 {
  21 }
  22
  23
  24 char *
  25 TAO249_ServerRequest_Interceptor::name ()
  26 {
  27   return CORBA::string_dup ("TAO_TAO249_ServerRequest_Interceptor");
  28 }
  29
  30 void
  31 TAO249_ServerRequest_Interceptor::destroy ()
  32 {
  33 }
  34
  35 void
  36 TAO249_ServerRequest_Interceptor::receive_request_service_contexts (
  37   PortableInterceptor::ServerRequestInfo_ptr
  38   )
  39 {
  40 }
  41
  42 void
  43 TAO249_ServerRequest_Interceptor::receive_request (
  44   PortableInterceptor::ServerRequestInfo_ptr ri
  45   )
  46 {
  47   CORBA::String_var op = ri->operation ();
  48
  49   try
  50   {
  51     IOP::ServiceContext_var sc =
  52       ri->get_request_service_context (IOP::FT_GROUP_VERSION
  53                                        );
  54
  55
  56     TAO_InputCDR cdr (reinterpret_cast <const char*>
  57                      (sc->context_data.get_buffer ()),
  58                      sc->context_data.length ());
  59
  60     CORBA::Boolean byte_order;
  61
  62     if ((cdr >> ACE_InputCDR::to_boolean (byte_order)) == 0)
  63       {
  64         throw CORBA::BAD_PARAM (CORBA::OMGVMCID | 28,
  65                                CORBA::COMPLETED_NO);
  66       }
  67
  68
  69     cdr.reset_byte_order (static_cast <int> (byte_order));
  70
  71     Hello::normal_context_ok_ = 0;
  72     Hello::extended_context_ok_ = 0;
  73
  74     if (! ACE_OS::strcmp (op.in (), "check_normal_context"))
  75       {
  76         FT::FTGroupVersionServiceContext ftrsc;
  77         Hello::normal_context_ok_ = (cdr >> ftrsc) != 0;
  78       }
  79     else if (! ACE_OS::strcmp (op.in (), "check_extended_context"))
  80       {
  81         FT::TagFTGroupTaggedComponent tftgtc;
  82         Hello::extended_context_ok_ = (cdr >> tftgtc) != 0;
  83       }
  84   }
  85 catch (const CORBA::Exception& ex)
  86   {
  87     ACE_DEBUG ((LM_ERROR, "Unexpected (non regression) error - test failed\n"));
  88     ex._tao_print_exception (
  89                                "Exception in TAO249_ServerRequest_Interceptor::receive_request\n");
  90     throw;
  91   }
  92
  93
  94
  95 }
  96
  97 void
  98 TAO249_ServerRequest_Interceptor::send_reply (
  99   PortableInterceptor::ServerRequestInfo_ptr
 100   )
 101 {
 102 }
 103
 104 void
 105 TAO249_ServerRequest_Interceptor::send_exception (
 106   PortableInterceptor::ServerRequestInfo_ptr
 107   )
 108 {
 109 }
 110
 111 void
 112 TAO249_ServerRequest_Interceptor::send_other (
 113   PortableInterceptor::ServerRequestInfo_ptr
 114   )
 115 {
 116 }
 117