ACE/ace/Monitor_Control/Monitor_Query.cpp

   1 #include "ace/Monitor_Point_Registry.h"
   2 #include "ace/Monitor_Base.h"
   3 #include "ace/Monitor_Control_Action.h"
   4
   5 #include "ace/Monitor_Control/Monitor_Query.h"
   6 #include "ace/Monitor_Control/Constraint_Interpreter.h"
   7 #include "ace/Monitor_Control/Constraint_Visitor.h"
   8
   9 #if defined (ACE_HAS_MONITOR_FRAMEWORK) && (ACE_HAS_MONITOR_FRAMEWORK == 1)
  10
  11 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  12
  13 namespace ACE
  14 {
  15   namespace Monitor_Control
  16   {
  17     Monitor_Point_Auto_Query::Monitor_Point_Auto_Query ()
  18     {
  19     }
  20
  21     int
  22     Monitor_Point_Auto_Query::handle_timeout (
  23       const ACE_Time_Value& /* current */,
  24       const void* monitor_query)
  25     {
  26       const Monitor_Query* const_mq =
  27         reinterpret_cast<const Monitor_Query*> (monitor_query);
  28
  29       Monitor_Query* mq = const_cast<Monitor_Query*> (const_mq);
  30
  31       mq->query ();
  32
  33       return 0;
  34     }
  35
  36     //=========================================================
  37
  38     Monitor_Query::Monitor_Query (const char* monitor_name)
  39       : monitor_ (0)
  40     {
  41       ACE_CString name_str (monitor_name, 0, false);
  42       this->monitor_ = Monitor_Point_Registry::instance ()->get (name_str);
  43
  44       if (this->monitor_ == 0)
  45         {
  46           ACELIB_ERROR ((LM_ERROR, "Monitor_Query - monitor lookup failed\n"));
  47         }
  48     }
  49
  50     void
  51     Monitor_Query::query ()
  52     {
  53       if (this->monitor_ == 0)
  54         {
  55           ACELIB_ERROR ((LM_ERROR, "Monitor_Query::query - null monitor\n"));
  56           return;
  57         }
  58
  59       Monitor_Base::CONSTRAINTS& list = this->monitor_->constraints ();
  60
  61       for (Monitor_Base::CONSTRAINT_ITERATOR i (list.begin ());
  62            i != list.end ();
  63            ++i)
  64         {
  65           Constraint_Interpreter interpreter;
  66           interpreter.build_tree (i->second.expr.fast_rep ());
  67
  68           Monitor_Control_Types::Data data (this->monitor_->type ());
  69           this->monitor_->retrieve (data);
  70           Constraint_Visitor visitor (data);
  71           bool satisfied = interpreter.evaluate (visitor);
  72
  73           if (satisfied && i->second.control_action != 0)
  74             {
  75               i->second.control_action->execute ();
  76             }
  77         }
  78     }
  79   }
  80 }
  81
  82 ACE_END_VERSIONED_NAMESPACE_DECL
  83
  84 #endif /* ACE_HAS_MONITOR_FRAMEWORK==1 */