CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Classes | Public Member Functions | Private Member Functions | Private Attributes
stor::DQMEventMonitorCollection Class Reference

#include <DQMEventMonitorCollection.h>

Inheritance diagram for stor::DQMEventMonitorCollection:
stor::MonitorCollection

Classes

struct  DQMEventStats
 

Public Member Functions

 DQMEventMonitorCollection (const utils::Duration_t &updateInterval)
 
const MonitoredQuantitygetDQMEventBandwidthMQ () const
 
MonitoredQuantitygetDQMEventBandwidthMQ ()
 
const MonitoredQuantitygetDQMEventSizeMQ () const
 
MonitoredQuantitygetDQMEventSizeMQ ()
 
const MonitoredQuantitygetDroppedDQMEventCountsMQ () const
 
MonitoredQuantitygetDroppedDQMEventCountsMQ ()
 
const MonitoredQuantitygetNumberOfCompleteUpdatesMQ () const
 
MonitoredQuantitygetNumberOfCompleteUpdatesMQ ()
 
const MonitoredQuantitygetNumberOfTopLevelFoldersMQ () const
 
MonitoredQuantitygetNumberOfTopLevelFoldersMQ ()
 
const MonitoredQuantitygetNumberOfUpdatesMQ () const
 
MonitoredQuantitygetNumberOfUpdatesMQ ()
 
const MonitoredQuantitygetNumberOfWrittenTopLevelFoldersMQ () const
 
MonitoredQuantitygetNumberOfWrittenTopLevelFoldersMQ ()
 
const MonitoredQuantitygetServedDQMEventBandwidthMQ () const
 
MonitoredQuantitygetServedDQMEventBandwidthMQ ()
 
const MonitoredQuantitygetServedDQMEventSizeMQ () const
 
MonitoredQuantitygetServedDQMEventSizeMQ ()
 
void getStats (DQMEventStats &stats) const
 
const MonitoredQuantitygetWrittenDQMEventBandwidthMQ () const
 
MonitoredQuantitygetWrittenDQMEventBandwidthMQ ()
 
const MonitoredQuantitygetWrittenDQMEventSizeMQ () const
 
MonitoredQuantitygetWrittenDQMEventSizeMQ ()
 
- Public Member Functions inherited from stor::MonitorCollection
void appendInfoSpaceItems (InfoSpaceItems &)
 
void calculateStatistics (const utils::TimePoint_t &now)
 
 MonitorCollection (const utils::Duration_t &updateInterval)
 
void reset (const utils::TimePoint_t &now)
 
void updateInfoSpaceItems ()
 
virtual ~MonitorCollection ()
 

Private Member Functions

virtual void do_appendInfoSpaceItems (InfoSpaceItems &)
 
virtual void do_calculateStatistics ()
 
virtual void do_reset ()
 
virtual void do_updateInfoSpaceItems ()
 
 DQMEventMonitorCollection (DQMEventMonitorCollection const &)
 
DQMEventMonitorCollectionoperator= (DQMEventMonitorCollection const &)
 

Private Attributes

xdata::Double completeDQMUpdates_
 
MonitoredQuantity dqmEventBandwidth_
 
MonitoredQuantity dqmEventSizes_
 
xdata::Double dqmFoldersPerEP_
 
MonitoredQuantity droppedDQMEventCounts_
 
xdata::UnsignedInteger32 droppedDQMEvents_
 
MonitoredQuantity numberOfCompleteUpdates_
 
MonitoredQuantity numberOfTopLevelFolders_
 
MonitoredQuantity numberOfUpdates_
 
MonitoredQuantity numberOfWrittenTopLevelFolders_
 
xdata::UnsignedInteger32 processedDQMEvents_
 
MonitoredQuantity servedDQMEventBandwidth_
 
MonitoredQuantity servedDQMEventSizes_
 
MonitoredQuantity writtenDQMEventBandwidth_
 
MonitoredQuantity writtenDQMEventSizes_
 

Additional Inherited Members

- Public Types inherited from stor::MonitorCollection
typedef std::vector< std::pair
< std::string,
xdata::Serializable * > > 
InfoSpaceItems
 

Detailed Description

A collection of MonitoredQuantities related to fragments

Author:
mommsen
Revision:
1.9
Date:
2011/04/04 12:03:30

