TAO/tests/Bug_1495_Regression/Client_Task.cpp

   1 /**
   2  * @file Client_Task.cpp
   3  * @author Will Otte <wotte@dre.vanderbilt.edu
   4  *
   5  * Implements the Client_Task class defined in Client_Task.h.
   6  */
   7
   8 #include "Client_Task.h"
   9 #include "testC.h"
  10 #include "Client_ORBInitializer.h"
  11 #include "tid_to_int.h"
  12 #include "ace/OS_NS_unistd.h"
  13 #include "ace/OS_NS_sys_stat.h"
  14
  15 Client_Task::Client_Task (const ACE_TCHAR *input,
  16                           CORBA::ORB_ptr corb,
  17                           ACE_Thread_Manager *thr_mgr)
  18   : ACE_Task_Base (thr_mgr),
  19     input_ (input),
  20     corb_ (CORBA::ORB::_duplicate (corb))
  21 {}
  22
  23
  24 int
  25 Client_Task::svc (void)
  26 {
  27   try
  28     {
  29       // The test was designed so that we have to wait here.
  30       ACE_stat st;
  31       int timeout = 10;
  32       while (--timeout)
  33         {
  34           if (ACE_OS::stat (this->input_, &st) == 0 &&
  35               st.st_size != 0)
  36             {
  37               break;
  38             }
  39
  40           ACE_OS::sleep (1);
  41         }
  42
  43       ACE_TString infile = ACE_TString (ACE_TEXT("file://")) + this->input_;
  44
  45       CORBA::Object_var object =
  46         this->corb_->string_to_object (infile.c_str ());
  47
  48       Bug1495_Regression::Bug1495_var server =
  49         Bug1495_Regression::Bug1495::_narrow (object.in ());
  50
  51       if (CORBA::is_nil (server.in ()))
  52         {
  53           ACE_ERROR ((LM_ERROR,
  54                       "Object reference <%s> is nil\n",
  55                       input_));
  56
  57           return 1;
  58         }
  59
  60       // Try multiple calls to see if we keep being forwarded
  61       for (int i = 0; i < 5; ++i)
  62         {
  63           using Bug1495_Regression::ThreadId;
  64
  65           // call the thread_id function on the test object
  66           ThreadId remote_thread_id;
  67
  68           server->get_thread_id (remote_thread_id);
  69
  70           ACE_DEBUG ((LM_INFO,
  71                       ACE_TEXT ("Remote thread ID was ")
  72                       ACE_INT64_FORMAT_SPECIFIER
  73                       ACE_TEXT ("\n"),
  74                       remote_thread_id));
  75
  76           ThreadId const mythread_id =
  77             ACE_thread_t_to_integer<ThreadId> (ACE_Thread::self ());
  78
  79           if (mythread_id != remote_thread_id)
  80             {
  81               ACE_ERROR ((LM_ERROR,
  82                           ACE_TEXT ("ERROR:  Failed Bug_1495_Regression test. ")
  83                           ACE_TEXT ("Expected thread id was ")
  84                           ACE_INT64_FORMAT_SPECIFIER
  85                           ACE_TEXT (", received ")
  86                           ACE_INT64_FORMAT_SPECIFIER
  87                           ACE_TEXT (".\n"),
  88                           mythread_id,
  89                           remote_thread_id));
  90             }
  91           else
  92             {
  93               ACE_DEBUG ((LM_INFO,
  94                           ACE_TEXT ("Passed Bug_1495_Regression test.\n")
  95                           ACE_TEXT ("Local thread id was ")
  96                           ACE_INT64_FORMAT_SPECIFIER
  97                           ACE_TEXT (", received ")
  98                           ACE_INT64_FORMAT_SPECIFIER
  99                           ACE_TEXT (".\n"),
 100                           mythread_id,
 101                           remote_thread_id));
 102             }
 103         }
 104     }
 105   catch (const CORBA::Exception& ex)
 106     {
 107       ex._tao_print_exception ("Caught exception in client task:");
 108       return 1;
 109     }
 110
 111   return 0;
 112 }