|
|
|
#include <ThroughputMonitorCollection.h>
A collection of MonitoredQuantities to track the flow of data through the storage manager.
Definition at line 31 of file ThroughputMonitorCollection.h.
| ThroughputMonitorCollection::ThroughputMonitorCollection | ( | const utils::Duration_t & | updateInterval, |
| const unsigned int & | throuphputAveragingCycles | ||
| ) | [explicit] |
Definition at line 10 of file ThroughputMonitorCollection.cc.
: MonitorCollection(updateInterval), binCount_(300), poolUsageMQ_(updateInterval, updateInterval*binCount_), entriesInFragmentQueueMQ_(updateInterval, updateInterval*binCount_), memoryUsedInFragmentQueueMQ_(updateInterval, updateInterval*binCount_), poppedFragmentSizeMQ_(updateInterval, updateInterval*binCount_), fragmentProcessorIdleTimeMQ_(updateInterval, updateInterval*binCount_), entriesInFragmentStoreMQ_(updateInterval, updateInterval*binCount_), memoryUsedInFragmentStoreMQ_(updateInterval, updateInterval*binCount_), entriesInStreamQueueMQ_(updateInterval, updateInterval*binCount_), memoryUsedInStreamQueueMQ_(updateInterval, updateInterval*binCount_), poppedEventSizeMQ_(updateInterval, updateInterval*binCount_), diskWriterIdleTimeMQ_(updateInterval, updateInterval*binCount_), diskWriteSizeMQ_(updateInterval, updateInterval*binCount_), entriesInDQMEventQueueMQ_(updateInterval, updateInterval*binCount_), memoryUsedInDQMEventQueueMQ_(updateInterval, updateInterval*binCount_), poppedDQMEventSizeMQ_(updateInterval, updateInterval*binCount_), dqmEventProcessorIdleTimeMQ_(updateInterval, updateInterval*binCount_), currentFragmentStoreSize_(0), currentFragmentStoreMemoryUsedMB_(0), throuphputAveragingCycles_(throuphputAveragingCycles), pool_(0) {}
| stor::ThroughputMonitorCollection::ThroughputMonitorCollection | ( | ThroughputMonitorCollection const & | ) | [private] |
| void ThroughputMonitorCollection::addDiskWriterIdleSample | ( | utils::Duration_t | idleTime | ) |
Definition at line 66 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), diskWriterIdleTimeMQ_, and stor::utils::durationToSeconds().
{
diskWriterIdleTimeMQ_.addSample(utils::durationToSeconds(idleTime));
}
| void ThroughputMonitorCollection::addDiskWriteSample | ( | double | dataSize | ) |
Definition at line 72 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), and diskWriteSizeMQ_.
{
diskWriteSizeMQ_.addSample(dataSize);
}
| void ThroughputMonitorCollection::addDQMEventProcessorIdleSample | ( | utils::Duration_t | idleTime | ) |
Definition at line 85 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), dqmEventProcessorIdleTimeMQ_, and stor::utils::durationToSeconds().
{
dqmEventProcessorIdleTimeMQ_.addSample(utils::durationToSeconds(idleTime));
}
| void ThroughputMonitorCollection::addFragmentProcessorIdleSample | ( | utils::Duration_t | idleTime | ) |
Definition at line 53 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), stor::utils::durationToSeconds(), and fragmentProcessorIdleTimeMQ_.
{
fragmentProcessorIdleTimeMQ_.addSample(utils::durationToSeconds(idleTime));
}
| void ThroughputMonitorCollection::addPoppedDQMEventSample | ( | double | dataSize | ) |
Definition at line 78 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), and poppedDQMEventSizeMQ_.
{
poppedDQMEventSizeMQ_.addSample(dataSize);
}
| void ThroughputMonitorCollection::addPoppedEventSample | ( | double | dataSize | ) |
Definition at line 59 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), and poppedEventSizeMQ_.
{
poppedEventSizeMQ_.addSample(dataSize);
}
| void ThroughputMonitorCollection::addPoppedFragmentSample | ( | double | dataSize | ) |
Definition at line 46 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), and poppedFragmentSizeMQ_.
{
poppedFragmentSizeMQ_.addSample(dataSize);
}
| double ThroughputMonitorCollection::calcBusyPercentage | ( | MonitoredQuantity::Stats & | stats, |
| const int & | idx | ||
| ) | const [private] |
Definition at line 316 of file ThroughputMonitorCollection.cc.
References stor::utils::durationToSeconds(), UserOptions_cff::idx, stor::MonitoredQuantity::Stats::recentBinnedDurations, stor::MonitoredQuantity::Stats::recentBinnedSampleCounts, and stor::MonitoredQuantity::Stats::recentBinnedValueSums.
Referenced by do_getStats().
{
double busyPercentage;
if (stats.recentBinnedSampleCounts[idx] == 0)
{
// the thread did not log any idle time
busyPercentage = 100;
}
else if (stats.recentBinnedSampleCounts[idx] == 1)
{
// only one sample means that we waited a whole second on a queue
// this should only happen if deq_timed_wait timeout >= statistics calculation period
busyPercentage = 0;
}
else if (stats.recentBinnedValueSums[idx] <= utils::durationToSeconds(stats.recentBinnedDurations[idx]))
{
// the thread was busy while it was not idle during the whole reporting duration
busyPercentage = 100.0 * (1.0 - (stats.recentBinnedValueSums[idx] /
utils::durationToSeconds(stats.recentBinnedDurations[idx])));
}
else
{
// the process logged more idle time than the whole reporting duration
// this can happen due to rounding issues.
busyPercentage = 0;
}
return busyPercentage;
}
| void ThroughputMonitorCollection::calcPoolUsage | ( | ) | [private] |
Definition at line 91 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), stor::MonitoredQuantity::calculateStatistics(), pool_, and poolUsageMQ_.
Referenced by do_calculateStatistics().
{
if (pool_)
{
try {
pool_->lock();
poolUsageMQ_.addSample(pool_->getMemoryUsage().getUsed());
pool_->unlock();
}
catch (...)
{
pool_->unlock();
}
}
poolUsageMQ_.calculateStatistics();
}
| void ThroughputMonitorCollection::do_appendInfoSpaceItems | ( | InfoSpaceItems & | infoSpaceItems | ) | [private, virtual] |
Reimplemented from stor::MonitorCollection.
Definition at line 408 of file ThroughputMonitorCollection.cc.
References averagingTime_, diskWriterBusy_, dqmEventProcessorBusy_, dqmQueueBandwidth_, dqmQueueRate_, entriesInDQMQueue_, entriesInFragmentQueue_, entriesInStreamQueue_, fragmentProcessorBusy_, fragmentQueueBandwidth_, fragmentQueueRate_, fragmentStoreMemoryUsed_, fragmentStoreSize_, memoryUsedInDQMQueue_, memoryUsedInFragmentQueue_, memoryUsedInStreamQueue_, poolUsage_, streamQueueBandwidth_, streamQueueRate_, writtenEventsBandwidth_, and writtenEventsRate_.
{
infoSpaceItems.push_back(std::make_pair("poolUsage", &poolUsage_));
infoSpaceItems.push_back(std::make_pair("entriesInFragmentQueue", &entriesInFragmentQueue_));
infoSpaceItems.push_back(std::make_pair("memoryUsedInFragmentQueue", &memoryUsedInFragmentQueue_));
infoSpaceItems.push_back(std::make_pair("fragmentQueueRate", &fragmentQueueRate_));
infoSpaceItems.push_back(std::make_pair("fragmentQueueBandwidth", &fragmentQueueBandwidth_));
infoSpaceItems.push_back(std::make_pair("fragmentStoreSize", &fragmentStoreSize_));
infoSpaceItems.push_back(std::make_pair("fragmentStoreMemoryUsed", &fragmentStoreMemoryUsed_));
infoSpaceItems.push_back(std::make_pair("entriesInStreamQueue", &entriesInStreamQueue_));
infoSpaceItems.push_back(std::make_pair("memoryUsedInStreamQueue", &memoryUsedInStreamQueue_));
infoSpaceItems.push_back(std::make_pair("streamQueueRate", &streamQueueRate_));
infoSpaceItems.push_back(std::make_pair("streamQueueBandwidth", &streamQueueBandwidth_));
infoSpaceItems.push_back(std::make_pair("writtenEventsRate", &writtenEventsRate_));
infoSpaceItems.push_back(std::make_pair("writtenEventsBandwidth", &writtenEventsBandwidth_));
infoSpaceItems.push_back(std::make_pair("entriesInDQMQueue", &entriesInDQMQueue_));
infoSpaceItems.push_back(std::make_pair("memoryUsedInDQMQueue", &memoryUsedInDQMQueue_));
infoSpaceItems.push_back(std::make_pair("dqmQueueRate", &dqmQueueRate_));
infoSpaceItems.push_back(std::make_pair("dqmQueueBandwidth", &dqmQueueBandwidth_));
infoSpaceItems.push_back(std::make_pair("fragmentProcessorBusy", &fragmentProcessorBusy_));
infoSpaceItems.push_back(std::make_pair("diskWriterBusy", &diskWriterBusy_));
infoSpaceItems.push_back(std::make_pair("dqmEventProcessorBusy", &dqmEventProcessorBusy_));
infoSpaceItems.push_back(std::make_pair("averagingTime", &averagingTime_));
}
| void ThroughputMonitorCollection::do_calculateStatistics | ( | ) | [private, virtual] |
Implements stor::MonitorCollection.
Definition at line 350 of file ThroughputMonitorCollection.cc.
References stor::MonitoredQuantity::addSample(), calcPoolUsage(), stor::MonitoredQuantity::calculateStatistics(), currentFragmentStoreMemoryUsedMB_, currentFragmentStoreSize_, diskWriterIdleTimeMQ_, diskWriteSizeMQ_, dqmEventProcessorIdleTimeMQ_, dqmEventQueue_, entriesInDQMEventQueueMQ_, entriesInFragmentQueueMQ_, entriesInFragmentStoreMQ_, entriesInStreamQueueMQ_, fragmentProcessorIdleTimeMQ_, fragmentQueue_, memoryUsedInDQMEventQueueMQ_, memoryUsedInFragmentQueueMQ_, memoryUsedInFragmentStoreMQ_, memoryUsedInStreamQueueMQ_, poppedDQMEventSizeMQ_, poppedEventSizeMQ_, poppedFragmentSizeMQ_, and streamQueue_.
{
calcPoolUsage();
if (fragmentQueue_.get() != 0) {
entriesInFragmentQueueMQ_.addSample(fragmentQueue_->size());
memoryUsedInFragmentQueueMQ_.addSample( static_cast<double>(fragmentQueue_->used()) / (1024*1024) );
}
if (streamQueue_.get() != 0) {
entriesInStreamQueueMQ_.addSample(streamQueue_->size());
memoryUsedInStreamQueueMQ_.addSample( static_cast<double>(streamQueue_->used()) / (1024*1024) );
}
if (dqmEventQueue_.get() != 0) {
entriesInDQMEventQueueMQ_.addSample(dqmEventQueue_->size());
memoryUsedInDQMEventQueueMQ_.addSample( static_cast<double>(dqmEventQueue_->used()) / (1024*1024) );
}
entriesInFragmentStoreMQ_.addSample(currentFragmentStoreSize_);
memoryUsedInFragmentStoreMQ_.addSample(currentFragmentStoreMemoryUsedMB_);
entriesInFragmentQueueMQ_.calculateStatistics();
memoryUsedInFragmentQueueMQ_.calculateStatistics();
poppedFragmentSizeMQ_.calculateStatistics();
fragmentProcessorIdleTimeMQ_.calculateStatistics();
entriesInFragmentStoreMQ_.calculateStatistics();
memoryUsedInFragmentStoreMQ_.calculateStatistics();
entriesInStreamQueueMQ_.calculateStatistics();
memoryUsedInStreamQueueMQ_.calculateStatistics();
poppedEventSizeMQ_.calculateStatistics();
diskWriterIdleTimeMQ_.calculateStatistics();
diskWriteSizeMQ_.calculateStatistics();
entriesInDQMEventQueueMQ_.calculateStatistics();
memoryUsedInDQMEventQueueMQ_.calculateStatistics();
poppedDQMEventSizeMQ_.calculateStatistics();
dqmEventProcessorIdleTimeMQ_.calculateStatistics();
}
| void ThroughputMonitorCollection::do_getStats | ( | Stats & | stats, |
| const unsigned int | sampleCount | ||
| ) | const [private] |
Definition at line 123 of file ThroughputMonitorCollection.cc.
References stor::ThroughputMonitorCollection::Stats::Snapshot::absoluteTime, stor::ThroughputMonitorCollection::Stats::average, binCount_, calcBusyPercentage(), stor::ThroughputMonitorCollection::Stats::Snapshot::diskWriterBusy, diskWriterIdleTimeMQ_, diskWriteSizeMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::dqmEventProcessorBusy, dqmEventProcessorIdleTimeMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::dqmQueueBandwidth, stor::ThroughputMonitorCollection::Stats::Snapshot::dqmQueueRate, stor::ThroughputMonitorCollection::Stats::Snapshot::duration, entriesInDQMEventQueueMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::entriesInDQMQueue, stor::ThroughputMonitorCollection::Stats::Snapshot::entriesInFragmentQueue, entriesInFragmentQueueMQ_, entriesInFragmentStoreMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::entriesInStreamQueue, entriesInStreamQueueMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::fragmentProcessorBusy, fragmentProcessorIdleTimeMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::fragmentQueueBandwidth, stor::ThroughputMonitorCollection::Stats::Snapshot::fragmentQueueRate, stor::ThroughputMonitorCollection::Stats::Snapshot::fragmentStoreMemoryUsed, stor::ThroughputMonitorCollection::Stats::Snapshot::fragmentStoreSize, getRateAndBandwidth(), stor::MonitoredQuantity::getStats(), UserOptions_cff::idx, memoryUsedInDQMEventQueueMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::memoryUsedInDQMQueue, stor::ThroughputMonitorCollection::Stats::Snapshot::memoryUsedInFragmentQueue, memoryUsedInFragmentQueueMQ_, memoryUsedInFragmentStoreMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::memoryUsedInStreamQueue, memoryUsedInStreamQueueMQ_, stor::ThroughputMonitorCollection::Stats::Snapshot::poolUsage, poolUsageMQ_, poppedDQMEventSizeMQ_, poppedEventSizeMQ_, poppedFragmentSizeMQ_, stor::MonitoredQuantity::Stats::recentBinnedDurations, stor::MonitoredQuantity::Stats::recentBinnedSampleCounts, stor::MonitoredQuantity::Stats::recentBinnedSnapshotTimes, stor::MonitoredQuantity::Stats::recentBinnedValueSums, stor::MonitoredQuantity::Stats::recentDuration, stor::ThroughputMonitorCollection::Stats::reset(), smoothIdleTimes(), stor::ThroughputMonitorCollection::Stats::snapshots, stor::ThroughputMonitorCollection::Stats::Snapshot::streamQueueBandwidth, stor::ThroughputMonitorCollection::Stats::Snapshot::streamQueueRate, stor::ThroughputMonitorCollection::Stats::Snapshot::writtenEventsBandwidth, and stor::ThroughputMonitorCollection::Stats::Snapshot::writtenEventsRate.
Referenced by getStats().
{
MonitoredQuantity::Stats fqEntryCountMQ, fqMemoryUsedMQ, fragSizeMQ;
MonitoredQuantity::Stats fpIdleMQ, fsEntryCountMQ, fsMemoryUsedMQ;
MonitoredQuantity::Stats sqEntryCountMQ, sqMemoryUsedMQ, eventSizeMQ, dwIdleMQ, diskWriteMQ;
MonitoredQuantity::Stats dqEntryCountMQ, dqMemoryUsedMQ, dqmEventSizeMQ, dqmIdleMQ, poolUsageMQ;
poolUsageMQ_.getStats(poolUsageMQ);
entriesInFragmentQueueMQ_.getStats(fqEntryCountMQ);
memoryUsedInFragmentQueueMQ_.getStats(fqMemoryUsedMQ);
poppedFragmentSizeMQ_.getStats(fragSizeMQ);
fragmentProcessorIdleTimeMQ_.getStats(fpIdleMQ);
entriesInFragmentStoreMQ_.getStats(fsEntryCountMQ);
memoryUsedInFragmentStoreMQ_.getStats(fsMemoryUsedMQ);
entriesInStreamQueueMQ_.getStats(sqEntryCountMQ);
memoryUsedInStreamQueueMQ_.getStats(sqMemoryUsedMQ);
poppedEventSizeMQ_.getStats(eventSizeMQ);
diskWriterIdleTimeMQ_.getStats(dwIdleMQ);
diskWriteSizeMQ_.getStats(diskWriteMQ);
entriesInDQMEventQueueMQ_.getStats(dqEntryCountMQ);
memoryUsedInDQMEventQueueMQ_.getStats(dqMemoryUsedMQ);
poppedDQMEventSizeMQ_.getStats(dqmEventSizeMQ);
dqmEventProcessorIdleTimeMQ_.getStats(dqmIdleMQ);
stats.reset();
smoothIdleTimes(fpIdleMQ);
smoothIdleTimes(dwIdleMQ);
smoothIdleTimes(dqmIdleMQ);
utils::Duration_t relativeTime = fqEntryCountMQ.recentDuration;
const int lowestBin = sampleCount<binCount_ ? binCount_-sampleCount : 0;
for (int idx = (binCount_ - 1); idx >= lowestBin; --idx)
{
utils::Duration_t binDuration = fqEntryCountMQ.recentBinnedDurations[idx];
relativeTime -= binDuration;
if (binDuration < boost::posix_time::milliseconds(10)) continue; //avoid very short durations
Stats::Snapshot snapshot;
snapshot.duration = binDuration;
snapshot.absoluteTime = fqEntryCountMQ.recentBinnedSnapshotTimes[idx];
// memory pool usage
snapshot.poolUsage = poolUsageMQ.recentBinnedSampleCounts[idx]>0 ?
poolUsageMQ.recentBinnedValueSums[idx]/poolUsageMQ.recentBinnedSampleCounts[idx] :
0;
// number of fragments in fragment queue
snapshot.entriesInFragmentQueue = fqEntryCountMQ.recentBinnedSampleCounts[idx]>0 ?
fqEntryCountMQ.recentBinnedValueSums[idx]/fqEntryCountMQ.recentBinnedSampleCounts[idx] :
0;
// memory usage in fragment queue
snapshot.memoryUsedInFragmentQueue = fqMemoryUsedMQ.recentBinnedSampleCounts[idx]>0 ?
fqMemoryUsedMQ.recentBinnedValueSums[idx]/fqMemoryUsedMQ.recentBinnedSampleCounts[idx] :
0;
// rate/bandwidth of fragments popped from fragment queue
getRateAndBandwidth(fragSizeMQ, idx, snapshot.fragmentQueueRate, snapshot.fragmentQueueBandwidth);
// number of events in fragment store
snapshot.fragmentStoreSize = fsEntryCountMQ.recentBinnedSampleCounts[idx]>0 ?
fsEntryCountMQ.recentBinnedValueSums[idx]/fsEntryCountMQ.recentBinnedSampleCounts[idx]>0 :
0;
// memory usage in fragment store
snapshot.fragmentStoreMemoryUsed = fsMemoryUsedMQ.recentBinnedSampleCounts[idx]>0 ?
fsMemoryUsedMQ.recentBinnedValueSums[idx]/fsMemoryUsedMQ.recentBinnedSampleCounts[idx] :
0;
// number of events in stream queue
snapshot.entriesInStreamQueue = sqEntryCountMQ.recentBinnedSampleCounts[idx]>0 ?
sqEntryCountMQ.recentBinnedValueSums[idx]/sqEntryCountMQ.recentBinnedSampleCounts[idx]>0 :
0;
// memory usage in stream queue
snapshot.memoryUsedInStreamQueue = sqMemoryUsedMQ.recentBinnedSampleCounts[idx]>0 ?
sqMemoryUsedMQ.recentBinnedValueSums[idx]/sqMemoryUsedMQ.recentBinnedSampleCounts[idx] :
0;
// rate/bandwidth of events popped from stream queue
getRateAndBandwidth(eventSizeMQ, idx, snapshot.streamQueueRate, snapshot.streamQueueBandwidth);
// rate/bandwidth of events written to disk
getRateAndBandwidth(diskWriteMQ, idx, snapshot.writtenEventsRate, snapshot.writtenEventsBandwidth);
// number of dqm events in DQMEvent queue
snapshot.entriesInDQMQueue = dqEntryCountMQ.recentBinnedSampleCounts[idx]>0 ?
dqEntryCountMQ.recentBinnedValueSums[idx]/dqEntryCountMQ.recentBinnedSampleCounts[idx] :
0;
// memory usage in DQMEvent queue
snapshot.memoryUsedInDQMQueue = dqMemoryUsedMQ.recentBinnedSampleCounts[idx]>0 ?
dqMemoryUsedMQ.recentBinnedValueSums[idx]/dqMemoryUsedMQ.recentBinnedSampleCounts[idx] :
0;
// rate/bandwidth of dqm events popped from DQMEvent queue
getRateAndBandwidth(dqmEventSizeMQ, idx, snapshot.dqmQueueRate, snapshot.dqmQueueBandwidth);
// fragment processor thread busy percentage
snapshot.fragmentProcessorBusy =
calcBusyPercentage(fpIdleMQ, idx);
// disk writer thread busy percentage
snapshot.diskWriterBusy =
calcBusyPercentage(dwIdleMQ, idx);
// DQMEvent processor thread busy percentage
snapshot.dqmEventProcessorBusy =
calcBusyPercentage(dqmIdleMQ, idx);
stats.average += snapshot;
stats.snapshots.push_back(snapshot);
}
const size_t snapshotCount = stats.snapshots.size();
if (snapshotCount > 0)
{
stats.average /= snapshotCount;
}
}
| void ThroughputMonitorCollection::do_reset | ( | ) | [private, virtual] |
Implements stor::MonitorCollection.
Definition at line 387 of file ThroughputMonitorCollection.cc.
References diskWriterIdleTimeMQ_, diskWriteSizeMQ_, dqmEventProcessorIdleTimeMQ_, entriesInDQMEventQueueMQ_, entriesInFragmentQueueMQ_, entriesInFragmentStoreMQ_, entriesInStreamQueueMQ_, fragmentProcessorIdleTimeMQ_, memoryUsedInDQMEventQueueMQ_, memoryUsedInFragmentQueueMQ_, memoryUsedInFragmentStoreMQ_, memoryUsedInStreamQueueMQ_, poolUsageMQ_, poppedDQMEventSizeMQ_, poppedEventSizeMQ_, poppedFragmentSizeMQ_, and stor::MonitoredQuantity::reset().
{
poolUsageMQ_.reset();
entriesInFragmentQueueMQ_.reset();
memoryUsedInFragmentQueueMQ_.reset();
poppedFragmentSizeMQ_.reset();
fragmentProcessorIdleTimeMQ_.reset();
entriesInFragmentStoreMQ_.reset();
memoryUsedInFragmentStoreMQ_.reset();
entriesInStreamQueueMQ_.reset();
memoryUsedInStreamQueueMQ_.reset();
poppedEventSizeMQ_.reset();
diskWriterIdleTimeMQ_.reset();
diskWriteSizeMQ_.reset();
entriesInDQMEventQueueMQ_.reset();
memoryUsedInDQMEventQueueMQ_.reset();
poppedDQMEventSizeMQ_.reset();
dqmEventProcessorIdleTimeMQ_.reset();
}
| void ThroughputMonitorCollection::do_updateInfoSpaceItems | ( | ) | [private, virtual] |
Reimplemented from stor::MonitorCollection.
Definition at line 434 of file ThroughputMonitorCollection.cc.
References stor::ThroughputMonitorCollection::Stats::average, averagingTime_, diskWriterBusy_, dqmEventProcessorBusy_, dqmQueueBandwidth_, dqmQueueRate_, stor::utils::durationToSeconds(), entriesInDQMQueue_, entriesInFragmentQueue_, entriesInStreamQueue_, fragmentProcessorBusy_, fragmentQueueBandwidth_, fragmentQueueRate_, fragmentStoreMemoryUsed_, fragmentStoreSize_, getStats(), memoryUsedInDQMQueue_, memoryUsedInFragmentQueue_, memoryUsedInStreamQueue_, poolUsage_, streamQueueBandwidth_, streamQueueRate_, throuphputAveragingCycles_, writtenEventsBandwidth_, and writtenEventsRate_.
{
Stats stats;
getStats(stats, throuphputAveragingCycles_);
poolUsage_ = static_cast<unsigned int>(stats.average.poolUsage);
entriesInFragmentQueue_ = static_cast<unsigned int>(stats.average.entriesInFragmentQueue);
memoryUsedInFragmentQueue_ = stats.average.memoryUsedInFragmentQueue;
fragmentQueueRate_ = stats.average.fragmentQueueRate;
fragmentQueueBandwidth_ = stats.average.fragmentQueueBandwidth;
fragmentStoreSize_ = static_cast<unsigned int>(stats.average.fragmentStoreSize);
fragmentStoreMemoryUsed_ = stats.average.fragmentStoreMemoryUsed;
entriesInStreamQueue_ = static_cast<unsigned int>(stats.average.entriesInStreamQueue);
memoryUsedInStreamQueue_ = stats.average.memoryUsedInStreamQueue;
streamQueueRate_ = stats.average.streamQueueRate;
streamQueueBandwidth_ = stats.average.streamQueueBandwidth;
writtenEventsRate_ = stats.average.writtenEventsRate;
writtenEventsBandwidth_ = stats.average.writtenEventsBandwidth;
entriesInDQMQueue_ = static_cast<unsigned int>(stats.average.entriesInDQMQueue);
memoryUsedInDQMQueue_ = stats.average.memoryUsedInDQMQueue;
dqmQueueRate_ = stats.average.dqmQueueRate;
dqmQueueBandwidth_ = stats.average.dqmQueueBandwidth;
fragmentProcessorBusy_ = stats.average.fragmentProcessorBusy;
diskWriterBusy_ = stats.average.diskWriterBusy;
dqmEventProcessorBusy_ = stats.average.dqmEventProcessorBusy;
averagingTime_ = utils::durationToSeconds(stats.average.duration);
}
| int stor::ThroughputMonitorCollection::getBinCount | ( | ) | const [inline] |
Definition at line 41 of file ThroughputMonitorCollection.h.
References binCount_.
{return binCount_;}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getDiskWriteMQ | ( | ) | [inline] |
Definition at line 147 of file ThroughputMonitorCollection.h.
References diskWriteSizeMQ_.
{
return diskWriteSizeMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getDiskWriteMQ | ( | ) | const [inline] |
Definition at line 144 of file ThroughputMonitorCollection.h.
References diskWriteSizeMQ_.
{
return diskWriteSizeMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getDiskWriterIdleMQ | ( | ) | const [inline] |
Definition at line 135 of file ThroughputMonitorCollection.h.
References diskWriterIdleTimeMQ_.
{
return diskWriterIdleTimeMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getDiskWriterIdleMQ | ( | ) | [inline] |
Definition at line 138 of file ThroughputMonitorCollection.h.
References diskWriterIdleTimeMQ_.
{
return diskWriterIdleTimeMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getDQMEventProcessorIdleMQ | ( | ) | const [inline] |
Definition at line 180 of file ThroughputMonitorCollection.h.
References dqmEventProcessorIdleTimeMQ_.
{
return dqmEventProcessorIdleTimeMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getDQMEventProcessorIdleMQ | ( | ) | [inline] |
Definition at line 183 of file ThroughputMonitorCollection.h.
References dqmEventProcessorIdleTimeMQ_.
{
return dqmEventProcessorIdleTimeMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getDQMEventQueueEntryCountMQ | ( | ) | const [inline] |
Definition at line 155 of file ThroughputMonitorCollection.h.
References entriesInDQMEventQueueMQ_.
{
return entriesInDQMEventQueueMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getDQMEventQueueEntryCountMQ | ( | ) | [inline] |
Definition at line 158 of file ThroughputMonitorCollection.h.
References entriesInDQMEventQueueMQ_.
{
return entriesInDQMEventQueueMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getDQMEventQueueMemoryUsedMQ | ( | ) | const [inline] |
Definition at line 162 of file ThroughputMonitorCollection.h.
References memoryUsedInDQMEventQueueMQ_.
{
return memoryUsedInDQMEventQueueMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getDQMEventQueueMemoryUsedMQ | ( | ) | [inline] |
Definition at line 165 of file ThroughputMonitorCollection.h.
References memoryUsedInDQMEventQueueMQ_.
{
return memoryUsedInDQMEventQueueMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentProcessorIdleMQ | ( | ) | const [inline] |
Definition at line 85 of file ThroughputMonitorCollection.h.
References fragmentProcessorIdleTimeMQ_.
{
return fragmentProcessorIdleTimeMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentProcessorIdleMQ | ( | ) | [inline] |
Definition at line 88 of file ThroughputMonitorCollection.h.
References fragmentProcessorIdleTimeMQ_.
{
return fragmentProcessorIdleTimeMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentQueueEntryCountMQ | ( | ) | const [inline] |
Definition at line 60 of file ThroughputMonitorCollection.h.
References entriesInFragmentQueueMQ_.
{
return entriesInFragmentQueueMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentQueueEntryCountMQ | ( | ) | [inline] |
Definition at line 63 of file ThroughputMonitorCollection.h.
References entriesInFragmentQueueMQ_.
{
return entriesInFragmentQueueMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentQueueMemoryUsedMQ | ( | ) | [inline] |
Definition at line 70 of file ThroughputMonitorCollection.h.
References memoryUsedInFragmentQueueMQ_.
{
return memoryUsedInFragmentQueueMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentQueueMemoryUsedMQ | ( | ) | const [inline] |
Definition at line 67 of file ThroughputMonitorCollection.h.
References memoryUsedInFragmentQueueMQ_.
{
return memoryUsedInFragmentQueueMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentStoreEntryCountMQ | ( | ) | const [inline] |
Definition at line 92 of file ThroughputMonitorCollection.h.
References entriesInFragmentStoreMQ_.
{
return entriesInFragmentStoreMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentStoreEntryCountMQ | ( | ) | [inline] |
Definition at line 95 of file ThroughputMonitorCollection.h.
References entriesInFragmentStoreMQ_.
{
return entriesInFragmentStoreMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentStoreMemoryUsedMQ | ( | ) | const [inline] |
Definition at line 99 of file ThroughputMonitorCollection.h.
References memoryUsedInFragmentStoreMQ_.
{
return memoryUsedInFragmentStoreMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getFragmentStoreMemoryUsedMQ | ( | ) | [inline] |
Definition at line 102 of file ThroughputMonitorCollection.h.
References memoryUsedInFragmentStoreMQ_.
{
return memoryUsedInFragmentStoreMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getPoolUsageMQ | ( | ) | const [inline] |
Definition at line 53 of file ThroughputMonitorCollection.h.
References poolUsageMQ_.
{
return poolUsageMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getPoolUsageMQ | ( | ) | [inline] |
Definition at line 56 of file ThroughputMonitorCollection.h.
References poolUsageMQ_.
{
return poolUsageMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getPoppedDQMEventSizeMQ | ( | ) | const [inline] |
Definition at line 171 of file ThroughputMonitorCollection.h.
References poppedDQMEventSizeMQ_.
{
return poppedDQMEventSizeMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getPoppedDQMEventSizeMQ | ( | ) | [inline] |
Definition at line 174 of file ThroughputMonitorCollection.h.
References poppedDQMEventSizeMQ_.
{
return poppedDQMEventSizeMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getPoppedEventSizeMQ | ( | ) | [inline] |
Definition at line 129 of file ThroughputMonitorCollection.h.
References poppedEventSizeMQ_.
{
return poppedEventSizeMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getPoppedEventSizeMQ | ( | ) | const [inline] |
Definition at line 126 of file ThroughputMonitorCollection.h.
References poppedEventSizeMQ_.
{
return poppedEventSizeMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getPoppedFragmentSizeMQ | ( | ) | const [inline] |
Definition at line 76 of file ThroughputMonitorCollection.h.
References poppedFragmentSizeMQ_.
{
return poppedFragmentSizeMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getPoppedFragmentSizeMQ | ( | ) | [inline] |
Definition at line 79 of file ThroughputMonitorCollection.h.
References poppedFragmentSizeMQ_.
{
return poppedFragmentSizeMQ_;
}
| void ThroughputMonitorCollection::getRateAndBandwidth | ( | MonitoredQuantity::Stats & | stats, |
| const int & | idx, | ||
| double & | rate, | ||
| double & | bandwidth | ||
| ) | const [private] |
Definition at line 295 of file ThroughputMonitorCollection.cc.
References stor::utils::durationToSeconds(), UserOptions_cff::idx, stor::MonitoredQuantity::Stats::recentBinnedDurations, stor::MonitoredQuantity::Stats::recentBinnedSampleCounts, and stor::MonitoredQuantity::Stats::recentBinnedValueSums.
Referenced by do_getStats().
{
const double recentBinnedDuration = utils::durationToSeconds(stats.recentBinnedDurations[idx]);
if (recentBinnedDuration > 0)
{
rate =
stats.recentBinnedSampleCounts[idx] / recentBinnedDuration;
bandwidth =
stats.recentBinnedValueSums[idx] / (1024*1024)
/ recentBinnedDuration;
}
}
| void ThroughputMonitorCollection::getStats | ( | Stats & | stats | ) | const |
Write all our collected statistics into the given Stats struct.
Definition at line 109 of file ThroughputMonitorCollection.cc.
References binCount_, do_getStats(), and statsMutex_.
Referenced by stor::SMWebPageHelper::addDOMforResourceUsage(), stor::SMWebPageHelper::addDOMforThroughputStatistics(), and do_updateInfoSpaceItems().
{
boost::mutex::scoped_lock sl(statsMutex_);
do_getStats(stats, binCount_);
}
| void ThroughputMonitorCollection::getStats | ( | Stats & | stats, |
| const unsigned int | sampleCount | ||
| ) | const |
Write only the sampleCount most recent snapshots into the given Stats struct.
Definition at line 116 of file ThroughputMonitorCollection.cc.
References do_getStats(), and statsMutex_.
{
boost::mutex::scoped_lock sl(statsMutex_);
do_getStats(stats, sampleCount);
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getStreamQueueEntryCountMQ | ( | ) | const [inline] |
Definition at line 110 of file ThroughputMonitorCollection.h.
References entriesInStreamQueueMQ_.
{
return entriesInStreamQueueMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getStreamQueueEntryCountMQ | ( | ) | [inline] |
Definition at line 113 of file ThroughputMonitorCollection.h.
References entriesInStreamQueueMQ_.
{
return entriesInStreamQueueMQ_;
}
| MonitoredQuantity& stor::ThroughputMonitorCollection::getStreamQueueMemoryUsedMQ | ( | ) | [inline] |
Definition at line 120 of file ThroughputMonitorCollection.h.
References memoryUsedInStreamQueueMQ_.
{
return memoryUsedInStreamQueueMQ_;
}
| const MonitoredQuantity& stor::ThroughputMonitorCollection::getStreamQueueMemoryUsedMQ | ( | ) | const [inline] |
Definition at line 117 of file ThroughputMonitorCollection.h.
References memoryUsedInStreamQueueMQ_.
{
return memoryUsedInStreamQueueMQ_;
}
| ThroughputMonitorCollection& stor::ThroughputMonitorCollection::operator= | ( | ThroughputMonitorCollection const & | ) | [private] |
| void stor::ThroughputMonitorCollection::setDQMEventQueue | ( | DQMEventQueuePtr | dqmEventQueue | ) | [inline] |
Definition at line 151 of file ThroughputMonitorCollection.h.
References dqmEventQueue_.
{
dqmEventQueue_ = dqmEventQueue;
}
| void stor::ThroughputMonitorCollection::setFragmentQueue | ( | FragmentQueuePtr | fragmentQueue | ) | [inline] |
Definition at line 49 of file ThroughputMonitorCollection.h.
References fragmentQueue_.
{
fragmentQueue_ = fragmentQueue;
}
| void stor::ThroughputMonitorCollection::setFragmentStoreMemoryUsed | ( | size_t | memoryUsed | ) | [inline] |
Sets the current number of events in the fragment store.
Definition at line 197 of file ThroughputMonitorCollection.h.
References currentFragmentStoreMemoryUsedMB_.
Referenced by stor::Processing::do_processI2OFragment().
{
currentFragmentStoreMemoryUsedMB_ = static_cast<double>(memoryUsed) / (1024*1024);
}
| void stor::ThroughputMonitorCollection::setFragmentStoreSize | ( | unsigned int | size | ) | [inline] |
Sets the current number of events in the fragment store.
Definition at line 190 of file ThroughputMonitorCollection.h.
References currentFragmentStoreSize_, and findQualityFiles::size.
Referenced by stor::Processing::do_processI2OFragment().
{
currentFragmentStoreSize_ = size;
}
| void ThroughputMonitorCollection::setMemoryPoolPointer | ( | toolbox::mem::Pool * | pool | ) |
Stores the given memory pool pointer if not yet set. If it is already set, the argument is ignored.
Definition at line 39 of file ThroughputMonitorCollection.cc.
References fetchall_from_DQM_v2::pool, and pool_.
Referenced by stor::StorageManager::receiveRegistryMessage().
| void stor::ThroughputMonitorCollection::setStreamQueue | ( | StreamQueuePtr | streamQueue | ) | [inline] |
Definition at line 106 of file ThroughputMonitorCollection.h.
References streamQueue_.
{
streamQueue_ = streamQueue;
}
| void ThroughputMonitorCollection::smoothIdleTimes | ( | MonitoredQuantity::Stats & | stats | ) | const [private] |
Smooth out binned idle times for the throughput display. Returns the index to be used for the next section to smooth. Note that this method works on the idleTimes and durations lists in *reverse* order. So, the initial indices should be idleTimes.size()-1.
Definition at line 246 of file ThroughputMonitorCollection.cc.
References binCount_, getHLTprescales::index, stor::MonitoredQuantity::Stats::recentBinnedDurations, stor::MonitoredQuantity::Stats::recentBinnedValueSums, and smoothIdleTimesHelper().
Referenced by do_getStats().
{
int index = binCount_ - 1;
while (index >= 0)
{
index = smoothIdleTimesHelper(stats.recentBinnedValueSums,
stats.recentBinnedDurations,
index, index);
}
}
| int ThroughputMonitorCollection::smoothIdleTimesHelper | ( | std::vector< double > & | idleTimes, |
| std::vector< utils::Duration_t > & | durations, | ||
| int | firstIndex, | ||
| int | lastIndex | ||
| ) | const [private] |
Definition at line 259 of file ThroughputMonitorCollection.cc.
References stor::utils::durationToSeconds(), UserOptions_cff::idx, and stor::utils::secondsToDuration().
Referenced by smoothIdleTimes().
{
int workingSize = lastIndex - firstIndex + 1;
double idleTimeSum = 0;
double durationSum = 0;
for (int idx = firstIndex; idx <= lastIndex; ++idx)
{
idleTimeSum += idleTimes[idx];
durationSum += utils::durationToSeconds(durations[idx]);
}
if (idleTimeSum > durationSum && firstIndex > 0)
{
return smoothIdleTimesHelper(idleTimes, durations, firstIndex-1, lastIndex);
}
else
{
if (lastIndex > firstIndex)
{
for (int idx = firstIndex; idx <= lastIndex; ++idx)
{
idleTimes[idx] = idleTimeSum / workingSize;
durations[idx] = utils::secondsToDuration(durationSum / workingSize);
}
}
return (firstIndex - 1);
}
}
xdata::Double stor::ThroughputMonitorCollection::averagingTime_ [private] |
Definition at line 352 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
const unsigned int stor::ThroughputMonitorCollection::binCount_ [private] |
Definition at line 299 of file ThroughputMonitorCollection.h.
Referenced by do_getStats(), getBinCount(), getStats(), and smoothIdleTimes().
double stor::ThroughputMonitorCollection::currentFragmentStoreMemoryUsedMB_ [private] |
Definition at line 326 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), and setFragmentStoreMemoryUsed().
unsigned int stor::ThroughputMonitorCollection::currentFragmentStoreSize_ [private] |
Definition at line 325 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), and setFragmentStoreSize().
xdata::Double stor::ThroughputMonitorCollection::diskWriterBusy_ [private] |
Definition at line 350 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 313 of file ThroughputMonitorCollection.h.
Referenced by addDiskWriterIdleSample(), do_calculateStatistics(), do_getStats(), do_reset(), and getDiskWriterIdleMQ().
Definition at line 314 of file ThroughputMonitorCollection.h.
Referenced by addDiskWriteSample(), do_calculateStatistics(), do_getStats(), do_reset(), and getDiskWriteMQ().
xdata::Double stor::ThroughputMonitorCollection::dqmEventProcessorBusy_ [private] |
Definition at line 351 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 319 of file ThroughputMonitorCollection.h.
Referenced by addDQMEventProcessorIdleSample(), do_calculateStatistics(), do_getStats(), do_reset(), and getDQMEventProcessorIdleMQ().
Definition at line 323 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), and setDQMEventQueue().
xdata::Double stor::ThroughputMonitorCollection::dqmQueueBandwidth_ [private] |
Definition at line 347 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::Double stor::ThroughputMonitorCollection::dqmQueueRate_ [private] |
Definition at line 346 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 316 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), do_getStats(), do_reset(), and getDQMEventQueueEntryCountMQ().
xdata::UnsignedInteger32 stor::ThroughputMonitorCollection::entriesInDQMQueue_ [private] |
Definition at line 344 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::UnsignedInteger32 stor::ThroughputMonitorCollection::entriesInFragmentQueue_ [private] |
Definition at line 332 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 303 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), do_getStats(), do_reset(), and getFragmentQueueEntryCountMQ().
Definition at line 307 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), do_getStats(), do_reset(), and getFragmentStoreEntryCountMQ().
xdata::UnsignedInteger32 stor::ThroughputMonitorCollection::entriesInStreamQueue_ [private] |
Definition at line 338 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 310 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), do_getStats(), do_reset(), and getStreamQueueEntryCountMQ().
xdata::Double stor::ThroughputMonitorCollection::fragmentProcessorBusy_ [private] |
Definition at line 349 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 306 of file ThroughputMonitorCollection.h.
Referenced by addFragmentProcessorIdleSample(), do_calculateStatistics(), do_getStats(), do_reset(), and getFragmentProcessorIdleMQ().
Definition at line 321 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), and setFragmentQueue().
xdata::Double stor::ThroughputMonitorCollection::fragmentQueueBandwidth_ [private] |
Definition at line 335 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::Double stor::ThroughputMonitorCollection::fragmentQueueRate_ [private] |
Definition at line 334 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::Double stor::ThroughputMonitorCollection::fragmentStoreMemoryUsed_ [private] |
Definition at line 337 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::UnsignedInteger32 stor::ThroughputMonitorCollection::fragmentStoreSize_ [private] |
Definition at line 336 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 317 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), do_getStats(), do_reset(), and getDQMEventQueueMemoryUsedMQ().
xdata::Double stor::ThroughputMonitorCollection::memoryUsedInDQMQueue_ [private] |
Definition at line 345 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::Double stor::ThroughputMonitorCollection::memoryUsedInFragmentQueue_ [private] |
Definition at line 333 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 304 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), do_getStats(), do_reset(), and getFragmentQueueMemoryUsedMQ().
Definition at line 308 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), do_getStats(), do_reset(), and getFragmentStoreMemoryUsedMQ().
xdata::Double stor::ThroughputMonitorCollection::memoryUsedInStreamQueue_ [private] |
Definition at line 339 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 311 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), do_getStats(), do_reset(), and getStreamQueueMemoryUsedMQ().
toolbox::mem::Pool* stor::ThroughputMonitorCollection::pool_ [private] |
Definition at line 329 of file ThroughputMonitorCollection.h.
Referenced by calcPoolUsage(), and setMemoryPoolPointer().
xdata::UnsignedInteger32 stor::ThroughputMonitorCollection::poolUsage_ [private] |
Definition at line 331 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
Definition at line 302 of file ThroughputMonitorCollection.h.
Referenced by calcPoolUsage(), do_getStats(), do_reset(), and getPoolUsageMQ().
Definition at line 318 of file ThroughputMonitorCollection.h.
Referenced by addPoppedDQMEventSample(), do_calculateStatistics(), do_getStats(), do_reset(), and getPoppedDQMEventSizeMQ().
Definition at line 312 of file ThroughputMonitorCollection.h.
Referenced by addPoppedEventSample(), do_calculateStatistics(), do_getStats(), do_reset(), and getPoppedEventSizeMQ().
Definition at line 305 of file ThroughputMonitorCollection.h.
Referenced by addPoppedFragmentSample(), do_calculateStatistics(), do_getStats(), do_reset(), and getPoppedFragmentSizeMQ().
boost::mutex stor::ThroughputMonitorCollection::statsMutex_ [mutable, private] |
Definition at line 300 of file ThroughputMonitorCollection.h.
Referenced by getStats().
Definition at line 322 of file ThroughputMonitorCollection.h.
Referenced by do_calculateStatistics(), and setStreamQueue().
xdata::Double stor::ThroughputMonitorCollection::streamQueueBandwidth_ [private] |
Definition at line 341 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::Double stor::ThroughputMonitorCollection::streamQueueRate_ [private] |
Definition at line 340 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
unsigned int stor::ThroughputMonitorCollection::throuphputAveragingCycles_ [private] |
Definition at line 327 of file ThroughputMonitorCollection.h.
Referenced by do_updateInfoSpaceItems().
xdata::Double stor::ThroughputMonitorCollection::writtenEventsBandwidth_ [private] |
Definition at line 343 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
xdata::Double stor::ThroughputMonitorCollection::writtenEventsRate_ [private] |
Definition at line 342 of file ThroughputMonitorCollection.h.
Referenced by do_appendInfoSpaceItems(), and do_updateInfoSpaceItems().
1.7.3