TAO/performance-tests/Sequence_Latency/AMI/Roundtrip_Handler.cpp

   1 #include "Roundtrip_Handler.h"
   2 #include "ace/OS_NS_time.h"
   3
   4 Roundtrip_Handler::Roundtrip_Handler (int expected_callbacks)
   5   : pending_callbacks_ (expected_callbacks)
   6 {
   7 }
   8
   9 int
  10 Roundtrip_Handler::pending_callbacks () const
  11 {
  12   return this->pending_callbacks_;
  13 }
  14
  15 void
  16 Roundtrip_Handler::dump_results (
  17   ACE_High_Res_Timer::global_scale_factor_type gsf)
  18 {
  19   this->latency_stats_.dump_results (ACE_TEXT("AMI Latency"), gsf);
  20 }
  21
  22 // = The skeleton methods for test octet load
  23
  24 void
  25 Roundtrip_Handler::test_octet_method (Test::Timestamp send_time)
  26 {
  27   --this->pending_callbacks_;
  28
  29   ACE_hrtime_t now = ACE_OS::gethrtime ();
  30   this->latency_stats_.sample (now - send_time);
  31 }
  32
  33 void
  34 Roundtrip_Handler::test_octet_method_excep (::Messaging::ExceptionHolder *holder)
  35 {
  36   try
  37     {
  38       --this->pending_callbacks_;
  39       holder->raise_exception ();
  40     }
  41   catch (const CORBA::Exception& ex)
  42     {
  43       ex._tao_print_exception ("test_octet_method:");
  44     }
  45 }
  46
  47 // = The skeleton methods for test char load
  48
  49 void
  50 Roundtrip_Handler::test_char_method (Test::Timestamp send_time)
  51 {
  52   --this->pending_callbacks_;
  53
  54   ACE_hrtime_t now = ACE_OS::gethrtime ();
  55   this->latency_stats_.sample (now - send_time);
  56 }
  57
  58 void
  59 Roundtrip_Handler::test_char_method_excep (::Messaging::ExceptionHolder *holder)
  60 {
  61   try
  62     {
  63       --this->pending_callbacks_;
  64       holder->raise_exception ();
  65     }
  66   catch (const CORBA::Exception& ex)
  67     {
  68       ex._tao_print_exception ("test_char_method:");
  69     }
  70 }
  71
  72 // = The skeleton methods for test long load
  73
  74 void
  75 Roundtrip_Handler::test_long_method (Test::Timestamp send_time)
  76 {
  77   --this->pending_callbacks_;
  78
  79   ACE_hrtime_t now = ACE_OS::gethrtime ();
  80   this->latency_stats_.sample (now - send_time);
  81 }
  82
  83 void
  84 Roundtrip_Handler::test_long_method_excep (::Messaging::ExceptionHolder *holder)
  85 {
  86   try
  87     {
  88       --this->pending_callbacks_;
  89       holder->raise_exception ();
  90     }
  91   catch (const CORBA::Exception& ex)
  92     {
  93       ex._tao_print_exception ("test_long_method:");
  94     }
  95 }
  96
  97 // = The skeleton methods for test short load
  98
  99 void
 100 Roundtrip_Handler::test_short_method (Test::Timestamp send_time)
 101 {
 102   --this->pending_callbacks_;
 103
 104   ACE_hrtime_t now = ACE_OS::gethrtime ();
 105   this->latency_stats_.sample (now - send_time);
 106 }
 107
 108 void
 109 Roundtrip_Handler::test_short_method_excep (::Messaging::ExceptionHolder *holder)
 110 {
 111   try
 112     {
 113       --this->pending_callbacks_;
 114       holder->raise_exception ();
 115     }
 116   catch (const CORBA::Exception& ex)
 117     {
 118       ex._tao_print_exception ("test_short_method:");
 119     }
 120 }
 121
 122 // = The skeleton methods for test double load
 123
 124 void
 125 Roundtrip_Handler::test_double_method (Test::Timestamp send_time)
 126 {
 127   --this->pending_callbacks_;
 128
 129   ACE_hrtime_t now = ACE_OS::gethrtime ();
 130   this->latency_stats_.sample (now - send_time);
 131 }
 132
 133 void
 134 Roundtrip_Handler::test_double_method_excep (::Messaging::ExceptionHolder *holder)
 135 {
 136   try
 137     {
 138       --this->pending_callbacks_;
 139       holder->raise_exception ();
 140     }
 141   catch (const CORBA::Exception& ex)
 142     {
 143       ex._tao_print_exception ("test_double_method:");
 144     }
 145 }
 146
 147 // = The skeleton methods for test longlong load
 148
 149 void
 150 Roundtrip_Handler::test_longlong_method (Test::Timestamp send_time)
 151 {
 152   --this->pending_callbacks_;
 153
 154   ACE_hrtime_t now = ACE_OS::gethrtime ();
 155   this->latency_stats_.sample (now - send_time);
 156 }
 157
 158 void
 159 Roundtrip_Handler::test_longlong_method_excep (::Messaging::ExceptionHolder *holder)
 160 {
 161   try
 162     {
 163       --this->pending_callbacks_;
 164       holder->raise_exception ();
 165     }
 166   catch (const CORBA::Exception& ex)
 167     {
 168       ex._tao_print_exception ("test_longlong_method:");
 169     }
 170 }
 171
 172
 173 // = Other methods
 174
 175 void
 176 Roundtrip_Handler::shutdown ()
 177 {
 178 }
 179
 180 void
 181 Roundtrip_Handler::shutdown_excep (::Messaging::ExceptionHolder *holder)
 182 {
 183   try
 184     {
 185       holder->raise_exception ();
 186     }
 187   catch (const CORBA::Exception& ex)
 188     {
 189       ex._tao_print_exception ("shutdown:");
 190     }
 191 }