TAO/tests/POA/Bug_1592_Regression/Server_Request_Interceptor.cpp

   1 #include "Server_Request_Interceptor.h"
   2
   3 CORBA::Boolean receive_request_service_contexts_called = 0;
   4 CORBA::Boolean receive_request_called = 0;
   5 CORBA::Boolean ending_interception_point_called = 0;
   6
   7
   8 Server_Request_Interceptor::Server_Request_Interceptor ()
   9 {
  10 }
  11
  12 Server_Request_Interceptor::~Server_Request_Interceptor ()
  13 {
  14 }
  15
  16 char *
  17 Server_Request_Interceptor::name ()
  18 {
  19   return CORBA::string_dup ("");  // Anonymous
  20 }
  21
  22 void
  23 Server_Request_Interceptor::destroy ()
  24 {
  25 }
  26
  27 void
  28 Server_Request_Interceptor::receive_request_service_contexts (
  29     PortableInterceptor::ServerRequestInfo_ptr ri)
  30 {
  31   CORBA::String_var op = ri->operation ();
  32
  33   if (ACE_OS::strcmp (op.in (), "shutdown") != 0)
  34     {
  35       if (::receive_request_service_contexts_called != 0)
  36         {
  37           throw CORBA::INTERNAL ();
  38         }
  39
  40       ::receive_request_service_contexts_called = 1;
  41     }
  42 }
  43
  44 void
  45 Server_Request_Interceptor::receive_request (
  46     PortableInterceptor::ServerRequestInfo_ptr ri)
  47 {
  48   CORBA::String_var op = ri->operation ();
  49
  50   if (ACE_OS::strcmp (op.in (), "shutdown") != 0)
  51     {
  52       if (::receive_request_called != 0)
  53         {
  54           throw CORBA::INTERNAL ();
  55         }
  56
  57       ::receive_request_called = 1;
  58     }
  59 }
  60
  61 void
  62 Server_Request_Interceptor::send_reply (
  63     PortableInterceptor::ServerRequestInfo_ptr ri)
  64 {
  65   CORBA::String_var op = ri->operation ();
  66
  67   if (ACE_OS::strcmp (op.in (), "shutdown") != 0)
  68     {
  69       if (::ending_interception_point_called != 0)
  70         {
  71           throw CORBA::INTERNAL ();
  72         }
  73
  74       ::ending_interception_point_called = 1;
  75     }
  76 }
  77
  78 void
  79 Server_Request_Interceptor::send_exception (
  80     PortableInterceptor::ServerRequestInfo_ptr ri)
  81 {
  82   CORBA::String_var op = ri->operation ();
  83
  84   if (ACE_OS::strcmp (op.in (), "shutdown") != 0)
  85     {
  86       if (::ending_interception_point_called != 0)
  87         {
  88           throw CORBA::INTERNAL ();
  89         }
  90
  91       ::ending_interception_point_called = 1;
  92     }
  93 }
  94
  95 void
  96 Server_Request_Interceptor::send_other (
  97     PortableInterceptor::ServerRequestInfo_ptr ri)
  98 {
  99   CORBA::String_var op = ri->operation ();
 100
 101   if (ACE_OS::strcmp (op.in (), "shutdown") != 0)
 102     {
 103       if (::ending_interception_point_called != 0)
 104         {
 105           throw CORBA::INTERNAL ();
 106         }
 107
 108       ::ending_interception_point_called = 1;
 109     }
 110 }