TAO/tests/Portable_Interceptors/PICurrent/ClientRequestInterceptor2.cpp

   1 #include "ClientRequestInterceptor2.h"
   2 #include "tao/CORBA_String.h"
   3 #include "ace/Log_Msg.h"
   4 #include "ace/OS_NS_string.h"
   5
   6 ClientRequestInterceptor2::ClientRequestInterceptor2 (
   7   PortableInterceptor::SlotId id)
   8   : slot_id_ (id)
   9 {
  10 }
  11
  12 char *
  13 ClientRequestInterceptor2::name ()
  14 {
  15   return CORBA::string_dup ("ClientRequestInterceptor2");
  16 }
  17
  18 void
  19 ClientRequestInterceptor2::destroy (void)
  20 {
  21 }
  22
  23 void
  24 ClientRequestInterceptor2::send_request (
  25       PortableInterceptor::ClientRequestInfo_ptr ri)
  26 {
  27   CORBA::String_var op = ri->operation ();
  28
  29   if (ACE_OS::strcmp (op.in (), "invoke_you") != 0)
  30     return; // Don't mess with PICurrent if not invoking test method.
  31
  32   try
  33     {
  34       // The goal of this test is to verify that a request scope
  35       // current was successfully shallow copied from a TSC that
  36       // itself was shallow copied from a ServerRequestInfo's RSC.
  37       // Specifically, verify that the RSC->TSC->RSC sequence of
  38       // copies occurred correctly.
  39
  40       // Retrieve data from the RSC (request scope current).
  41       CORBA::Long number = 0;
  42
  43       CORBA::Any_var data =
  44         ri->get_slot (this->slot_id_);
  45
  46       if (!(data.in () >>= number))
  47         {
  48           ACE_ERROR ((LM_ERROR,
  49                       "(%P|%t) ERROR: Unable to extract data from "
  50                       "CORBA::Any retrieved from RSC.\n"));
  51
  52           throw CORBA::INTERNAL ();
  53         }
  54
  55       ACE_DEBUG ((LM_DEBUG,
  56                   "(%P|%t) Extracted <%d> from RSC slot %u\n",
  57                   number,
  58                   this->slot_id_));
  59     }
  60   catch (const PortableInterceptor::InvalidSlot& ex)
  61     {
  62       ex._tao_print_exception ("Exception thrown in ""send_request()\n");
  63
  64       ACE_DEBUG ((LM_DEBUG,
  65                   "Invalid slot: %u\n",
  66                   this->slot_id_));
  67
  68       throw CORBA::INTERNAL ();
  69     }
  70
  71   ACE_DEBUG ((LM_INFO,
  72               "(%P|%t) RSC->TSC->RSC copying appears to be working.\n"));
  73 }
  74
  75 void
  76 ClientRequestInterceptor2::send_poll (
  77     PortableInterceptor::ClientRequestInfo_ptr)
  78 {
  79 }
  80
  81 void
  82 ClientRequestInterceptor2::receive_reply (
  83     PortableInterceptor::ClientRequestInfo_ptr)
  84 {
  85 }
  86
  87 void
  88 ClientRequestInterceptor2::receive_exception (
  89     PortableInterceptor::ClientRequestInfo_ptr)
  90 {
  91 }
  92
  93 void
  94 ClientRequestInterceptor2::receive_other (
  95     PortableInterceptor::ClientRequestInfo_ptr)
  96 {
  97 }