TAO/tests/RTCORBA/Client_Propagated/interceptors.cpp

   1 #include "interceptors.h"
   2 #include "tao/OctetSeqC.h"
   3 #include "ace/Log_Msg.h"
   4
   5 Client_Request_Interceptor::
   6 Client_Request_Interceptor (const char *id)
   7   : myname_ ("Client_Request_Interceptor"),
   8     orb_id_ (CORBA::string_dup (id))
   9 {
  10 }
  11
  12 Client_Request_Interceptor::~Client_Request_Interceptor (void)
  13 {
  14 }
  15
  16 char *
  17 Client_Request_Interceptor::name (void)
  18 {
  19   return CORBA::string_dup (this->myname_);
  20 }
  21
  22 void
  23 Client_Request_Interceptor::destroy (void)
  24 {
  25 }
  26
  27 void
  28 Client_Request_Interceptor::send_poll (
  29     PortableInterceptor::ClientRequestInfo_ptr)
  30 {
  31   // Do Nothing
  32 }
  33
  34 void
  35 Client_Request_Interceptor::send_request (
  36     PortableInterceptor::ClientRequestInfo_ptr)
  37 {
  38   // Do Nothing
  39 }
  40
  41 void
  42 Client_Request_Interceptor::receive_reply (
  43     PortableInterceptor::ClientRequestInfo_ptr ri)
  44 {
  45
  46   try
  47     {
  48       // Try to get the RTCorbaPriority context.  If its not there,
  49       // report the fact via an exception.
  50       IOP::ServiceContext_var sc =
  51         ri->get_reply_service_context (IOP::RTCorbaPriority);
  52     }
  53   catch (const CORBA::Exception& ex)
  54     {
  55       ex._tao_print_exception ("Caught exception:");
  56
  57       ACE_DEBUG ((LM_DEBUG, "EXCEPTION was most likely caused by the lack "
  58                             "of an IOP::RTCorbaPriority context in the reply.\n"));
  59       throw;
  60     }
  61
  62 }
  63
  64 void
  65 Client_Request_Interceptor::receive_other (
  66     PortableInterceptor::ClientRequestInfo_ptr)
  67 {
  68 }
  69
  70 void
  71 Client_Request_Interceptor::receive_exception (
  72     PortableInterceptor::ClientRequestInfo_ptr ri)
  73 {
  74
  75   if (CORBA::is_nil (this->orb_.in ()))
  76     {
  77       int argc = 0;
  78       ACE_TCHAR **argv = 0;
  79       this->orb_ = CORBA::ORB_init (argc, argv,
  80                                     this->orb_id_.in ());
  81     }
  82
  83   CORBA::String_var operation = ri->operation ();
  84
  85   CORBA::Object_var target = ri->target ();
  86
  87   CORBA::String_var ior =
  88     this->orb_->object_to_string (target.in ());
  89
  90   ACE_DEBUG ((LM_DEBUG,
  91               "%s.received_exception "
  92               "from \"%s\" on object: %s\n",
  93               this->myname_,
  94               operation.in (),
  95               ior.in ()));
  96
  97   // Try to get the RTCorbaPriority context.  If its not there,
  98   // report the fact via an exception.
  99   IOP::ServiceContext_var sc =
 100     ri->get_reply_service_context (IOP::RTCorbaPriority);
 101 }