#include <FragmentMonitorCollection.h>

Inheritance diagram for stor::FragmentMonitorCollection:

Classes
struct	FragmentStats

Public Member Functions
void	addDQMEventFragmentSample (const double bytecount)

void	addEventFragmentSample (const double bytecount)

void	addFragmentSample (const double bytecount)

	FragmentMonitorCollection (const utils::Duration_t &updateInterval)

const MonitoredQuantity &	getAllFragmentBandwidthMQ () const

MonitoredQuantity &	getAllFragmentBandwidthMQ ()

const MonitoredQuantity &	getAllFragmentSizeMQ () const

MonitoredQuantity &	getAllFragmentSizeMQ ()

const MonitoredQuantity &	getDQMEventFragmentBandwidthMQ () const

MonitoredQuantity &	getDQMEventFragmentBandwidthMQ ()

const MonitoredQuantity &	getDQMEventFragmentSizeMQ () const

MonitoredQuantity &	getDQMEventFragmentSizeMQ ()

const MonitoredQuantity &	getEventFragmentBandwidthMQ () const

MonitoredQuantity &	getEventFragmentBandwidthMQ ()

const MonitoredQuantity &	getEventFragmentSizeMQ () const

MonitoredQuantity &	getEventFragmentSizeMQ ()

void	getStats (FragmentStats &stats) const

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 ()

	FragmentMonitorCollection (FragmentMonitorCollection const &)

FragmentMonitorCollection &	operator= (FragmentMonitorCollection const &)

Private Attributes
MonitoredQuantity	allFragmentBandwidth_

MonitoredQuantity	allFragmentSizes_

MonitoredQuantity	dqmEventFragmentBandwidth_

MonitoredQuantity	dqmEventFragmentSizes_

MonitoredQuantity	eventFragmentBandwidth_

MonitoredQuantity	eventFragmentSizes_

xdata::Double	instantBandwidth_

xdata::Double	instantRate_

xdata::UnsignedInteger32	receivedFrames_

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.8

Date:: 2011/03/07 15:31:32

Definition at line 23 of file FragmentMonitorCollection.h.

Constructor & Destructor Documentation

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

Member Function Documentation

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 )

privatevirtual

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 ( )

privatevirtual

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 ( )

privatevirtual

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 ( )

privatevirtual

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));
   }

const MonitoredQuantity& stor::FragmentMonitorCollection::getAllFragmentBandwidthMQ ( ) const

inline

Definition at line 89 of file FragmentMonitorCollection.h.

References allFragmentBandwidth_.

Referenced by getStats().

                                                                {
       return allFragmentBandwidth_;
     }

MonitoredQuantity& stor::FragmentMonitorCollection::getAllFragmentBandwidthMQ ( )

inline

Definition at line 92 of file FragmentMonitorCollection.h.

References allFragmentBandwidth_.

                                                    {
       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_;
     }

const MonitoredQuantity& stor::FragmentMonitorCollection::getDQMEventFragmentBandwidthMQ ( ) const

inline

Definition at line 103 of file FragmentMonitorCollection.h.

References dqmEventFragmentBandwidth_.

Referenced by getStats().

                                                                     {
       return dqmEventFragmentBandwidth_;
     }

MonitoredQuantity& stor::FragmentMonitorCollection::getDQMEventFragmentBandwidthMQ ( )

inline

Definition at line 106 of file FragmentMonitorCollection.h.

References dqmEventFragmentBandwidth_.

                                                         {
       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_;
     }

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::getEventFragmentBandwidthMQ ( )

inline

Definition at line 99 of file FragmentMonitorCollection.h.

References eventFragmentBandwidth_.

                                                      {
       return eventFragmentBandwidth_;
     }

const MonitoredQuantity& stor::FragmentMonitorCollection::getEventFragmentSizeMQ ( ) const

inline

Definition at line 75 of file FragmentMonitorCollection.h.

References eventFragmentSizes_.

Referenced by getStats().

                                                             {
       return eventFragmentSizes_;
     }

MonitoredQuantity& stor::FragmentMonitorCollection::getEventFragmentSizeMQ ( )

inline

Definition at line 78 of file FragmentMonitorCollection.h.

References eventFragmentSizes_.

                                                 {
       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);
   }