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

   1 #ifndef ROUNDTRIP_HANDLER_H
   2 #define ROUNDTRIP_HANDLER_H
   3 #include /**/ "ace/pre.h"
   4
   5 #include "TestS.h"
   6 #include "ace/Basic_Stats.h"
   7 #include "ace/High_Res_Timer.h"
   8
   9 /// Implement the Test::Roundtrip interface
  10 class Roundtrip_Handler
  11   : public virtual POA_Test::AMI_RoundtripHandler
  12 {
  13 public:
  14   /// Constructor
  15   Roundtrip_Handler (int expected_callbacks);
  16
  17   /// Return the number of pending callbacks
  18   int pending_callbacks () const;
  19
  20   /// Dump the results
  21   void dump_results (ACE_High_Res_Timer::global_scale_factor_type gsf);
  22
  23   // = The skeleton methods for test octet load
  24   virtual void test_octet_method (Test::Timestamp send_time);
  25
  26   virtual void test_octet_method_excep (::Messaging::ExceptionHolder *holder);
  27
  28   // = The skeleton methods for test char load
  29   virtual void test_char_method (Test::Timestamp send_time);
  30   virtual void test_char_method_excep (::Messaging::ExceptionHolder *holder);
  31
  32   // = The skeleton methods for test long load
  33   virtual void test_long_method  (Test::Timestamp send_time);
  34   virtual void test_long_method_excep (::Messaging::ExceptionHolder *holder);
  35
  36   // = The skeleton methods for test short load
  37   virtual void test_short_method (Test::Timestamp send_time);
  38   virtual void test_short_method_excep (::Messaging::ExceptionHolder *holder);
  39
  40   // = The skeleton methods for test longlong load
  41   virtual void test_longlong_method (Test::Timestamp send_time);
  42   virtual void test_longlong_method_excep (::Messaging::ExceptionHolder *holder);
  43
  44   // = The skeleton methods for test double load
  45   virtual void test_double_method (Test::Timestamp send_time);
  46   virtual void test_double_method_excep (::Messaging::ExceptionHolder *holder);
  47
  48   // = Other methods
  49
  50   virtual void shutdown ();
  51   virtual void shutdown_excep (::Messaging::ExceptionHolder *holder);
  52
  53 private:
  54   /// The number of callbacks not received yet
  55   int pending_callbacks_;
  56
  57   /// Collect the latency results
  58   ACE_Basic_Stats latency_stats_;
  59 };
  60
  61 #include /**/ "ace/post.h"
  62 #endif /* ROUNDTRIP_H */