#include <ConsumerMonitorCollection.h>

Inheritance diagram for stor::ConsumerMonitorCollection:

Classes
struct	TotalStats

Public Member Functions
void	addDroppedEvents (const QueueID &, const size_t &count)

void	addQueuedEventSample (const QueueID &, const unsigned int &data_size)

void	addServedEventSample (const QueueID &, const unsigned int &data_size)

	ConsumerMonitorCollection (const utils::Duration_t &updateInterval, const utils::Duration_t &recentDuration)

bool	getDropped (const QueueID &qid, MonitoredQuantity::Stats &result) const

bool	getQueued (const QueueID &qid, MonitoredQuantity::Stats &result) const

bool	getServed (const QueueID &qid, MonitoredQuantity::Stats &result) const

void	getTotalStats (TotalStats &) const

void	resetCounters ()

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

Protected Attributes
ConsStatMap	dmap_

boost::mutex	mutex_

ConsStatMap	qmap_

ConsStatMap	smap_

Private Types
typedef std::map< QueueID, MonitoredQuantityPtr >	ConsStatMap

Private Member Functions
void	addEventSampleToMap (const QueueID &, const unsigned int &data_size, ConsStatMap &)

	ConsumerMonitorCollection (const ConsumerMonitorCollection &)

virtual void	do_calculateStatistics ()

virtual void	do_reset ()

bool	getValueFromMap (const QueueID &, MonitoredQuantity::Stats &, const ConsStatMap &) const

ConsumerMonitorCollection &	operator= (const ConsumerMonitorCollection &)

Private Attributes
const utils::Duration_t	recentDuration_

MonitoredQuantity	totalDroppedMQ_

MonitoredQuantity	totalQueuedMQ_

MonitoredQuantity	totalServedMQ_

const utils::Duration_t	updateInterval_

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

Protected Member Functions inherited from stor::MonitorCollection
virtual void	do_appendInfoSpaceItems (InfoSpaceItems &)

virtual void	do_updateInfoSpaceItems ()

Detailed Description

A collection of MonitoredQuantities to track consumer activity.

Author:: mommsen

Revision:: 1.12

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

Definition at line 28 of file ConsumerMonitorCollection.h.

Member Typedef Documentation

typedef std::map<QueueID, MonitoredQuantityPtr> stor::ConsumerMonitorCollection::ConsStatMap

private

Definition at line 92 of file ConsumerMonitorCollection.h.

Constructor & Destructor Documentation

stor::ConsumerMonitorCollection::ConsumerMonitorCollection	(	const utils::Duration_t &	updateInterval,
		const utils::Duration_t &	recentDuration
	)

explicit

Definition at line 12 of file ConsumerMonitorCollection.cc.

    :
   MonitorCollection(updateInterval),
   updateInterval_(updateInterval),
   recentDuration_(recentDuration),
   totalQueuedMQ_(updateInterval, recentDuration),
   totalDroppedMQ_(updateInterval, recentDuration),
   totalServedMQ_(updateInterval, recentDuration)
   {}

stor::ConsumerMonitorCollection::ConsumerMonitorCollection ( const ConsumerMonitorCollection & )

private

Member Function Documentation

void stor::ConsumerMonitorCollection::addDroppedEvents	(	const QueueID &	qid,
		const size_t &	count
	)

Add number of dropped events

Definition at line 38 of file ConsumerMonitorCollection.cc.

References prof2calltree::l.

   {
     boost::mutex::scoped_lock l( mutex_ );
     addEventSampleToMap(qid, count, dmap_);
     totalDroppedMQ_.addSample(count);
   }

void stor::ConsumerMonitorCollection::addEventSampleToMap	(	const QueueID &	qid,
		const unsigned int &	data_size,
		ConsStatMap &	map
	)

private

Definition at line 62 of file ConsumerMonitorCollection.cc.

References pos.

   {
     ConsStatMap::iterator pos = map.lower_bound(qid);
     
     // 05-Oct-2009, KAB - added a test of whether qid appears before pos->first
     // in the map sort order.  Since lower_bound can return a non-end iterator
     // even when qid is not in the map, we need to complete the test of whether
     // qid is in the map.  (Another way to look at this is we need to implement
     // the full test described in the efficientAddOrUpdates pattern suggested
     // by Item 24 of 'Effective STL' by Scott Meyers.)
     if (pos == map.end() || (map.key_comp()(qid, pos->first)))
     {
       // The key does not exist in the map, add it to the map
       // Use pos as a hint to insert, so it can avoid another lookup
       pos = map.insert(pos,
         ConsStatMap::value_type(qid, 
           MonitoredQuantityPtr(
             new MonitoredQuantity(updateInterval_, recentDuration_)
           )
         )
       );
     }
     
     pos->second->addSample( data_size );
   }

void stor::ConsumerMonitorCollection::addQueuedEventSample	(	const QueueID &	qid,
		const unsigned int &	data_size
	)

Add queued sample

Definition at line 26 of file ConsumerMonitorCollection.cc.

References prof2calltree::l.

   {
     boost::mutex::scoped_lock l( mutex_ );
     addEventSampleToMap(qid, data_size, qmap_);
     totalQueuedMQ_.addSample(data_size);
   }

void stor::ConsumerMonitorCollection::addServedEventSample	(	const QueueID &	qid,
		const unsigned int &	data_size
	)

Add served sample

Definition at line 50 of file ConsumerMonitorCollection.cc.

References prof2calltree::l.

   {
     boost::mutex::scoped_lock l( mutex_ );
     addEventSampleToMap(qid, data_size, smap_);
     totalServedMQ_.addSample(data_size);
   }

