|
|
|
#include <FragmentMonitorCollection.h>
A collection of MonitoredQuantities related to fragments
Definition at line 23 of file FragmentMonitorCollection.h.
| stor::FragmentMonitorCollection::FragmentMonitorCollection | ( | const utils::Duration_t & | updateInterval | ) | [explicit] |
Definition at line 14 of file FragmentMonitorCollection.cc.
: MonitorCollection(updateInterval), allFragmentSizes_(updateInterval, boost::posix_time::seconds(5)), allFragmentBandwidth_(updateInterval, boost::posix_time::seconds(5)), eventFragmentSizes_(updateInterval, boost::posix_time::seconds(5)), eventFragmentBandwidth_(updateInterval, boost::posix_time::seconds(5)), dqmEventFragmentSizes_(updateInterval, boost::posix_time::seconds(300)), dqmEventFragmentBandwidth_(updateInterval, boost::posix_time::seconds(300)) {}
| stor::FragmentMonitorCollection::FragmentMonitorCollection | ( | FragmentMonitorCollection const & | ) | [private] |
| void stor::FragmentMonitorCollection::addDQMEventFragmentSample | ( | const double | bytecount | ) |
Add a DQM event fragment size of bytes
Definition at line 40 of file FragmentMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), allFragmentSizes_, and dqmEventFragmentSizes_.
Referenced by stor::StorageManager::receiveDQMMessage().
{
double mbytes = bytecount / 0x100000;
allFragmentSizes_.addSample(mbytes);
dqmEventFragmentSizes_.addSample(mbytes);
}
| void stor::FragmentMonitorCollection::addEventFragmentSample | ( | const double | bytecount | ) |
Add an event fragment size of bytes
Definition at line 32 of file FragmentMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), allFragmentSizes_, and eventFragmentSizes_.
Referenced by stor::StorageManager::receiveDataMessage(), and stor::StorageManager::receiveErrorDataMessage().
{
double mbytes = bytecount / 0x100000;
allFragmentSizes_.addSample(mbytes);
eventFragmentSizes_.addSample(mbytes);
}
| void stor::FragmentMonitorCollection::addFragmentSample | ( | const double | bytecount | ) |
Add a generic fragment size of bytes
Definition at line 25 of file FragmentMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), and allFragmentSizes_.
Referenced by stor::StorageManager::receiveEndOfLumiSectionMessage().
{
double mbytes = bytecount / 0x100000;
allFragmentSizes_.addSample(mbytes);
}
| void stor::FragmentMonitorCollection::do_appendInfoSpaceItems | ( | InfoSpaceItems & | infoSpaceItems | ) | [private, virtual] |
Reimplemented from stor::MonitorCollection.
Definition at line 99 of file FragmentMonitorCollection.cc.
References instantBandwidth_, instantRate_, and receivedFrames_.
{
infoSpaceItems.push_back(std::make_pair("receivedFrames", &receivedFrames_));
infoSpaceItems.push_back(std::make_pair("instantBandwidth", &instantBandwidth_));
infoSpaceItems.push_back(std::make_pair("instantRate", &instantRate_));
}
| void stor::FragmentMonitorCollection::do_calculateStatistics | ( | ) | [private, virtual] |
Implements stor::MonitorCollection.
Definition at line 60 of file FragmentMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), allFragmentBandwidth_, allFragmentSizes_, stor::MonitoredQuantity::calculateStatistics(), dqmEventFragmentBandwidth_, dqmEventFragmentSizes_, eventFragmentBandwidth_, eventFragmentSizes_, stor::MonitoredQuantity::Stats::getLastValueRate(), stor::MonitoredQuantity::Stats::getSampleCount(), and stor::MonitoredQuantity::getStats().
{
allFragmentSizes_.calculateStatistics();
eventFragmentSizes_.calculateStatistics();
dqmEventFragmentSizes_.calculateStatistics();
MonitoredQuantity::Stats stats;
allFragmentSizes_.getStats(stats);
if (stats.getSampleCount() > 0) {
allFragmentBandwidth_.addSample(stats.getLastValueRate());
}
allFragmentBandwidth_.calculateStatistics();
eventFragmentSizes_.getStats(stats);
if (stats.getSampleCount() > 0) {
eventFragmentBandwidth_.addSample(stats.getLastValueRate());
}
eventFragmentBandwidth_.calculateStatistics();
dqmEventFragmentSizes_.getStats(stats);
if (stats.getSampleCount() > 0) {
dqmEventFragmentBandwidth_.addSample(stats.getLastValueRate());
}
dqmEventFragmentBandwidth_.calculateStatistics();
}
| void stor::FragmentMonitorCollection::do_reset | ( | ) | [private, virtual] |
Implements stor::MonitorCollection.
Definition at line 87 of file FragmentMonitorCollection.cc.
References allFragmentBandwidth_, allFragmentSizes_, dqmEventFragmentBandwidth_, dqmEventFragmentSizes_, eventFragmentBandwidth_, eventFragmentSizes_, and stor::MonitoredQuantity::reset().
{
allFragmentSizes_.reset();
eventFragmentSizes_.reset();
dqmEventFragmentSizes_.reset();
allFragmentBandwidth_.reset();
eventFragmentBandwidth_.reset();
dqmEventFragmentBandwidth_.reset();
}
| void stor::FragmentMonitorCollection::do_updateInfoSpaceItems | ( | ) | [private, virtual] |
Reimplemented from stor::MonitorCollection.
Definition at line 107 of file FragmentMonitorCollection.cc.
References allFragmentBandwidth_, allFragmentSizes_, stor::MonitoredQuantity::Stats::getSampleCount(), stor::MonitoredQuantity::Stats::getSampleRate(), stor::MonitoredQuantity::getStats(), stor::MonitoredQuantity::Stats::getValueRate(), instantBandwidth_, instantRate_, receivedFrames_, and stor::MonitoredQuantity::RECENT.
{
MonitoredQuantity::Stats stats;
allFragmentSizes_.getStats(stats);
receivedFrames_ = static_cast<xdata::UnsignedInteger32>(stats.getSampleCount());
instantRate_ = static_cast<xdata::Double>(stats.getSampleRate(MonitoredQuantity::RECENT));
allFragmentBandwidth_.getStats(stats);
instantBandwidth_ = static_cast<xdata::Double>(stats.getValueRate(MonitoredQuantity::RECENT));
}
| MonitoredQuantity& stor::FragmentMonitorCollection::getAllFragmentBandwidthMQ | ( | ) | [inline] |
Definition at line 92 of file FragmentMonitorCollection.h.
References allFragmentBandwidth_.
{
return allFragmentBandwidth_;
}
| const MonitoredQuantity& stor::FragmentMonitorCollection::getAllFragmentBandwidthMQ | ( | ) | const [inline] |
Definition at line 89 of file FragmentMonitorCollection.h.
References allFragmentBandwidth_.
Referenced by getStats().
{
return allFragmentBandwidth_;
}
| const MonitoredQuantity& stor::FragmentMonitorCollection::getAllFragmentSizeMQ | ( | ) | const [inline] |
Definition at line 68 of file FragmentMonitorCollection.h.
References allFragmentSizes_.
Referenced by getStats(), and stor::StorageManager::receiveRegistryMessage().
{
return allFragmentSizes_;
}
| MonitoredQuantity& stor::FragmentMonitorCollection::getAllFragmentSizeMQ | ( | ) | [inline] |
Definition at line 71 of file FragmentMonitorCollection.h.
References allFragmentSizes_.
{
return allFragmentSizes_;
}
| MonitoredQuantity& stor::FragmentMonitorCollection::getDQMEventFragmentBandwidthMQ | ( | ) | [inline] |
Definition at line 106 of file FragmentMonitorCollection.h.
References dqmEventFragmentBandwidth_.
{
return dqmEventFragmentBandwidth_;
}
| const MonitoredQuantity& stor::FragmentMonitorCollection::getDQMEventFragmentBandwidthMQ | ( | ) | const [inline] |
Definition at line 103 of file FragmentMonitorCollection.h.
References dqmEventFragmentBandwidth_.
Referenced by getStats().
{
return dqmEventFragmentBandwidth_;
}
| const MonitoredQuantity& stor::FragmentMonitorCollection::getDQMEventFragmentSizeMQ | ( | ) | const [inline] |
Definition at line 82 of file FragmentMonitorCollection.h.
References dqmEventFragmentSizes_.
Referenced by getStats().
{
return dqmEventFragmentSizes_;
}
| MonitoredQuantity& stor::FragmentMonitorCollection::getDQMEventFragmentSizeMQ | ( | ) | [inline] |
Definition at line 85 of file FragmentMonitorCollection.h.
References dqmEventFragmentSizes_.
{
return dqmEventFragmentSizes_;
}
| MonitoredQuantity& stor::FragmentMonitorCollection::getEventFragmentBandwidthMQ | ( | ) | [inline] |
Definition at line 99 of file FragmentMonitorCollection.h.
References eventFragmentBandwidth_.
{
return eventFragmentBandwidth_;
}
| const MonitoredQuantity& stor::FragmentMonitorCollection::getEventFragmentBandwidthMQ | ( | ) | const [inline] |
Definition at line 96 of file FragmentMonitorCollection.h.
References eventFragmentBandwidth_.
Referenced by getStats().
{
return eventFragmentBandwidth_;
}
| MonitoredQuantity& stor::FragmentMonitorCollection::getEventFragmentSizeMQ | ( | ) | [inline] |
Definition at line 78 of file FragmentMonitorCollection.h.
References eventFragmentSizes_.
{
return eventFragmentSizes_;
}
| const MonitoredQuantity& stor::FragmentMonitorCollection::getEventFragmentSizeMQ | ( | ) | const [inline] |
Definition at line 75 of file FragmentMonitorCollection.h.
References eventFragmentSizes_.
Referenced by getStats().
{
return eventFragmentSizes_;
}
| void stor::FragmentMonitorCollection::getStats | ( | FragmentStats & | stats | ) | const |
Write all our collected statistics into the given Stats struct.
Definition at line 48 of file FragmentMonitorCollection.cc.
References stor::FragmentMonitorCollection::FragmentStats::allFragmentBandwidthStats, stor::FragmentMonitorCollection::FragmentStats::allFragmentSizeStats, stor::FragmentMonitorCollection::FragmentStats::dqmEventFragmentBandwidthStats, stor::FragmentMonitorCollection::FragmentStats::dqmEventFragmentSizeStats, stor::FragmentMonitorCollection::FragmentStats::eventFragmentBandwidthStats, stor::FragmentMonitorCollection::FragmentStats::eventFragmentSizeStats, getAllFragmentBandwidthMQ(), getAllFragmentSizeMQ(), getDQMEventFragmentBandwidthMQ(), getDQMEventFragmentSizeMQ(), getEventFragmentBandwidthMQ(), getEventFragmentSizeMQ(), and stor::MonitoredQuantity::getStats().
Referenced by stor::SMWebPageHelper::addDOMforFragmentMonitor().
{
getAllFragmentSizeMQ().getStats(stats.allFragmentSizeStats);
getEventFragmentSizeMQ().getStats(stats.eventFragmentSizeStats);
getDQMEventFragmentSizeMQ().getStats(stats.dqmEventFragmentSizeStats);
getAllFragmentBandwidthMQ().getStats(stats.allFragmentBandwidthStats);
getEventFragmentBandwidthMQ().getStats(stats.eventFragmentBandwidthStats);
getDQMEventFragmentBandwidthMQ().getStats(stats.dqmEventFragmentBandwidthStats);
}
| FragmentMonitorCollection& stor::FragmentMonitorCollection::operator= | ( | FragmentMonitorCollection const & | ) | [private] |
Definition at line 28 of file FragmentMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), do_updateInfoSpaceItems(), and getAllFragmentBandwidthMQ().
Definition at line 27 of file FragmentMonitorCollection.h.
Referenced by addDQMEventFragmentSample(), addEventFragmentSample(), addFragmentSample(), do_calculateStatistics(), do_reset(), do_updateInfoSpaceItems(), and getAllFragmentSizeMQ().
Definition at line 34 of file FragmentMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getDQMEventFragmentBandwidthMQ().
Definition at line 33 of file FragmentMonitorCollection.h.
Referenced by addDQMEventFragmentSample(), do_calculateStatistics(), do_reset(), and getDQMEventFragmentSizeMQ().
Definition at line 31 of file FragmentMonitorCollection.h.
Referenced by do_calculateStatistics(), do_reset(), and getEventFragmentBandwidthMQ().
Definition at line 30 of file FragmentMonitorCollection.h.
Referenced by addEventFragmentSample(), do_calculateStatistics(), do_reset(), and getEventFragmentSizeMQ().
xdata::Double stor::FragmentMonitorCollection::instantBandwidth_ [private] |
Definition at line 128 of file FragmentMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::Double stor::FragmentMonitorCollection::instantRate_ [private] |
Definition at line 129 of file FragmentMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::UnsignedInteger32 stor::FragmentMonitorCollection::receivedFrames_ [private] |
Definition at line 127 of file FragmentMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
1.7.3