TAO/tests/ORT/ServerRequestInterceptor.cpp

   1 // -*- C++ -*-
   2 #include "ServerRequestInterceptor.h"
   3
   4 #include "ace/Log_Msg.h"
   5 #include "ace/OS_NS_string.h"
   6
   7 ServerRequestInterceptor::ServerRequestInterceptor (
   8   const char * orb_id,
   9   PortableServer::Current_ptr poa_current)
  10   : orb_id_ (orb_id),
  11     poa_current_ (PortableServer::Current::_duplicate (poa_current))
  12 {
  13 }
  14
  15 char *
  16 ServerRequestInterceptor::name ()
  17 {
  18   return CORBA::string_dup ("ServerRequestInterceptor");
  19 }
  20
  21 void
  22 ServerRequestInterceptor::destroy ()
  23 {
  24 }
  25
  26 void
  27 ServerRequestInterceptor::receive_request_service_contexts (
  28     PortableInterceptor::ServerRequestInfo_ptr)
  29 {
  30 }
  31
  32 void
  33 ServerRequestInterceptor::receive_request (
  34     PortableInterceptor::ServerRequestInfo_ptr ri)
  35 {
  36   // If no response is expected, then we're invoking the oneway
  37   // shutdown operation.  Don't bother displaying output a second
  38   // time.
  39   CORBA::Boolean response_expected =
  40     ri->response_expected ();
  41
  42   if (!response_expected)
  43     return;
  44
  45   PortableServer::POA_var poa;
  46
  47   try
  48     {
  49       poa = this->poa_current_->get_POA ();
  50     }
  51   catch (const PortableServer::Current::NoContext& ex)
  52     {
  53       ex._tao_print_exception ("ServerRequestInterceptor::receive_request");
  54
  55       throw CORBA::INTERNAL ();
  56     }
  57
  58   PortableServer::POA_var parent_poa =
  59     poa->the_parent ();
  60
  61   // Make sure there is more than one POA in the POA hierarchy since
  62   // the servant should have been registered with a child POA, not the
  63   // RootPOA.
  64   ACE_ASSERT (!CORBA::is_nil (parent_poa.in ()));
  65
  66   PortableInterceptor::AdapterName_var name =
  67     ri->adapter_name ();
  68
  69
  70   ACE_DEBUG ((LM_INFO,
  71               "POA Hierarchy:\n"
  72               "==============\n"));
  73
  74   const CORBA::ULong len = name->length ();
  75
  76   // Make sure there is more than one AdapterName in the AdapterName
  77   // sequence since the servant should have been registered with a
  78   // child POA, not the RootPOA.
  79   ACE_ASSERT (len > 1);
  80
  81   for (CORBA::ULong i = 0; i < len; ++i)
  82     {
  83       for (CORBA::ULong j = 0; j < i; ++j)
  84         ACE_DEBUG ((LM_INFO, "\t"));
  85
  86       ACE_DEBUG ((LM_INFO,
  87                   "%C\n",
  88                   static_cast<char const*>(name[i])));
  89     }
  90
  91   ACE_DEBUG ((LM_INFO,
  92               "\n"
  93               "==============\n"));
  94
  95   // Make sure the name of the RootPOA is the first in the AdapterName
  96   // sequence.
  97   ACE_ASSERT (ACE_OS::strcmp ("RootPOA", name[(CORBA::ULong) 0]) == 0);
  98
  99   CORBA::String_var orb_id = ri->orb_id ();
 100
 101   ACE_ASSERT (ACE_OS::strcmp (this->orb_id_.in (), orb_id.in ()) == 0);
 102
 103   CORBA::String_var server_id = ri->server_id ();
 104
 105   ACE_ASSERT (ACE_OS::strcmp (server_id.in (), "ORT_test_server") == 0);
 106 }
 107
 108 void
 109 ServerRequestInterceptor::send_reply (
 110     PortableInterceptor::ServerRequestInfo_ptr)
 111 {
 112 }
 113
 114 void
 115 ServerRequestInterceptor::send_exception (
 116     PortableInterceptor::ServerRequestInfo_ptr)
 117 {
 118 }
 119
 120 void
 121 ServerRequestInterceptor::send_other (
 122     PortableInterceptor::ServerRequestInfo_ptr)
 123 {
 124 }