TAO/performance-tests/Sequence_Latency/Thread_Pool/Client_Task.cpp

   1 #include "Client_Task.h"
   2 #include "ace/OS_NS_time.h"
   3
   4 Client_Task::Client_Task (const ACE_TCHAR *data_type,
   5                           int size,
   6                           Test::Roundtrip_ptr roundtrip,
   7                           int niterations)
   8   : data_type_ (data_type)
   9   , size_ (size)
  10   , roundtrip_ (Test::Roundtrip::_duplicate (roundtrip))
  11   , niterations_ (niterations)
  12 {
  13 }
  14
  15 int
  16 Client_Task::svc ()
  17 {
  18   try
  19     {
  20       this->validate_connection ();
  21
  22       if (ACE_OS::strcmp (this->data_type_, ACE_TEXT("octet")) == 0 )
  23         {
  24           this->test_octet_seq ();
  25         }
  26       if (ACE_OS::strcmp (this->data_type_, ACE_TEXT("long")) == 0 )
  27         {
  28           this->test_long_seq ();
  29         }
  30       if (ACE_OS::strcmp (this->data_type_, ACE_TEXT("short")) == 0 )
  31         {
  32           this->test_short_seq ();
  33         }
  34       if (ACE_OS::strcmp (this->data_type_, ACE_TEXT("char")) == 0 )
  35         {
  36           this->test_char_seq ();
  37         }
  38       if (ACE_OS::strcmp (this->data_type_, ACE_TEXT("longlong")) == 0 )
  39         {
  40           this->test_longlong_seq ();
  41         }
  42       if (ACE_OS::strcmp (this->data_type_, ACE_TEXT("double")) == 0 )
  43         {
  44           this->test_double_seq ();
  45         }
  46     }
  47   catch (const CORBA::Exception&)
  48     {
  49       return 0;
  50     }
  51   return 0;
  52 }
  53
  54 void
  55 Client_Task::accumulate_and_dump (
  56   ACE_Basic_Stats &totals,
  57   const ACE_TCHAR *msg,
  58   ACE_High_Res_Timer::global_scale_factor_type gsf)
  59 {
  60   totals.accumulate (this->latency_);
  61   this->latency_.dump_results (msg, gsf);
  62 }
  63
  64 void
  65 Client_Task::validate_connection ()
  66 {
  67   CORBA::ULongLong dummy = 0;
  68   Test::octet_load oc;
  69
  70   for (int i = 0; i != 100; ++i)
  71     {
  72       try
  73         {
  74           (void) this->roundtrip_->test_octet_method (oc, dummy);
  75         }
  76       catch (const CORBA::Exception&){}
  77     }
  78 }
  79
  80 void
  81 Client_Task::test_octet_seq ()
  82 {
  83   Test::octet_load ol (this->size_);
  84   ol.length (this->size_);
  85
  86   for (int i = 0; i != this->niterations_; ++i)
  87     {
  88       ACE_hrtime_t start = ACE_OS::gethrtime ();
  89
  90       (void) this->roundtrip_->test_octet_method (ol, start);
  91
  92       ACE_hrtime_t now = ACE_OS::gethrtime ();
  93       this->latency_.sample (now - start);
  94     }
  95 }
  96
  97 void
  98 Client_Task::test_long_seq ()
  99 {
 100   Test::long_load ll (this->size_);
 101   ll.length (this->size_);
 102
 103   for (int i = 0; i != this->niterations_; ++i)
 104     {
 105       ACE_hrtime_t start = ACE_OS::gethrtime ();
 106
 107       (void) this->roundtrip_->test_long_method (ll, start);
 108
 109       ACE_hrtime_t now = ACE_OS::gethrtime ();
 110       this->latency_.sample (now - start);
 111     }
 112 }
 113
 114
 115 void
 116 Client_Task::test_short_seq ()
 117 {
 118   Test::short_load sl (this->size_);
 119   sl.length (this->size_);
 120
 121   for (int i = 0; i != this->niterations_; ++i)
 122     {
 123       ACE_hrtime_t start = ACE_OS::gethrtime ();
 124
 125       (void) this->roundtrip_->test_short_method (sl, start);
 126
 127       ACE_hrtime_t now = ACE_OS::gethrtime ();
 128       this->latency_.sample (now - start);
 129     }
 130 }
 131
 132 void
 133 Client_Task::test_char_seq ()
 134 {
 135   Test::char_load cl (this->size_);
 136   cl.length (this->size_);
 137
 138   for (int i = 0; i != this->niterations_; ++i)
 139     {
 140       ACE_hrtime_t start = ACE_OS::gethrtime ();
 141
 142       (void) this->roundtrip_->test_char_method (cl, start);
 143
 144       ACE_hrtime_t now = ACE_OS::gethrtime ();
 145       this->latency_.sample (now - start);
 146     }
 147 }
 148
 149 void
 150 Client_Task::test_longlong_seq ()
 151 {
 152   Test::longlong_load ll (this->size_);
 153   ll.length (this->size_);
 154
 155   for (int i = 0; i != this->niterations_; ++i)
 156     {
 157       ACE_hrtime_t start = ACE_OS::gethrtime ();
 158
 159       (void) this->roundtrip_->test_longlong_method (ll, start);
 160
 161       ACE_hrtime_t now = ACE_OS::gethrtime ();
 162       this->latency_.sample (now - start);
 163     }
 164 }
 165
 166 void
 167 Client_Task::test_double_seq ()
 168 {
 169   Test::double_load dl (this->size_);
 170   dl.length (this->size_);
 171
 172   for (int i = 0; i != this->niterations_; ++i)
 173     {
 174       ACE_hrtime_t start = ACE_OS::gethrtime ();
 175
 176       (void) this->roundtrip_->test_double_method (dl, start);
 177
 178       ACE_hrtime_t now = ACE_OS::gethrtime ();
 179       this->latency_.sample (now - start);
 180     }
 181 }