Definition at line 23 of file DQMEventMonitorCollection.h.

Constructor & Destructor Documentation

stor::DQMEventMonitorCollection::DQMEventMonitorCollection ( const utils::Duration_t updateInterval)
explicit

Definition at line 14 of file DQMEventMonitorCollection.cc.

14  :
15  MonitorCollection(updateInterval),
17  dqmEventSizes_(updateInterval, boost::posix_time::seconds(300)),
20  dqmEventBandwidth_(updateInterval, boost::posix_time::seconds(300)),
24  numberOfUpdates_(updateInterval, boost::posix_time::seconds(300)),
27  {}
double seconds()
MonitorCollection(const utils::Duration_t &updateInterval)
stor::DQMEventMonitorCollection::DQMEventMonitorCollection ( DQMEventMonitorCollection const &  )
private

Member Function Documentation

void stor::DQMEventMonitorCollection::do_appendInfoSpaceItems ( InfoSpaceItems infoSpaceItems)
privatevirtual

Reimplemented from stor::MonitorCollection.

Definition at line 105 of file DQMEventMonitorCollection.cc.

References completeDQMUpdates_, dqmFoldersPerEP_, droppedDQMEvents_, and processedDQMEvents_.

106  {
107  infoSpaceItems.push_back(std::make_pair("dqmFoldersPerEP", &dqmFoldersPerEP_));
108  infoSpaceItems.push_back(std::make_pair("processedDQMEvents", &processedDQMEvents_));
109  infoSpaceItems.push_back(std::make_pair("droppedDQMEvents", &droppedDQMEvents_));
110  infoSpaceItems.push_back(std::make_pair("discardedDQMEvents", &droppedDQMEvents_));
111  infoSpaceItems.push_back(std::make_pair("completeDQMUpdates", &completeDQMUpdates_));
112  }
xdata::UnsignedInteger32 droppedDQMEvents_
xdata::UnsignedInteger32 processedDQMEvents_
void stor::DQMEventMonitorCollection::do_calculateStatistics ( )
privatevirtual

Implements stor::MonitorCollection.

Definition at line 50 of file DQMEventMonitorCollection.cc.

References stor::MonitoredQuantity::addSample(), stor::MonitoredQuantity::calculateStatistics(), dqmEventBandwidth_, dqmEventSizes_, droppedDQMEventCounts_, stor::MonitoredQuantity::Stats::getLastValueRate(), stor::MonitoredQuantity::Stats::getSampleCount(), stor::MonitoredQuantity::getStats(), numberOfCompleteUpdates_, numberOfTopLevelFolders_, numberOfUpdates_, numberOfWrittenTopLevelFolders_, servedDQMEventBandwidth_, servedDQMEventSizes_, writtenDQMEventBandwidth_, and writtenDQMEventSizes_.

51  {
53 
57 
58  MonitoredQuantity::Stats stats;
59  dqmEventSizes_.getStats(stats);
60  if (stats.getSampleCount() > 0) {
61  dqmEventBandwidth_.addSample(stats.getLastValueRate());
62  }
64 
66  if (stats.getSampleCount() > 0) {
67  servedDQMEventBandwidth_.addSample(stats.getLastValueRate());
68  }
70 
72  if (stats.getSampleCount() > 0) {
73  writtenDQMEventBandwidth_.addSample(stats.getLastValueRate());
74  }
76 
80 
82  }
void addSample(const double &value=1)
void getStats(Stats &stats) const
void calculateStatistics(const utils::TimePoint_t &currentTime=utils::getCurrentTime())
void stor::DQMEventMonitorCollection::do_reset ( )
privatevirtual

Implements stor::MonitorCollection.

Definition at line 85 of file DQMEventMonitorCollection.cc.

References dqmEventBandwidth_, dqmEventSizes_, droppedDQMEventCounts_, numberOfCompleteUpdates_, numberOfTopLevelFolders_, numberOfUpdates_, numberOfWrittenTopLevelFolders_, stor::MonitoredQuantity::reset(), servedDQMEventBandwidth_, servedDQMEventSizes_, writtenDQMEventBandwidth_, and writtenDQMEventSizes_.

86  {
88 
92 
96 
100 
102  }
void stor::DQMEventMonitorCollection::do_updateInfoSpaceItems ( )
privatevirtual

