TAO/tests/Stack_Recursion/Client_Task.cpp

   1
   2 #include "Client_Task.h"
   3
   4 Client_Task::Client_Task (Test::Sender_ptr sender,
   5                           CORBA::Long event_count,
   6                           CORBA::ULong event_size,
   7                           ACE_Thread_Manager *thr_mgr)
   8   : ACE_Task_Base (thr_mgr)
   9   , sender_ (Test::Sender::_duplicate (sender))
  10   , event_count_ (event_count)
  11   , event_size_ (event_size)
  12 {
  13 }
  14
  15 int
  16 Client_Task::svc (void)
  17 {
  18   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Starting client task\n"));
  19
  20   try
  21     {
  22       this->validate_connections ();
  23
  24       for (int i = 0; i != this->event_count_; ++i)
  25         {
  26 #if 0
  27           if (i%100 == 0)
  28             ACE_DEBUG ((LM_DEBUG,
  29                         "(%P|%t) In iteration [%d] ....\n",
  30                         i));
  31 #endif /*if 0*/
  32           Test::Payload_var pl;
  33           this->sender_->get_data (this->event_size_, pl.out ());
  34         }
  35     }
  36   catch (const CORBA::Exception&)
  37     {
  38       return -1;
  39     }
  40   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Client task finished\n"));
  41   return 0;
  42 }
  43
  44
  45 void
  46 Client_Task::validate_connections (void)
  47 {
  48   for (int i = 0 ; i != 100; i++)
  49     {
  50       try
  51         {
  52           this->sender_->ping ();
  53
  54         }
  55       catch (const CORBA::Exception&){}
  56     }
  57 }