TAO/tests/Bug_3853_Regression/client_interceptor.cpp

   1 #include "client_interceptor.h"
   2 #include "HelloC.h"
   3 #include "ace/Log_Msg.h"
   4
   5 extern const ACE_TCHAR *server2_ior;
   6 extern CORBA::ORB_var orb;
   7
   8 int isRecursive = 0;
   9 extern Demo::HelloWorld_var server1_shutdownObj;
  10
  11 Echo_Client_Request_Interceptor::
  12 Echo_Client_Request_Interceptor ()
  13   : myname_ ("Echo_Client_Interceptor")
  14 {
  15 }
  16
  17 char *
  18 Echo_Client_Request_Interceptor::name ()
  19 {
  20   return CORBA::string_dup (this->myname_);
  21 }
  22
  23 void
  24 Echo_Client_Request_Interceptor::destroy ()
  25 {
  26 }
  27
  28 void
  29 Echo_Client_Request_Interceptor::send_poll (
  30     PortableInterceptor::ClientRequestInfo_ptr)
  31 {
  32   // Do Nothing
  33 }
  34
  35 void
  36 Echo_Client_Request_Interceptor::send_request (
  37     PortableInterceptor::ClientRequestInfo_ptr ri)
  38 {
  39   CORBA::String_var operation = ri->operation ();
  40   if (ACE_OS::strcmp (operation.in (), "shutdown") == 0) {
  41     return;
  42   }
  43
  44   //send to another
  45   isRecursive ++ ;
  46   if (isRecursive%2 == 1 )
  47   {
  48     if (isRecursive == 3) {
  49       ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t)Echo_Client_Request_Interceptor::send_request(%d) ")
  50                             ACE_TEXT ("shutdown server 1 now. \n"), isRecursive));
  51       server1_shutdownObj->shutdown();
  52     }
  53
  54     CORBA::Object_var helloObj = orb->string_to_object(server2_ior);
  55
  56     Demo::HelloWorld_var hello = Demo::HelloWorld::_narrow(helloObj.in ());
  57
  58     if (CORBA::is_nil(hello.in ())) {
  59       ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%P|%t)Echo_Client_Request_Interceptor::send_request(%d) ")
  60                             ACE_TEXT ("hello reference is nil.\n"), isRecursive));
  61     }
  62     else {
  63       ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t)Echo_Client_Request_Interceptor::send_request(%d) ")
  64                             ACE_TEXT ("call server2 HelloWorld::sayHello() \n"), isRecursive));
  65       const char* pMsg = " server2 say Hello";
  66       hello->sayHello(pMsg);
  67     }
  68   }
  69 }
  70
  71 void
  72 Echo_Client_Request_Interceptor::receive_reply (
  73     PortableInterceptor::ClientRequestInfo_ptr)
  74 {
  75 }
  76
  77 void
  78 Echo_Client_Request_Interceptor::receive_other (
  79     PortableInterceptor::ClientRequestInfo_ptr)
  80 {
  81 }
  82
  83 void
  84 Echo_Client_Request_Interceptor::receive_exception (
  85     PortableInterceptor::ClientRequestInfo_ptr)
  86 {
  87 }