ACE/examples/APG/Naming/Temperature_Monitor2.cpp

   1 #include "ace/OS_NS_time.h"
   2 #include "ace/OS_NS_unistd.h"
   3 #include "ace/Log_Msg.h"
   4
   5 #include "Thermometer.h"
   6 #include "Temperature_Monitor2.h"
   7 #include "EMail.h"
   8
   9 // Listing 1 code/ch21
  10 void Temperature_Monitor2::record_temperature (float temp)
  11 {
  12   Name_Binding_Ptr current
  13     (this->naming_context_.fetch ("current"));
  14   if (current.get ())
  15     {
  16       this->naming_context_.rebind ("previous",
  17                                     current->value ());
  18     }
  19
  20   this->record_history (temp);
  21
  22   this->naming_context_.unbind ("lastFailure");
  23   this->naming_context_.unbind ("lastReset");
  24   this->naming_context_.unbind ("resetCount");
  25 }
  26 // Listing 1
  27
  28 // Listing 2 code/ch21
  29 void Temperature_Monitor2::record_history (float temp)
  30 {
  31   int now = (int)ACE_OS::time ();
  32   this->shared_context_.rebind ("lastUpdate", now);
  33
  34   Name_Binding_Ptr counter
  35     (this->shared_context_.fetch ("counter"));
  36   int counterValue = counter.get () ? counter->int_value () : 0;
  37
  38   char name[BUFSIZ];
  39   ACE_OS::sprintf (name, "history[%d]", counterValue);
  40
  41   char value[BUFSIZ];
  42   ACE_OS::sprintf (value, "%d|%.2f", now, temp);
  43
  44   this->shared_context_.rebind (name, value);
  45
  46   ++counterValue;
  47   counterValue %= this->opt_.history_size ();
  48   this->shared_context_.rebind ("counter", counterValue);
  49 }
  50 // Listing 2
  51
  52 void Temperature_Monitor2::reset_device (Name_Binding_Ptr &resetCount)
  53 {
  54   int number_of_resets = 1;
  55
  56   if (resetCount.get ())
  57     {
  58       number_of_resets = resetCount->int_value () + 1;
  59
  60       if (number_of_resets > this->opt_.excessive_resets ())
  61         {
  62           EMail notification;
  63
  64           char message[BUFSIZ];
  65           ACE_OS::sprintf (message,
  66                            "Thermometer: %s\n"
  67                            "Reset Count: %d\n",
  68                            this->thermometer_->address (),
  69                            number_of_resets);
  70
  71           notification.send (this->opt_.admin_email (),
  72                              this->opt_.email_from (),
  73                              "Excessive number of thermometer resets",
  74                              message);
  75         }
  76     }
  77
  78   this->thermometer_->reset ();
  79
  80   this->naming_context_.rebind ("lastReset", (int)ACE_OS::time ());
  81   this->naming_context_.rebind ("resetCount", number_of_resets);
  82 }
  83
  84 void Temperature_Monitor2::record_failure ()
  85 {
  86   Name_Binding_Ptr lastFailure (this->naming_context_.fetch ("lastFailure"));
  87   Name_Binding_Ptr lastReset (this->naming_context_.fetch ("lastReset"));
  88   Name_Binding_Ptr resetCount (this->naming_context_.fetch ("resetCount"));
  89
  90   int now = (int) ACE_OS::time ();
  91
  92   int lastFailureTime;
  93   int lastResetTime = 0;
  94
  95   if (lastFailure.get ())
  96     {
  97       lastFailureTime = lastFailure->int_value ();
  98     }
  99   else
 100     {
 101       this->naming_context_.rebind ("firstFailure", now);
 102       this->naming_context_.rebind ("lastReset", now);
 103       lastFailureTime = now;
 104       lastResetTime = now;
 105     }
 106
 107   if (lastReset.get ())
 108     {
 109       lastResetTime = lastReset->int_value ();
 110     }
 111
 112   if (now - lastResetTime > this->opt_.reset_interval ())
 113     {
 114       this->reset_device (resetCount);
 115     }
 116
 117   this->naming_context_.rebind ("lastFailure", lastFailureTime);
 118 }
 119
 120 void Temperature_Monitor2::monitor ()
 121 {
 122   this->thermometer_ = new Thermometer (this->opt_.thermometer_address ());
 123
 124   for (;;)
 125     {
 126       float temp = this->thermometer_->temperature ();
 127
 128       ACE_DEBUG ((LM_INFO, ACE_TEXT ("Read temperature %.2f\n"), temp));
 129
 130       if (temp >= 0)
 131         {
 132           this->record_temperature (temp);
 133         }
 134       else
 135         {
 136           this->record_failure ();
 137         }
 138
 139       ACE_OS::sleep (this->opt_.poll_interval ());
 140     }
 141
 142   ACE_NOTREACHED (delete this->thermometer_;)
 143 }