Reimplemented from stor::MonitorCollection.

Definition at line 115 of file DQMEventMonitorCollection.cc.

References completeDQMUpdates_, stor::DQMEventMonitorCollection::DQMEventStats::dqmEventSizeStats, dqmFoldersPerEP_, stor::DQMEventMonitorCollection::DQMEventStats::droppedDQMEventCountsStats, droppedDQMEvents_, stor::MonitoredQuantity::FULL, stor::MonitoredQuantity::Stats::getSampleCount(), getStats(), stor::MonitoredQuantity::Stats::getValueAverage(), stor::MonitoredQuantity::Stats::getValueSum(), stor::DQMEventMonitorCollection::DQMEventStats::numberOfCompleteUpdatesStats, stor::DQMEventMonitorCollection::DQMEventStats::numberOfUpdatesStats, processedDQMEvents_, and stor::MonitoredQuantity::RECENT.

116  {
117  DQMEventMonitorCollection::DQMEventStats stats;
118  getStats(stats);
119 
120  dqmFoldersPerEP_ = static_cast<xdata::Double>(
121  stats.numberOfUpdatesStats.getValueAverage(MonitoredQuantity::RECENT));
122 
123  processedDQMEvents_ = static_cast<xdata::UnsignedInteger32>(
124  static_cast<unsigned int>(stats.dqmEventSizeStats.getSampleCount(MonitoredQuantity::FULL)));
125 
126  droppedDQMEvents_ = static_cast<xdata::UnsignedInteger32>(
127  static_cast<unsigned int>(stats.droppedDQMEventCountsStats.getValueSum(MonitoredQuantity::FULL)));
128 
129  completeDQMUpdates_ = static_cast<xdata::Double>(
130  stats.numberOfCompleteUpdatesStats.getValueAverage(MonitoredQuantity::RECENT));
131  }
xdata::UnsignedInteger32 droppedDQMEvents_
void getStats(DQMEventStats &stats) const
xdata::UnsignedInteger32 processedDQMEvents_
const MonitoredQuantity& stor::DQMEventMonitorCollection::getDQMEventBandwidthMQ ( ) const
inline

Definition at line 94 of file DQMEventMonitorCollection.h.

References dqmEventBandwidth_.

Referenced by getStats().

