TAO/orbsvcs/tests/Notify/lib/Periodic_Supplier.h

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file Periodic_Supplier.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_Tests_PERIODIC_SUPPLIER_H
   9 #define TAO_Notify_Tests_PERIODIC_SUPPLIER_H
  10 #include /**/ "ace/pre.h"
  11
  12 #include "notify_test_export.h"
  13
  14 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  15 # pragma once
  16 #endif /* ACE_LACKS_PRAGMA_ONCE */
  17
  18 #include "Notify_StructuredPushSupplier.h"
  19 #include "Task_Stats.h"
  20 #include "StructuredEvent.h"
  21 #include "ace/Task.h"
  22 #include "ace/Barrier.h"
  23 #include "ace/Arg_Shifter.h"
  24
  25 class TAO_Notify_Tests_Task_Callback;
  26
  27 /**
  28  * @class TAO_Notify_Tests_Periodic_Supplier
  29  *
  30  * @brief A Periodic Supplier.
  31  */
  32 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_Periodic_Supplier : public TAO_Notify_Tests_StructuredPushSupplier, public ACE_Task <ACE_SYNCH>
  33 {
  34 public:
  35   /// Constructor
  36   TAO_Notify_Tests_Periodic_Supplier ();
  37
  38   /// Destructor
  39   ~TAO_Notify_Tests_Periodic_Supplier ();
  40
  41   /// set the helper callback
  42   void task_callback(TAO_Notify_Tests_Task_Callback* client);
  43
  44   /// Init the state of this object.
  45   int init_state (ACE_Arg_Shifter& arg_shifter);
  46
  47   /// Activate this task, synch on the given barrier.
  48   virtual int activate_task (ACE_Barrier* barrier);
  49
  50   /// task svc
  51   virtual int svc ();
  52
  53   /// Dump stats.
  54   void dump_stats (ACE_TCHAR* msg, int dump_samples);
  55
  56   /// Get the name of the proxy
  57   const char* proxy_name ();
  58
  59 protected:
  60   /// svc method.
  61   void handle_svc ();
  62
  63   /// Send a few events before the actual measurements.
  64   void send_warmup_events ();
  65
  66   /// Send Prologue
  67   void send_prologue ();
  68
  69   /// All tasks synch at this barrier.
  70   ACE_Barrier* barrier_;
  71
  72   /// The event to send.
  73   TAO_Notify_Tests_StructuredEvent event_;
  74
  75   TAO_Notify_Tests_StructuredEvent zeroth_event;
  76
  77   /// The priority of this task.
  78   CORBA::Short priority_;
  79
  80   /// Period
  81   long period_;
  82
  83   /// Counts the total number of deadlines missed.
  84   long total_deadlines_missed_;
  85
  86   /// RunTime - The Max. time to run the supplier.
  87   long run_time_;
  88
  89   /// Worst case exec. time.
  90   unsigned long exec_time_;
  91
  92   /// Phase
  93   long phase_;
  94
  95   /// Number of times to exec. Job
  96   int iter_;
  97
  98   /// A load factor supplied to each Job.
  99   CORBA::ULong load_;
 100
 101   /// Stats house keeping
 102   Task_Stats stats_;
 103
 104   /// Client
 105   TAO_Notify_Tests_Task_Callback* client_;
 106 };
 107
 108 #include /**/ "ace/post.h"
 109 #endif /* TAO_Notify_Tests_PERIODIC_SUPPLIER_H */