ACE/examples/Monitor/Constraint/constraint.cpp

   1 #include "ace/OS_NS_unistd.h"
   2 #include "ace/Monitor_Control_Action.h"
   3
   4 #include "ace/Monitor_Control/Monitor_Control.h"
   5
   6 #include "examples/Monitor/MC_Test_Utilities.h"
   7
   8 #if defined (ACE_HAS_MONITOR_FRAMEWORK) && (ACE_HAS_MONITOR_FRAMEWORK == 1)
   9
  10 using namespace ACE_VERSIONED_NAMESPACE_NAME::ACE::Monitor_Control;
  11
  12 /// Two control actions that will be associated with two different
  13 /// constraints on the same monitor.
  14
  15 class Trigger8k : public Control_Action
  16 {
  17   virtual void execute (const char* /* command */)
  18   {
  19     ACE_DEBUG ((LM_DEBUG, "Total bytes received is above 8k\n"));
  20   }
  21 };
  22
  23 class Trigger16k : public Control_Action
  24 {
  25   virtual void execute (const char* /* command */)
  26   {
  27     ACE_DEBUG ((LM_DEBUG, "Total bytes received is above 16k\n"));
  28   }
  29 };
  30
  31 /// Subclass of ACE_Task_Base, meaning that the override of
  32 /// the svc() method below will run in a new thread when
  33 /// activate() is called on a class instance.
  34 class Monitor_Checker : public ACE_Task_Base
  35 {
  36 public:
  37   int svc ()
  38   {
  39     /// Get an instance of the MC service singleton.
  40     MC_ADMINMANAGER* mgr =
  41       ACE_Dynamic_Service<MC_ADMINMANAGER>::instance ("MC_ADMINMANAGER");
  42
  43     /// Call on the administrator class to look up the desired monitors.
  44     Monitor_Base *bytes_monitor =
  45       mgr->admin ().monitor_point ("OS/Network/BytesReceived");
  46
  47     if (bytes_monitor != 0)
  48       {
  49         /// Query the monitor for its data every 2 seconds, and call the
  50         /// appropriate display function.
  51         for (int i = 0; i < 10; ++i)
  52           {
  53             ACE_OS::sleep (2);
  54
  55             Monitor_Control_Types::Data data (bytes_monitor->type ());
  56             bytes_monitor->retrieve (data);
  57             MC_Test_Utilities::display_bytes_received (data);
  58           }
  59
  60         bytes_monitor->remove_ref ();
  61       }
  62
  63     return 0;
  64   }
  65 };
  66
  67 #endif /* ACE_HAS_MONITOR_FRAMEWORK==1 */
  68
  69 int
  70 ACE_TMAIN (int /* argc */, ACE_TCHAR * /* argv */ [])
  71 {
  72 #if defined (ACE_HAS_MONITOR_FRAMEWORK) && (ACE_HAS_MONITOR_FRAMEWORK == 1)
  73
  74   /// Set the timer for # of threads check at 2 sec.
  75   Monitor_Base *bytes_monitor =
  76     create_os_monitor<BYTES_RECEIVED_MONITOR> (0, ACE_Time_Value (2));
  77
  78   /// Add two constraints, each with its own triggered action.
  79
  80   Trigger8k *trigger8k = new Trigger8k;
  81   long id8 = bytes_monitor->add_constraint ("value > 8192", trigger8k);
  82
  83   ACE_DEBUG ((LM_DEBUG, "trigger8k id = %d\n", id8));
  84
  85   Trigger16k *trigger16k = new Trigger16k;
  86   long id16 = bytes_monitor->add_constraint ("value > 16384", trigger16k);
  87
  88   ACE_DEBUG ((LM_DEBUG, "trigger16k id = %d\n", id16));
  89
  90   /// Create a query and register it to be called periodically.
  91   Monitor_Query query ("OS/Network/BytesReceived");
  92   Monitor_Point_Auto_Query *auto_query = new Monitor_Point_Auto_Query;
  93   auto_query->reference_counting_policy ().value (
  94     ACE_Event_Handler::Reference_Counting_Policy::ENABLED);
  95   ACE_Event_Handler_var safety (auto_query);
  96   ADD_PERIODIC_QUERY (auto_query, &query, ACE_Time_Value (2));
  97
  98   /// Runs the reactor's event loop in a separate thread so the timer(s)
  99   /// can run concurrently with the application.
 100   START_PERIODIC_MONITORS;
 101
 102   /// Run the monitor checker in a separate thread. This class will
 103   /// fetch the monitor's value directly, and its output will be
 104   /// separate from the output from triggered actions.
 105   Monitor_Checker monitor_checker;
 106   monitor_checker.activate ();
 107
 108   ACE_OS::sleep (20);
 109
 110   /// Can do a remove_ref() on this returned value or on the original
 111   /// control action 'trigger8k', but not on both, since they point to
 112   /// the same thing.
 113   Control_Action *removed_action = bytes_monitor->remove_constraint (id8);
 114   ACE_DEBUG ((LM_DEBUG, "8k trigger removed\n"));
 115
 116   ACE_OS::sleep (5);
 117
 118   /// End the reactor's event loop, stopping the timer(s).
 119   STOP_PERIODIC_MONITORS;
 120
 121   /// Do this instead of 'delete' since they are refcounted.
 122   removed_action->remove_ref ();
 123   trigger16k->remove_ref ();
 124   bytes_monitor->remove_ref ();
 125
 126 #endif /* ACE_HAS_MONITOR_FRAMEWORK==1 */
 127
 128   return 0;
 129 }