TAO/examples/AMH/Sink_Server/Client_Task.h

   1 // -*- C++ -*-
   2
   3 // =========================================================================
   4 /**
   5  *  @file  Client_Task.h
   6  *
   7  *  @desc  Provides common functionality needed to run a client
   8  *  thread. Also incorporates functionality to collect and print
   9  *  statistics about the test.
  10  *
  11  *  @author Mayur Deshpande <mayur@ics.uci.edu>
  12  */
  13 // =========================================================================
  14
  15 #ifndef MT_CLIENT_TASK_H
  16 #define MT_CLIENT_TASK_H
  17
  18 #include "ace/Task.h"
  19 #include "ace/Basic_Stats.h"
  20 #include "ace/High_Res_Timer.h"
  21
  22 #include "TestC.h"
  23
  24 // Helper class for common client functionality
  25 class Client_Task : public ACE_Task_Base
  26 {
  27 public:
  28   /// Constructor
  29   Client_Task (int &argc, ACE_TCHAR **argv);
  30
  31   int parse_args ();
  32
  33   void try_RT_scheduling ();
  34
  35   int narrow_servant (CORBA::ORB_ptr orb);
  36
  37   int run_test ();
  38
  39 protected:
  40   /// The service method
  41   virtual int svc ();
  42
  43 private:
  44   /// Print Statistics
  45   void accumulate_and_dump (ACE_Basic_Stats &totals,
  46                             const ACE_TCHAR *msg,
  47                             ACE_High_Res_Timer::global_scale_factor_type gsf);
  48
  49 private:
  50   /// The object reference used for this test
  51   Test::Roundtrip_var roundtrip_;
  52
  53   /// Keep track of the latency (minimum, average, maximum and jitter)
  54   ACE_Basic_Stats latency_;
  55
  56   int &argc_;
  57   ACE_TCHAR **argv_;
  58   const ACE_TCHAR *ior_;
  59   int iterations_;
  60 };
  61
  62 #endif // Client_Task_H