TAO/performance-tests/Latency/Thread_Per_Connection/Client_Task.cpp

   1 #include "Client_Task.h"
   2 #include "ace/OS_NS_time.h"
   3
   4 Client_Task::Client_Task (Test::Roundtrip_ptr roundtrip,
   5                           int niterations)
   6   : roundtrip_ (Test::Roundtrip::_duplicate (roundtrip))
   7   , niterations_ (niterations)
   8 {
   9 }
  10
  11 int
  12 Client_Task::svc ()
  13 {
  14   try
  15     {
  16       this->validate_connection ();
  17
  18       for (int i = 0; i != this->niterations_; ++i)
  19         {
  20           ACE_hrtime_t start = ACE_OS::gethrtime ();
  21
  22           (void) this->roundtrip_->test_method (start);
  23
  24           ACE_hrtime_t now = ACE_OS::gethrtime ();
  25           this->latency_.sample (now - start);
  26         }
  27     }
  28   catch (const CORBA::Exception&)
  29     {
  30       return 0;
  31     }
  32   return 0;
  33 }
  34
  35 void
  36 Client_Task::accumulate_and_dump (
  37   ACE_Basic_Stats &totals,
  38   const ACE_TCHAR *msg,
  39   ACE_High_Res_Timer::global_scale_factor_type gsf)
  40 {
  41   totals.accumulate (this->latency_);
  42   this->latency_.dump_results (msg, gsf);
  43 }
  44
  45 void
  46 Client_Task::validate_connection ()
  47 {
  48   CORBA::ULongLong dummy = 0;
  49   for (int i = 0; i != 100; ++i)
  50     {
  51       try
  52         {
  53           (void) this->roundtrip_->test_method (dummy);
  54         }
  55       catch (const CORBA::Exception&){}
  56     }
  57 }