ACE/examples/Monitor/Memory_Usage/memory_usage.cpp

   1 #include "ace/OS_NS_unistd.h"
   2
   3 #include "ace/Monitor_Control/Monitor_Control.h"
   4
   5 #include "examples/Monitor/MC_Test_Utilities.h"
   6
   7 #if defined (ACE_HAS_MONITOR_FRAMEWORK) && (ACE_HAS_MONITOR_FRAMEWORK == 1)
   8
   9 /// Subclass of ACE_Task_Base, meaning that the override of
  10 /// the svc() method below will run in a new thread when
  11 /// activate() is called on a class instance.
  12 class Monitor_Checker : public ACE_Task_Base
  13 {
  14 public:
  15   int svc ()
  16   {
  17     /// Get an instance of the MC service singleton.
  18     MC_ADMINMANAGER* mgr =
  19       ACE_Dynamic_Service<MC_ADMINMANAGER>::instance ("MC_ADMINMANAGER");
  20
  21     /// Call on the administrator class to look up the desired monitors.
  22     ACE::Monitor_Control::Monitor_Base *memory_monitor =
  23       mgr->admin ().monitor_point ("OS/Memory/TotalUsage");
  24
  25     if (memory_monitor != 0)
  26       {
  27         /// Query each monitor for its data every 2 seconds, and call the
  28         /// appropriate display function.
  29         for (int i = 0; i < 10; ++i)
  30           {
  31             ACE_OS::sleep (2);
  32
  33             Monitor_Control_Types::Data data (memory_monitor->type ());
  34             memory_monitor->retrieve (data);
  35             MC_Test_Utilities::display_memory_usage (data);
  36           }
  37
  38         memory_monitor->remove_ref ();
  39       }
  40
  41     return 0;
  42   }
  43 };
  44
  45 #endif /* ACE_HAS_MONITOR_FRAMEWORK==1 */
  46
  47 int
  48 ACE_TMAIN (int /* argc */, ACE_TCHAR * /* argv */ [])
  49 {
  50 #if defined (ACE_HAS_MONITOR_FRAMEWORK) && (ACE_HAS_MONITOR_FRAMEWORK == 1)
  51
  52   /// Set the timer for memory usage check at 2 sec.
  53   Monitor_Base *memory_usage_monitor =
  54     create_os_monitor<MEMORY_USAGE_MONITOR> (0, ACE_Time_Value (2));
  55
  56   /// Runs the reactor's event loop in a separate thread so the timer(s)
  57   /// can run concurrently with the application.
  58   START_PERIODIC_MONITORS;
  59
  60   /// Run the monitor checker in a separate thread.
  61   Monitor_Checker monitor_checker;
  62   monitor_checker.activate ();
  63
  64   char * str_array[5] = {0};
  65
  66   for (int i = 0; i < 10; ++i)
  67     {
  68       ACE_OS::sleep (2);
  69
  70       /// Allocate a large string in each of the first 5 loops,
  71       /// free them in the last 5 loops.
  72       if (i < 5)
  73         {
  74           str_array[i] = new char[1024*1024*10];
  75         }
  76       else
  77         {
  78           delete [] str_array[i - 5];
  79         }
  80     }
  81
  82   /// End the reactor's event loop, stopping the timer(s).
  83   STOP_PERIODIC_MONITORS;
  84
  85   memory_usage_monitor->remove_ref ();
  86
  87 #endif /* ACE_HAS_MONITOR_FRAMEWORK==1 */
  88
  89   return 0;
  90 }
  91