ACE/tests/Upgradable_RW_Test.h

   1
   2 //=============================================================================
   3 /**
   4  *  @file    Upgradable_RW_Test.h
   5  *
   6  *  It is only used by Upgradable_RW_Test.cpp.
   7  *
   8  *  @author Michael Kircher <mk1@cs.wustl.edu>
   9  */
  10 //=============================================================================
  11
  12
  13 #ifndef ACE_TESTS_UPGRADABLE_RW_TEST_H
  14 #define ACE_TESTS_UPGRADABLE_RW_TEST_H
  15
  16 #include "test_config.h"
  17 #include "ace/Barrier.h"
  18
  19 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  20 # pragma once
  21 #endif /* ACE_LACKS_PRAGMA_ONCE */
  22
  23 #include "ace/Task.h"
  24 #include "ace/Thread.h"
  25 #include "ace/Thread_Manager.h"
  26 #include "ace/Get_Opt.h"
  27 #include "ace/SString.h"
  28 #include "ace/Profile_Timer.h"
  29
  30 class Element;
  31
  32   /**
  33    * @class Element
  34    *
  35    * @brief The members for the double linked list.
  36    */
  37 class Element
  38 {
  39   friend class ACE_Double_Linked_List<Element>;
  40   friend class ACE_Double_Linked_List_Iterator_Base<Element>;
  41   friend class ACE_Double_Linked_List_Iterator<Element>;
  42   friend class ACE_Double_Linked_List_Reverse_Iterator<Element>;
  43
  44 public:
  45   Element (ACE_CString *item = 0,
  46            Element *p = 0,
  47            Element *n = 0)
  48     : prev_ (p),
  49       next_(n),
  50       item_(item)
  51   {
  52   }
  53
  54   ACE_CString *value ()
  55   {
  56     return this->item_;
  57   }
  58
  59 private:
  60   Element *prev_;
  61   Element *next_;
  62   ACE_CString *item_;
  63 };
  64
  65 typedef ACE_Double_Linked_List<Element> Linked_List;
  66
  67 /**
  68  * @class Time_Calculation
  69  *
  70  * @brief class to do time calculations thread safe
  71  */
  72 class Time_Calculation
  73 {
  74 public:
  75   Time_Calculation ()
  76     : reported_times_ (0)
  77   {
  78     times_.real_time = 0;
  79     times_.user_time = 0;
  80     times_.system_time = 0;
  81   }
  82
  83   /// take the time of the thread and add it to
  84   void report_time (ACE_Profile_Timer::ACE_Elapsed_Time &elapsed_time);
  85
  86   void print_stats ();
  87
  88 private:
  89   /// add the times incrementally
  90   ACE_Profile_Timer::ACE_Elapsed_Time times_;
  91
  92   /// protect the time
  93   ACE_SYNCH_MUTEX mutex_;
  94
  95   /// count how many threads gave me the elapsed_time
  96   unsigned int reported_times_;
  97 };
  98
  99 /**
 100  * @class Reader_Task
 101  *
 102  * @brief A Task for readers
 103  */
 104 class Reader_Task : public ACE_Task_Base
 105 {
 106 public:
 107   Reader_Task (Time_Calculation &time_Calculation,
 108                ACE_Barrier &barrier)
 109     : time_Calculation_ (time_Calculation),
 110       barrier_(barrier)
 111   {
 112   };
 113
 114   virtual int svc ();
 115
 116 private:
 117   /// keep a reference to the time calculation class
 118   Time_Calculation &time_Calculation_;
 119
 120   /// keep this reference for the barrier, in order
 121   /// to allow a "nice" start
 122   ACE_Barrier &barrier_;
 123 };
 124
 125 /**
 126  * @class Writer_Task
 127  *
 128  * @brief A Task for wirters.
 129  */
 130 class Writer_Task : public ACE_Task_Base
 131 {
 132 public:
 133   Writer_Task (Time_Calculation &time_Calculation,
 134                ACE_Barrier &barrier)
 135     : time_Calculation_ (time_Calculation),
 136       barrier_(barrier)
 137   {
 138   };
 139
 140   virtual int svc ();
 141
 142 private:
 143   /// keep a reference to the time calculation class
 144   Time_Calculation &time_Calculation_;
 145
 146   /// keep this reference for the barrier, in order
 147   /// to allow a "nice" start
 148   ACE_Barrier &barrier_;
 149 };
 150
 151 #endif /* ACE_TESTS_UPGRADABLE_RW_TEST_H */