void stor::ConsumerMonitorCollection::do_calculateStatistics ( )

privatevirtual

Implements stor::MonitorCollection.

Definition at line 164 of file ConsumerMonitorCollection.cc.

References stor::MonitoredQuantity::calculateStatistics(), dmap_, i, prof2calltree::l, mutex_, qmap_, smap_, totalDroppedMQ_, totalQueuedMQ_, and totalServedMQ_.

   {
     boost::mutex::scoped_lock l( mutex_ );
     for( ConsStatMap::iterator i = qmap_.begin(); i != qmap_.end(); ++i )
       i->second->calculateStatistics();
     for( ConsStatMap::iterator i = smap_.begin(); i != smap_.end(); ++i )
       i->second->calculateStatistics();
     for( ConsStatMap::iterator i = dmap_.begin(); i != dmap_.end(); ++i )
       i->second->calculateStatistics();
     
     totalQueuedMQ_.calculateStatistics();
     totalDroppedMQ_.calculateStatistics();
     totalServedMQ_.calculateStatistics();
   }

void stor::ConsumerMonitorCollection::do_reset ( )

privatevirtual

Implements stor::MonitorCollection.

Definition at line 180 of file ConsumerMonitorCollection.cc.

References dmap_, prof2calltree::l, mutex_, qmap_, stor::MonitoredQuantity::reset(), smap_, totalDroppedMQ_, totalQueuedMQ_, and totalServedMQ_.

   {
     boost::mutex::scoped_lock l( mutex_ );
     qmap_.clear();
     smap_.clear();
     dmap_.clear();
     
     totalQueuedMQ_.reset();
     totalDroppedMQ_.reset();
     totalServedMQ_.reset();
   }

bool stor::ConsumerMonitorCollection::getDropped	(	const QueueID &	qid,
		MonitoredQuantity::Stats &	result
	)		const

Get number of dropped events. Return false if consumer ID not found.

Definition at line 116 of file ConsumerMonitorCollection.cc.

References prof2calltree::l.

   {
     boost::mutex::scoped_lock l( mutex_ );
     return getValueFromMap( qid, result, dmap_ );
   }

bool stor::ConsumerMonitorCollection::getQueued	(	const QueueID &	qid,
		MonitoredQuantity::Stats &	result
	)		const

Get queued data size. Return false if consumer ID not found.

Definition at line 94 of file ConsumerMonitorCollection.cc.

References prof2calltree::l.

   {
     boost::mutex::scoped_lock l( mutex_ );
     return getValueFromMap( qid, result, qmap_ );
   }

bool stor::ConsumerMonitorCollection::getServed	(	const QueueID &	qid,
		MonitoredQuantity::Stats &	result
	)		const

Get served data size. Return false if consumer ID not found.

Definition at line 105 of file ConsumerMonitorCollection.cc.

References prof2calltree::l.

Referenced by smproxy::SMPSWebPageHelper::addRowForEventType(), and stor::SMWebPageHelper::getServedConsumerBandwidth().

   {
     boost::mutex::scoped_lock l( mutex_ );
     return getValueFromMap( qid, result, smap_ );
   }

void stor::ConsumerMonitorCollection::getTotalStats ( TotalStats & totalStats ) const

Get the summary statistics for all consumers

Definition at line 141 of file ConsumerMonitorCollection.cc.

References stor::ConsumerMonitorCollection::TotalStats::droppedStats, stor::MonitoredQuantity::getStats(), stor::ConsumerMonitorCollection::TotalStats::queuedStats, stor::ConsumerMonitorCollection::TotalStats::servedStats, totalDroppedMQ_, totalQueuedMQ_, and totalServedMQ_.

Referenced by smproxy::SMPSWebPageHelper::addSummaryRowForThroughput().

   {
     totalQueuedMQ_.getStats(totalStats.queuedStats);
     totalDroppedMQ_.getStats(totalStats.droppedStats);
     totalServedMQ_.getStats(totalStats.servedStats);
   }

bool stor::ConsumerMonitorCollection::getValueFromMap	(	const QueueID &	qid,
		MonitoredQuantity::Stats &	result,
		const ConsStatMap &	map
	)		const

private

Definition at line 126 of file ConsumerMonitorCollection.cc.

References pos.

   {
     ConsStatMap::const_iterator pos = map.find(qid);
     
     if (pos == map.end()) return false;
     
     pos->second->getStats( result );
     return true;
   }

ConsumerMonitorCollection& stor::ConsumerMonitorCollection::operator= ( const ConsumerMonitorCollection & )

private

void stor::ConsumerMonitorCollection::resetCounters ( )

Reset sizes to zero leaving consumers in

Definition at line 148 of file ConsumerMonitorCollection.cc.

References dmap_, i, prof2calltree::l, mutex_, qmap_, stor::MonitoredQuantity::reset(), smap_, totalDroppedMQ_, totalQueuedMQ_, and totalServedMQ_.

   {
     boost::mutex::scoped_lock l( mutex_ );
     for( ConsStatMap::iterator i = qmap_.begin(); i != qmap_.end(); ++i )
       i->second->reset();
     for( ConsStatMap::iterator i = smap_.begin(); i != smap_.end(); ++i )
       i->second->reset();
     for( ConsStatMap::iterator i = dmap_.begin(); i != dmap_.end(); ++i )
       i->second->reset();
     
     totalQueuedMQ_.reset();
     totalDroppedMQ_.reset();
     totalServedMQ_.reset();
   }