ACE/examples/APG/Reactor/Timer_State_Data.cpp

   1 /**
   2  * Reactor examples
   3  *
   4  * Timers & state data
   5  */
   6
   7 #include "ace/OS_NS_time.h"
   8 #include "ace/Log_Msg.h"
   9 #include "ace/Reactor.h"
  10 #include "ace/Event_Handler.h"
  11
  12 // Listing 0 code/ch07
  13 class TemperatureSensor
  14 {
  15 public:
  16   TemperatureSensor (const char *location)
  17     : location_(location),
  18       count_(0),
  19       temperature_(0.0)
  20     // ...
  21   { }
  22
  23   const char *location () const
  24   {
  25     return this->location_;
  26   }
  27
  28   int querySensor ()
  29   {
  30     // ...
  31     return ++this->count_;
  32   }
  33
  34   float temperature () const
  35   {
  36     return this->temperature_;
  37   }
  38
  39 private:
  40   const char *location_;
  41   int count_;
  42   float temperature_;
  43   // ...
  44 };
  45 // Listing 0
  46
  47 // Listing 1 code/ch07
  48 class TemperatureQueryHandler : public ACE_Event_Handler
  49 {
  50 public:
  51   TemperatureQueryHandler ()
  52     : ACE_Event_Handler(),
  53       counter_(0),
  54       averageTemperature_(0.0)
  55     // ...
  56   {
  57   }
  58
  59   int handle_timeout (const ACE_Time_Value &current_time,
  60                       const void *arg)
  61   {
  62     time_t epoch = ((timespec_t)current_time).tv_sec;
  63
  64     const TemperatureSensor *const_sensor =
  65       reinterpret_cast<const TemperatureSensor *> (arg);
  66     TemperatureSensor *sensor =
  67       const_cast<TemperatureSensor *> (const_sensor);
  68
  69     int queryCount = sensor->querySensor ();
  70     this->updateAverageTemperature (sensor);
  71
  72     ACE_DEBUG ((LM_INFO,
  73                 ACE_TEXT ("%s\t")
  74                 ACE_TEXT ("%d/%d\t")
  75                 ACE_TEXT ("%.2f/%.2f\t")
  76                 ACE_TEXT ("%s\n"),
  77                 sensor->location (),
  78                 ++this->counter_,
  79                 queryCount,
  80                 this->averageTemperature_,
  81                 sensor->temperature (),
  82                 ACE_OS::ctime(&epoch)));
  83     return 0;
  84   }
  85
  86 private:
  87   void updateAverageTemperature (TemperatureSensor *)
  88   {
  89     // ...
  90   }
  91
  92   int counter_;
  93   float averageTemperature_;
  94 };
  95 // Listing 1
  96
  97 // Create a SIGINT handler so that we can exit
  98 // the program politely
  99 class SigintHandler : public ACE_Event_Handler
 100 {
 101 public:
 102   int handle_signal (int signum, siginfo_t * = 0, ucontext_t * = 0)
 103   {
 104     if (signum == SIGINT)
 105       {
 106         ACE_Reactor::instance ()->end_reactor_event_loop ();
 107       }
 108     return 0;
 109   }
 110 };
 111
 112 int ACE_TMAIN (int, ACE_TCHAR *[])
 113 {
 114   // Listing 2 code/ch07
 115   TemperatureQueryHandler *temperatureMonitor =
 116     new TemperatureQueryHandler ();
 117   // Listing 2
 118
 119   ACE_Time_Value initialDelay (3);
 120   ACE_Time_Value intervalOne (5);
 121   // Listing 3 code/ch07
 122   TemperatureSensor *sensorOne =
 123     new TemperatureSensor ("Kitchen");
 124
 125   ACE_Reactor::instance ()->schedule_timer (temperatureMonitor,
 126                                             sensorOne,
 127                                             initialDelay,
 128                                             intervalOne);
 129   // Listing 3
 130
 131   ACE_Time_Value intervalTwo (4);
 132   // Listing 4 code/ch07
 133   TemperatureSensor *sensorTwo =
 134     new TemperatureSensor ("Foyer");
 135
 136   ACE_Reactor::instance ()->schedule_timer (temperatureMonitor,
 137                                             sensorTwo,
 138                                             initialDelay,
 139                                             intervalTwo);
 140   // Listing 4
 141
 142   SigintHandler *handleExit = new SigintHandler ();
 143
 144   ACE_Reactor::instance ()->register_handler (SIGINT,
 145                                               handleExit);
 146
 147   ACE_Reactor::instance ()->run_reactor_event_loop ();
 148
 149   return 0;
 150 }