94  {
95  return dqmEventBandwidth_;
96  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getDQMEventBandwidthMQ ( )
inline

Definition at line 97 of file DQMEventMonitorCollection.h.

References dqmEventBandwidth_.

97  {
98  return dqmEventBandwidth_;
99  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getDQMEventSizeMQ ( ) const
inline

Definition at line 73 of file DQMEventMonitorCollection.h.

References dqmEventSizes_.

Referenced by stor::DQMTopLevelFolder::addDQMEvent(), and getStats().

73  {
74  return dqmEventSizes_;
75  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getDQMEventSizeMQ ( )
inline

Definition at line 76 of file DQMEventMonitorCollection.h.

References dqmEventSizes_.

76  {
77  return dqmEventSizes_;
78  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getDroppedDQMEventCountsMQ ( ) const
inline

Definition at line 66 of file DQMEventMonitorCollection.h.

References droppedDQMEventCounts_.

Referenced by getStats().

66  {
68  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getDroppedDQMEventCountsMQ ( )
inline

Definition at line 69 of file DQMEventMonitorCollection.h.

References droppedDQMEventCounts_.

69  {
71  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfCompleteUpdatesMQ ( ) const
inline

Definition at line 129 of file DQMEventMonitorCollection.h.

References numberOfCompleteUpdates_.

Referenced by getStats(), and stor::DQMTopLevelFolder::isReady().

129  {
131  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfCompleteUpdatesMQ ( )
inline

Definition at line 132 of file DQMEventMonitorCollection.h.

References numberOfCompleteUpdates_.

132  {
134  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfTopLevelFoldersMQ ( ) const
inline

Definition at line 115 of file DQMEventMonitorCollection.h.

References numberOfTopLevelFolders_.

Referenced by getStats().

115  {
117  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfTopLevelFoldersMQ ( )
inline

Definition at line 118 of file DQMEventMonitorCollection.h.

References numberOfTopLevelFolders_.

118  {
120  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfUpdatesMQ ( ) const
inline

Definition at line 122 of file DQMEventMonitorCollection.h.

References numberOfUpdates_.

Referenced by stor::DQMTopLevelFolder::getRecord(), and getStats().

122  {
123  return numberOfUpdates_;
124  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfUpdatesMQ ( )
inline

Definition at line 125 of file DQMEventMonitorCollection.h.

References numberOfUpdates_.

125  {
126  return numberOfUpdates_;
127  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfWrittenTopLevelFoldersMQ ( ) const
inline
MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfWrittenTopLevelFoldersMQ ( )
inline

Definition at line 139 of file DQMEventMonitorCollection.h.

References numberOfWrittenTopLevelFolders_.

139  {
141  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getServedDQMEventBandwidthMQ ( ) const
inline

Definition at line 101 of file DQMEventMonitorCollection.h.

References servedDQMEventBandwidth_.

Referenced by getStats().

101  {
103  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getServedDQMEventBandwidthMQ ( )
inline

Definition at line 104 of file DQMEventMonitorCollection.h.

References servedDQMEventBandwidth_.

104  {
106  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getServedDQMEventSizeMQ ( ) const
inline

Definition at line 80 of file DQMEventMonitorCollection.h.

References servedDQMEventSizes_.

Referenced by stor::DQMTopLevelFolder::getRecord(), and getStats().

80  {
81  return servedDQMEventSizes_;
82  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getServedDQMEventSizeMQ ( )
inline

Definition at line 83 of file DQMEventMonitorCollection.h.

References servedDQMEventSizes_.

83  {
84  return servedDQMEventSizes_;
85  }
void stor::DQMEventMonitorCollection::getStats ( DQMEventStats stats) const

Write all our collected statistics into the given Stats struct.

Definition at line 30 of file DQMEventMonitorCollection.cc.

References stor::DQMEventMonitorCollection::DQMEventStats::dqmEventBandwidthStats, stor::DQMEventMonitorCollection::DQMEventStats::dqmEventSizeStats, stor::DQMEventMonitorCollection::DQMEventStats::droppedDQMEventCountsStats, getDQMEventBandwidthMQ(), getDQMEventSizeMQ(), getDroppedDQMEventCountsMQ(), getNumberOfCompleteUpdatesMQ(), getNumberOfTopLevelFoldersMQ(), getNumberOfUpdatesMQ(), getNumberOfWrittenTopLevelFoldersMQ(), getServedDQMEventBandwidthMQ(), getServedDQMEventSizeMQ(), stor::MonitoredQuantity::getStats(), getWrittenDQMEventBandwidthMQ(), getWrittenDQMEventSizeMQ(), stor::DQMEventMonitorCollection::DQMEventStats::numberOfCompleteUpdatesStats, stor::DQMEventMonitorCollection::DQMEventStats::numberOfTopLevelFoldersStats, stor::DQMEventMonitorCollection::DQMEventStats::numberOfUpdatesStats, stor::DQMEventMonitorCollection::DQMEventStats::numberOfWrittenTopLevelFoldersStats, stor::DQMEventMonitorCollection::DQMEventStats::servedDQMEventBandwidthStats, stor::DQMEventMonitorCollection::DQMEventStats::servedDQMEventSizeStats, stor::DQMEventMonitorCollection::DQMEventStats::writtenDQMEventBandwidthStats, and stor::DQMEventMonitorCollection::DQMEventStats::writtenDQMEventSizeStats.

Referenced by stor::SMWebPageHelper::addDOMforSummaryInformation(), and do_updateInfoSpaceItems().

31  {
32  getDroppedDQMEventCountsMQ().getStats(stats.droppedDQMEventCountsStats);
33 
34  getDQMEventSizeMQ().getStats(stats.dqmEventSizeStats);
35  getServedDQMEventSizeMQ().getStats(stats.servedDQMEventSizeStats);
36  getWrittenDQMEventSizeMQ().getStats(stats.writtenDQMEventSizeStats);
37 
38  getDQMEventBandwidthMQ().getStats(stats.dqmEventBandwidthStats);
39  getServedDQMEventBandwidthMQ().getStats(stats.servedDQMEventBandwidthStats);
40  getWrittenDQMEventBandwidthMQ().getStats(stats.writtenDQMEventBandwidthStats);
41 
42  getNumberOfTopLevelFoldersMQ().getStats(stats.numberOfTopLevelFoldersStats);
43  getNumberOfUpdatesMQ().getStats(stats.numberOfUpdatesStats);
44  getNumberOfWrittenTopLevelFoldersMQ().getStats(stats.numberOfWrittenTopLevelFoldersStats);
45 
46  getNumberOfCompleteUpdatesMQ().getStats(stats.numberOfCompleteUpdatesStats);
47  }
void getStats(Stats &stats) const
const MonitoredQuantity & getDroppedDQMEventCountsMQ() const
const MonitoredQuantity & getWrittenDQMEventBandwidthMQ() const
const MonitoredQuantity & getNumberOfUpdatesMQ() const
const MonitoredQuantity & getDQMEventSizeMQ() const
const MonitoredQuantity & getNumberOfCompleteUpdatesMQ() const
const MonitoredQuantity & getWrittenDQMEventSizeMQ() const
const MonitoredQuantity & getNumberOfTopLevelFoldersMQ() const
const MonitoredQuantity & getServedDQMEventBandwidthMQ() const
const MonitoredQuantity & getServedDQMEventSizeMQ() const
const MonitoredQuantity & getNumberOfWrittenTopLevelFoldersMQ() const
const MonitoredQuantity & getDQMEventBandwidthMQ() const
const MonitoredQuantity& stor::DQMEventMonitorCollection::getWrittenDQMEventBandwidthMQ ( ) const
inline

Definition at line 108 of file DQMEventMonitorCollection.h.

References writtenDQMEventBandwidth_.

Referenced by getStats().

108  {
110  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getWrittenDQMEventBandwidthMQ ( )
inline

Definition at line 111 of file DQMEventMonitorCollection.h.

References writtenDQMEventBandwidth_.

111  {
113  }
const MonitoredQuantity& stor::DQMEventMonitorCollection::getWrittenDQMEventSizeMQ ( ) const
inline

Definition at line 87 of file DQMEventMonitorCollection.h.

References writtenDQMEventSizes_.

Referenced by getStats(), and smproxy::DQMArchiver::writeDQMEventToFile().

87  {
88  return writtenDQMEventSizes_;
89  }
MonitoredQuantity& stor::DQMEventMonitorCollection::getWrittenDQMEventSizeMQ ( )
inline

Definition at line 90 of file DQMEventMonitorCollection.h.

References writtenDQMEventSizes_.

90  {
91  return writtenDQMEventSizes_;
92  }
DQMEventMonitorCollection& stor::DQMEventMonitorCollection::operator= ( DQMEventMonitorCollection const &  )
private

Member Data Documentation

xdata::Double stor::DQMEventMonitorCollection::completeDQMUpdates_
private
MonitoredQuantity stor::DQMEventMonitorCollection::dqmEventBandwidth_
private
MonitoredQuantity stor::DQMEventMonitorCollection::dqmEventSizes_
private

Definition at line 29 of file DQMEventMonitorCollection.h.

Referenced by do_calculateStatistics(), do_reset(), and getDQMEventSizeMQ().

xdata::Double stor::DQMEventMonitorCollection::dqmFoldersPerEP_
private
MonitoredQuantity stor::DQMEventMonitorCollection::droppedDQMEventCounts_
private
xdata::UnsignedInteger32 stor::DQMEventMonitorCollection::droppedDQMEvents_
private
MonitoredQuantity stor::DQMEventMonitorCollection::numberOfCompleteUpdates_
private
MonitoredQuantity stor::DQMEventMonitorCollection::numberOfTopLevelFolders_
private
MonitoredQuantity stor::DQMEventMonitorCollection::numberOfUpdates_
private
MonitoredQuantity stor::DQMEventMonitorCollection::numberOfWrittenTopLevelFolders_
private
xdata::UnsignedInteger32 stor::DQMEventMonitorCollection::processedDQMEvents_
private
MonitoredQuantity stor::DQMEventMonitorCollection::servedDQMEventBandwidth_
private
MonitoredQuantity stor::DQMEventMonitorCollection::servedDQMEventSizes_
private
MonitoredQuantity stor::DQMEventMonitorCollection::writtenDQMEventBandwidth_
private
MonitoredQuantity stor::DQMEventMonitorCollection::writtenDQMEventSizes_
private