|
|
|
#include <DQMEventMonitorCollection.h>
A collection of MonitoredQuantities related to fragments
Definition at line 23 of file DQMEventMonitorCollection.h.
| stor::DQMEventMonitorCollection::DQMEventMonitorCollection | ( | const utils::Duration_t & | updateInterval | ) | [explicit] |
Definition at line 14 of file DQMEventMonitorCollection.cc.
: MonitorCollection(updateInterval), droppedDQMEventCounts_(updateInterval, boost::posix_time::seconds(300)), dqmEventSizes_(updateInterval, boost::posix_time::seconds(300)), servedDQMEventSizes_(updateInterval, boost::posix_time::seconds(300)), writtenDQMEventSizes_(updateInterval, boost::posix_time::seconds(300)), dqmEventBandwidth_(updateInterval, boost::posix_time::seconds(300)), servedDQMEventBandwidth_(updateInterval, boost::posix_time::seconds(300)), writtenDQMEventBandwidth_(updateInterval, boost::posix_time::seconds(300)), numberOfTopLevelFolders_(updateInterval, boost::posix_time::seconds(300)), numberOfUpdates_(updateInterval, boost::posix_time::seconds(300)), numberOfWrittenTopLevelFolders_(updateInterval, boost::posix_time::seconds(300)), numberOfCompleteUpdates_(updateInterval, boost::posix_time::seconds(300)) {}
| stor::DQMEventMonitorCollection::DQMEventMonitorCollection | ( | DQMEventMonitorCollection const & | ) | [private] |
| void stor::DQMEventMonitorCollection::do_appendInfoSpaceItems | ( | InfoSpaceItems & | infoSpaceItems | ) | [private, virtual] |
Reimplemented from stor::MonitorCollection.
Definition at line 105 of file DQMEventMonitorCollection.cc.
References completeDQMUpdates_, dqmFoldersPerEP_, droppedDQMEvents_, and processedDQMEvents_.
{
infoSpaceItems.push_back(std::make_pair("dqmFoldersPerEP", &dqmFoldersPerEP_));
infoSpaceItems.push_back(std::make_pair("processedDQMEvents", &processedDQMEvents_));
infoSpaceItems.push_back(std::make_pair("droppedDQMEvents", &droppedDQMEvents_));
infoSpaceItems.push_back(std::make_pair("discardedDQMEvents", &droppedDQMEvents_));
infoSpaceItems.push_back(std::make_pair("completeDQMUpdates", &completeDQMUpdates_));
}
| void stor::DQMEventMonitorCollection::do_calculateStatistics | ( | ) | [private, virtual] |
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_.
{
droppedDQMEventCounts_.calculateStatistics();
dqmEventSizes_.calculateStatistics();
servedDQMEventSizes_.calculateStatistics();
writtenDQMEventSizes_.calculateStatistics();
MonitoredQuantity::Stats stats;
dqmEventSizes_.getStats(stats);
if (stats.getSampleCount() > 0) {
dqmEventBandwidth_.addSample(stats.getLastValueRate());
}
dqmEventBandwidth_.calculateStatistics();
servedDQMEventSizes_.getStats(stats);
if (stats.getSampleCount() > 0) {
servedDQMEventBandwidth_.addSample(stats.getLastValueRate());
}
servedDQMEventBandwidth_.calculateStatistics();
writtenDQMEventSizes_.getStats(stats);
if (stats.getSampleCount() > 0) {
writtenDQMEventBandwidth_.addSample(stats.getLastValueRate());
}
writtenDQMEventBandwidth_.calculateStatistics();
numberOfTopLevelFolders_.calculateStatistics();
numberOfUpdates_.calculateStatistics();
numberOfWrittenTopLevelFolders_.calculateStatistics();
numberOfCompleteUpdates_.calculateStatistics();
}
| void stor::DQMEventMonitorCollection::do_reset | ( | ) | [private, virtual] |
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_.
{
droppedDQMEventCounts_.reset();
dqmEventSizes_.reset();
servedDQMEventSizes_.reset();
writtenDQMEventSizes_.reset();
dqmEventBandwidth_.reset();
servedDQMEventBandwidth_.reset();
writtenDQMEventBandwidth_.reset();
numberOfTopLevelFolders_.reset();
numberOfUpdates_.reset();
numberOfWrittenTopLevelFolders_.reset();
numberOfCompleteUpdates_.reset();
}
| void stor::DQMEventMonitorCollection::do_updateInfoSpaceItems | ( | ) | [private, virtual] |
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.
{
DQMEventMonitorCollection::DQMEventStats stats;
getStats(stats);
dqmFoldersPerEP_ = static_cast<xdata::Double>(
stats.numberOfUpdatesStats.getValueAverage(MonitoredQuantity::RECENT));
processedDQMEvents_ = static_cast<xdata::UnsignedInteger32>(
static_cast<unsigned int>(stats.dqmEventSizeStats.getSampleCount(MonitoredQuantity::FULL)));
droppedDQMEvents_ = static_cast<xdata::UnsignedInteger32>(
static_cast<unsigned int>(stats.droppedDQMEventCountsStats.getValueSum(MonitoredQuantity::FULL)));
completeDQMUpdates_ = static_cast<xdata::Double>(
stats.numberOfCompleteUpdatesStats.getValueAverage(MonitoredQuantity::RECENT));
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getDQMEventBandwidthMQ | ( | ) | [inline] |
Definition at line 97 of file DQMEventMonitorCollection.h.
References dqmEventBandwidth_.
{
return dqmEventBandwidth_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getDQMEventBandwidthMQ | ( | ) | const [inline] |
Definition at line 94 of file DQMEventMonitorCollection.h.
References dqmEventBandwidth_.
Referenced by getStats().
{
return dqmEventBandwidth_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getDQMEventSizeMQ | ( | ) | [inline] |
Definition at line 76 of file DQMEventMonitorCollection.h.
References dqmEventSizes_.
{
return dqmEventSizes_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getDQMEventSizeMQ | ( | ) | const [inline] |
Definition at line 73 of file DQMEventMonitorCollection.h.
References dqmEventSizes_.
Referenced by stor::DQMTopLevelFolder::addDQMEvent(), and getStats().
{
return dqmEventSizes_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getDroppedDQMEventCountsMQ | ( | ) | [inline] |
Definition at line 69 of file DQMEventMonitorCollection.h.
References droppedDQMEventCounts_.
{
return droppedDQMEventCounts_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getDroppedDQMEventCountsMQ | ( | ) | const [inline] |
Definition at line 66 of file DQMEventMonitorCollection.h.
References droppedDQMEventCounts_.
Referenced by getStats().
{
return droppedDQMEventCounts_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfCompleteUpdatesMQ | ( | ) | const [inline] |
Definition at line 129 of file DQMEventMonitorCollection.h.
References numberOfCompleteUpdates_.
Referenced by getStats(), and stor::DQMTopLevelFolder::isReady().
{
return numberOfCompleteUpdates_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfCompleteUpdatesMQ | ( | ) | [inline] |
Definition at line 132 of file DQMEventMonitorCollection.h.
References numberOfCompleteUpdates_.
{
return numberOfCompleteUpdates_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfTopLevelFoldersMQ | ( | ) | [inline] |
Definition at line 118 of file DQMEventMonitorCollection.h.
References numberOfTopLevelFolders_.
{
return numberOfTopLevelFolders_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfTopLevelFoldersMQ | ( | ) | const [inline] |
Definition at line 115 of file DQMEventMonitorCollection.h.
References numberOfTopLevelFolders_.
Referenced by getStats().
{
return numberOfTopLevelFolders_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfUpdatesMQ | ( | ) | const [inline] |
Definition at line 122 of file DQMEventMonitorCollection.h.
References numberOfUpdates_.
Referenced by stor::DQMTopLevelFolder::getRecord(), and getStats().
{
return numberOfUpdates_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfUpdatesMQ | ( | ) | [inline] |
Definition at line 125 of file DQMEventMonitorCollection.h.
References numberOfUpdates_.
{
return numberOfUpdates_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfWrittenTopLevelFoldersMQ | ( | ) | const [inline] |
Definition at line 136 of file DQMEventMonitorCollection.h.
References numberOfWrittenTopLevelFolders_.
Referenced by getStats(), and smproxy::DQMArchiver::writeDQMEventToFile().
{
return numberOfWrittenTopLevelFolders_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getNumberOfWrittenTopLevelFoldersMQ | ( | ) | [inline] |
Definition at line 139 of file DQMEventMonitorCollection.h.
References numberOfWrittenTopLevelFolders_.
{
return numberOfWrittenTopLevelFolders_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getServedDQMEventBandwidthMQ | ( | ) | const [inline] |
Definition at line 101 of file DQMEventMonitorCollection.h.
References servedDQMEventBandwidth_.
Referenced by getStats().
{
return servedDQMEventBandwidth_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getServedDQMEventBandwidthMQ | ( | ) | [inline] |
Definition at line 104 of file DQMEventMonitorCollection.h.
References servedDQMEventBandwidth_.
{
return servedDQMEventBandwidth_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getServedDQMEventSizeMQ | ( | ) | [inline] |
Definition at line 83 of file DQMEventMonitorCollection.h.
References servedDQMEventSizes_.
{
return servedDQMEventSizes_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getServedDQMEventSizeMQ | ( | ) | const [inline] |
Definition at line 80 of file DQMEventMonitorCollection.h.
References servedDQMEventSizes_.
Referenced by stor::DQMTopLevelFolder::getRecord(), and getStats().
{
return servedDQMEventSizes_;
}
| 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().
{
getDroppedDQMEventCountsMQ().getStats(stats.droppedDQMEventCountsStats);
getDQMEventSizeMQ().getStats(stats.dqmEventSizeStats);
getServedDQMEventSizeMQ().getStats(stats.servedDQMEventSizeStats);
getWrittenDQMEventSizeMQ().getStats(stats.writtenDQMEventSizeStats);
getDQMEventBandwidthMQ().getStats(stats.dqmEventBandwidthStats);
getServedDQMEventBandwidthMQ().getStats(stats.servedDQMEventBandwidthStats);
getWrittenDQMEventBandwidthMQ().getStats(stats.writtenDQMEventBandwidthStats);
getNumberOfTopLevelFoldersMQ().getStats(stats.numberOfTopLevelFoldersStats);
getNumberOfUpdatesMQ().getStats(stats.numberOfUpdatesStats);
getNumberOfWrittenTopLevelFoldersMQ().getStats(stats.numberOfWrittenTopLevelFoldersStats);
getNumberOfCompleteUpdatesMQ().getStats(stats.numberOfCompleteUpdatesStats);
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getWrittenDQMEventBandwidthMQ | ( | ) | [inline] |
Definition at line 111 of file DQMEventMonitorCollection.h.
References writtenDQMEventBandwidth_.
{
return writtenDQMEventBandwidth_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getWrittenDQMEventBandwidthMQ | ( | ) | const [inline] |
Definition at line 108 of file DQMEventMonitorCollection.h.
References writtenDQMEventBandwidth_.
Referenced by getStats().
{
return writtenDQMEventBandwidth_;
}
| MonitoredQuantity& stor::DQMEventMonitorCollection::getWrittenDQMEventSizeMQ | ( | ) | [inline] |
Definition at line 90 of file DQMEventMonitorCollection.h.
References writtenDQMEventSizes_.
{
return writtenDQMEventSizes_;
}
| const MonitoredQuantity& stor::DQMEventMonitorCollection::getWrittenDQMEventSizeMQ | ( | ) | const [inline] |
Definition at line 87 of file DQMEventMonitorCollection.h.
References writtenDQMEventSizes_.
Referenced by getStats(), and smproxy::DQMArchiver::writeDQMEventToFile().
{
return writtenDQMEventSizes_;
}
| DQMEventMonitorCollection& stor::DQMEventMonitorCollection::operator= | ( | DQMEventMonitorCollection const & | ) | [private] |
xdata::Double stor::DQMEventMonitorCollection::completeDQMUpdates_ [private] |
Definition at line 163 of file DQMEventMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 33 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getDQMEventBandwidthMQ().
Definition at line 29 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getDQMEventSizeMQ().
xdata::Double stor::DQMEventMonitorCollection::dqmFoldersPerEP_ [private] |
Definition at line 160 of file DQMEventMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 27 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getDroppedDQMEventCountsMQ().
xdata::UnsignedInteger32 stor::DQMEventMonitorCollection::droppedDQMEvents_ [private] |
Definition at line 162 of file DQMEventMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 41 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getNumberOfCompleteUpdatesMQ().
Definition at line 37 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getNumberOfTopLevelFoldersMQ().
Definition at line 38 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getNumberOfUpdatesMQ().
Definition at line 39 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getNumberOfWrittenTopLevelFoldersMQ().
xdata::UnsignedInteger32 stor::DQMEventMonitorCollection::processedDQMEvents_ [private] |
Definition at line 161 of file DQMEventMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 34 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getServedDQMEventBandwidthMQ().
Definition at line 30 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getServedDQMEventSizeMQ().
Definition at line 35 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getWrittenDQMEventBandwidthMQ().
Definition at line 31 of file DQMEventMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getWrittenDQMEventSizeMQ().
1.7.3