TAO/tests/Client_Leaks/Client_Task.cpp

   1
   2 #include "Client_Task.h"
   3
   4 Client_Task::Client_Task (Test::Process_Factory_ptr process_factory,
   5                           int iterations)
   6   : process_factory_ (Test::Process_Factory::_duplicate (process_factory))
   7   , iterations_ (iterations)
   8   , successful_calls_ (0)
   9 {
  10 }
  11
  12 int
  13 Client_Task::successful_calls () const
  14 {
  15   return this->successful_calls_;
  16 }
  17
  18 int
  19 Client_Task::svc ()
  20 {
  21   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Starting client task\n"));
  22
  23   int successful_calls = 0;
  24
  25   try
  26     {
  27       this->validate_connection ();
  28
  29       for (int i = 0; i != this->iterations_; ++i)
  30         {
  31           int retval = this->one_iteration ();
  32
  33           if (retval != 0)
  34             successful_calls++;
  35
  36           if (i % 10 == 0)
  37             {
  38               ACE_DEBUG ((LM_DEBUG,
  39                           "(%P|%t) - Client_Task::svc %d / %d iterations\n",
  40                           i, this->iterations_));
  41             }
  42         }
  43     }
  44   catch (const CORBA::Exception& ex)
  45     {
  46       ex._tao_print_exception ("Exception caught:");
  47       return -1;
  48     }
  49   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Client task finished\n"));
  50
  51   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->mutex_, -1);
  52   this->successful_calls_ += successful_calls;
  53
  54   return 0;
  55 }
  56
  57 void
  58 Client_Task::validate_connection ()
  59 {
  60   try
  61     {
  62       for (int i = 0; i != 100; ++i)
  63         {
  64           (void) this->process_factory_->noop ();
  65         }
  66     }
  67   catch (const CORBA::TRANSIENT& )
  68     {
  69       // Ignore transient exceptions
  70     }
  71 }
  72
  73 int
  74 Client_Task::one_iteration ()
  75 {
  76   try
  77     {
  78       Test::Process_var process =
  79         this->process_factory_->create_new_process ();
  80
  81       (void) process->get_process_id ();
  82
  83       process->shutdown ();
  84
  85       return 1;
  86     }
  87   catch (const Test::Spawn_Failed& )
  88     {
  89       // Ignore this exception, it is usually caused by a transient
  90       // condition
  91     }
  92   catch (const CORBA::Exception& ex)
  93     {
  94       ex._tao_print_exception ("Exception caught:");
  95     }
  96
  97   return 0;
  98 }