TAO/performance-tests/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 void
  23 Roundtrip_Handler::test_method (Test::Timestamp send_time)
  24 {
  25   --this->pending_callbacks_;
  26
  27   ACE_hrtime_t now = ACE_OS::gethrtime ();
  28   this->latency_stats_.sample (now - send_time);
  29 }
  30
  31 void
  32 Roundtrip_Handler::test_method_excep (::Messaging::ExceptionHolder *holder)
  33 {
  34   try
  35     {
  36       --this->pending_callbacks_;
  37       holder->raise_exception ();
  38     }
  39   catch (const CORBA::Exception& ex)
  40     {
  41       ex._tao_print_exception ("test_method:");
  42     }
  43 }
  44
  45 void
  46 Roundtrip_Handler::shutdown ()
  47 {
  48 }
  49
  50 void
  51 Roundtrip_Handler::shutdown_excep (::Messaging::ExceptionHolder *holder)
  52 {
  53   try
  54     {
  55       holder->raise_exception ();
  56     }
  57   catch (const CORBA::Exception& ex)
  58     {
  59       ex._tao_print_exception ("shutdown:");
  60     }
  61 }