TAO/orbsvcs/performance-tests/RTEvent/lib/Send_Task.h

   1 /**
   2  * @file Send_Task.h
   3  *
   4  * @author Carlos O'Ryan <coryan@uci.edu>
   5  */
   6
   7 #ifndef TAO_PERF_RTEC_SEND_TASK_H
   8 #define TAO_PERF_RTEC_SEND_TASK_H
   9
  10 #include "Supplier.h"
  11 #include "ace/Task.h"
  12 #include "ace/Synch_Traits.h"
  13
  14 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  15 # pragma once
  16 #endif /* ACE_LACKS_PRAGMA_ONCE */
  17
  18 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  19 class ACE_Barrier;
  20 ACE_END_VERSIONED_NAMESPACE_DECL
  21
  22 /**
  23  * @class Send_Task
  24  *
  25  * @brief Implement a simple ACE_Task to send the events
  26  */
  27 class TAO_RTEC_Perf_Export Send_Task : public ACE_Task_Base
  28 {
  29 public:
  30   /// Constructor
  31   Send_Task ();
  32
  33   /// This is for compilers that are a PITA complaining that we are
  34   /// hiding something.
  35   virtual int init (int argc, ACE_TCHAR *argv[])
  36   {
  37     return ACE_Task_Base::init (argc, argv);
  38   }
  39
  40   void init (int iterations,
  41              int period_in_usecs,
  42              int startup_sleep,
  43              int event_type,
  44              int event_source,
  45              Supplier *supplier,
  46              ACE_Barrier *barrier);
  47
  48   /// Run the experiment
  49   int svc ();
  50
  51   /// Stop the experiment
  52   void stop ();
  53
  54 private:
  55   int iterations_;
  56
  57   int period_in_usecs_;
  58
  59   int startup_sleep_;
  60
  61   int event_type_;
  62
  63   int event_source_;
  64
  65   PortableServer::Servant_var<Supplier> supplier_;
  66
  67   ACE_Barrier *barrier_;
  68
  69   TAO_SYNCH_MUTEX mutex_;
  70   int stop_;
  71 };
  72
  73
  74 #endif /* TAO_PERF_RTEC_SEND_TASK_H */