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 int
  24 Client_Task::svc ()
  25 {
  26   try
  27     {
  28       // The test was designed so that we have to wait here.
  29       ACE_stat st;
  30       int timeout = 10;
  31       while (--timeout)
  32         {
  33           if (ACE_OS::stat (this->input_, &st) == 0 &&
  34               st.st_size != 0)
  35             {
  36               break;
  37             }
  38
  39           ACE_OS::sleep (1);
  40         }
  41
  42       ACE_TString infile = ACE_TString (ACE_TEXT("file://")) + this->input_;
  43
  44       CORBA::Object_var object =
  45         this->corb_->string_to_object (infile.c_str ());
  46
  47       Bug1495_Regression::Bug1495_var server =
  48         Bug1495_Regression::Bug1495::_narrow (object.in ());
  49
  50       if (CORBA::is_nil (server.in ()))
  51         {
  52           ACE_ERROR ((LM_ERROR,
  53                       "Object reference <%s> is nil\n",
  54                       input_));
  55
  56           return 1;
  57         }
  58
  59       // Try multiple calls to see if we keep being forwarded
  60       for (int i = 0; i < 5; ++i)
  61         {
  62           using Bug1495_Regression::ThreadId;
  63
  64           // call the thread_id function on the test object
  65           ThreadId remote_thread_id;
  66
  67           server->get_thread_id (remote_thread_id);
  68
  69           ACE_DEBUG ((LM_INFO,
  70                       ACE_TEXT ("Remote thread ID was ")
  71                       ACE_INT64_FORMAT_SPECIFIER
  72                       ACE_TEXT ("\n"),
  73                       remote_thread_id));
  74
  75           ThreadId const mythread_id =
  76             ACE_thread_t_to_integer<ThreadId> (ACE_Thread::self ());
  77
  78           if (mythread_id != remote_thread_id)
  79             {
  80               ACE_ERROR ((LM_ERROR,
  81                           ACE_TEXT ("ERROR:  Failed Bug_1495_Regression test. ")
  82                           ACE_TEXT ("Expected thread id was ")
  83                           ACE_INT64_FORMAT_SPECIFIER
  84                           ACE_TEXT (", received ")
  85                           ACE_INT64_FORMAT_SPECIFIER
  86                           ACE_TEXT (".\n"),
  87                           mythread_id,
  88                           remote_thread_id));
  89             }
  90           else
  91             {
  92               ACE_DEBUG ((LM_INFO,
  93                           ACE_TEXT ("Passed Bug_1495_Regression test.\n")
  94                           ACE_TEXT ("Local thread id was ")
  95                           ACE_INT64_FORMAT_SPECIFIER
  96                           ACE_TEXT (", received ")
  97                           ACE_INT64_FORMAT_SPECIFIER
  98                           ACE_TEXT (".\n"),
  99                           mythread_id,
 100                           remote_thread_id));
 101             }
 102         }
 103     }
 104   catch (const CORBA::Exception& ex)
 105     {
 106       ex._tao_print_exception ("Caught exception in client task:");
 107       return 1;
 108     }
 109
 110   return 0;
 111 }