TAO/tests/RTCORBA/Bug_3382_Regression/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 ()
  13 {
  14 }
  15
  16 char *
  17 Client_Request_Interceptor::name ()
  18 {
  19   return CORBA::string_dup (this->myname_);
  20 }
  21
  22 void
  23 Client_Request_Interceptor::destroy ()
  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   try
  46     {
  47       // Try to get the RTCorbaPriority context.  If its not there,
  48       // report the fact via an exception.
  49       IOP::ServiceContext_var sc =
  50         ri->get_reply_service_context (IOP::RTCorbaPriority);
  51     }
  52   catch (const CORBA::Exception& ex)
  53     {
  54       ex._tao_print_exception ("Caught exception:");
  55
  56       ACE_DEBUG ((LM_DEBUG, "EXCEPTION was most likely caused by the lack "
  57                             "of an IOP::RTCorbaPriority context in the reply.\n"));
  58       throw;
  59     }
  60
  61 }
  62
  63 void
  64 Client_Request_Interceptor::receive_other (
  65     PortableInterceptor::ClientRequestInfo_ptr)
  66 {
  67 }
  68
  69 void
  70 Client_Request_Interceptor::receive_exception (
  71     PortableInterceptor::ClientRequestInfo_ptr ri)
  72 {
  73   if (CORBA::is_nil (this->orb_.in ()))
  74     {
  75       int argc = 0;
  76       ACE_TCHAR **argv = 0;
  77       this->orb_ = CORBA::ORB_init (argc, argv,
  78                                     this->orb_id_.in ());
  79     }
  80
  81   CORBA::String_var operation = ri->operation ();
  82
  83   CORBA::Object_var target = ri->target ();
  84
  85   CORBA::String_var ior =
  86     this->orb_->object_to_string (target.in ());
  87
  88   ACE_DEBUG ((LM_DEBUG,
  89               "%s.received_exception "
  90               "from \"%s\" on object: %s\n",
  91               this->myname_,
  92               operation.in (),
  93               ior.in ()));
  94
  95   // Try to get the RTCorbaPriority context.  If its not there,
  96   // report the fact via an exception.
  97   IOP::ServiceContext_var sc =
  98     ri->get_reply_service_context (IOP::RTCorbaPriority);
  99 }