ACE/ace/Monitor_Control/Windows_Multi_Instance_Monitor.cpp

   1 #include "ace/Monitor_Control/Windows_Multi_Instance_Monitor.h"
   2
   3 #if defined (ACE_HAS_WIN32_PDH)
   4
   5 #include "ace/Log_Category.h"
   6 #include "ace/SString.h"
   7 #include "ace/os_include/os_pdhmsg.h"
   8
   9 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  10
  11 namespace ACE
  12 {
  13   namespace Monitor_Control
  14   {
  15     Windows_Multi_Instance_Monitor::Windows_Multi_Instance_Monitor (
  16       const ACE_TCHAR *wildcard_path)
  17       : value_ (0.0)
  18       , instances_ (0)
  19       , n_instances_ (0)
  20       , status_ (ERROR_SUCCESS)
  21     {
  22       /// Create a string which is a concatentation of the path
  23       /// name of each 'instance' we need to monitor.
  24
  25       DWORD paths_size = 4096;
  26       ACE_LPSTR paths = (ACE_LPSTR) GlobalAlloc (GPTR, paths_size);
  27
  28       this->status_ = ACE_TEXT_PdhExpandCounterPath (wildcard_path,
  29                                                      paths,
  30                                                      &paths_size);
  31
  32       if (PDH_MORE_DATA == static_cast<DWORD> (this->status_))
  33         {
  34           ++paths_size;
  35           GlobalFree (paths);
  36           paths = (ACE_LPSTR) GlobalAlloc (GPTR, paths_size);
  37
  38           this->status_ = ACE_TEXT_PdhExpandCounterPath (wildcard_path,
  39                                                          paths,
  40                                                          &paths_size);
  41         }
  42
  43       if (PDH_CSTATUS_VALID_DATA != static_cast<DWORD> (this->status_))
  44         {
  45           ACELIB_ERROR ((LM_ERROR,
  46                       ACE_TEXT ("%s: PdhExpandCounterPath failed\n"),
  47                       wildcard_path));
  48         }
  49
  50       ACE_LPSTR path = paths;
  51
  52       /// Create a regular Windows monitor for each path name.
  53       while (*path != 0)
  54         {
  55           Windows_Monitor *instance = new Windows_Monitor (path);
  56           this->instances_.enqueue_tail (instance);
  57           path += ACE_OS::strlen (path) + 1;
  58         }
  59
  60       GlobalFree (paths);
  61     }
  62
  63     Windows_Multi_Instance_Monitor::~Windows_Multi_Instance_Monitor ()
  64     {
  65       Windows_Monitor *instance = 0;
  66
  67       /// Destroy the single instance monitors created in the constructor.
  68       while (this->instances_.dequeue_head (instance) == 0)
  69         {
  70           delete instance;
  71         }
  72     }
  73
  74     void
  75     Windows_Multi_Instance_Monitor::update_i ()
  76     {
  77       Windows_Monitor **current_instance = 0;
  78
  79       /// Sum the values of each single instance monitor.
  80       for (INSTANCES_ITERATOR i (this->instances_); !i.done (); i.advance ())
  81         {
  82           i.next (current_instance);
  83
  84           (*current_instance)->update_i ();
  85
  86           this->value_ += (*current_instance)->value_;
  87         }
  88     }
  89
  90     void
  91     Windows_Multi_Instance_Monitor::clear_impl ()
  92     {
  93       Windows_Monitor **current_instance = 0;
  94
  95       /// Sum the values of each single instance monitor.
  96       for (INSTANCES_ITERATOR i (this->instances_); !i.done (); i.advance ())
  97         {
  98           i.next (current_instance);
  99
 100           (*current_instance)->clear_impl ();
 101         }
 102     }
 103   }
 104 }
 105
 106 ACE_END_VERSIONED_NAMESPACE_DECL
 107
 108 #endif /* defined (ACE_HAS_WIN32_PDH) */