/data/refman/pasoursint/CMSSW_5_3_3/src/EventFilter/StorageManager/src/EventConsumerMonitorCollection.cc

Go to the documentation of this file.

// $Id: EventConsumerMonitorCollection.cc,v 1.3 2011/03/07 15:31:32 mommsen Exp $

#include "EventFilter/StorageManager/interface/EventConsumerMonitorCollection.h"
#include "EventFilter/StorageManager/interface/QueueID.h"

using namespace stor;


EventConsumerMonitorCollection::EventConsumerMonitorCollection(const utils::Duration_t& updateInterval):
ConsumerMonitorCollection(updateInterval, boost::posix_time::seconds(10))
{}


void EventConsumerMonitorCollection::do_appendInfoSpaceItems(InfoSpaceItems& infoSpaceItems)
{
  infoSpaceItems.push_back(std::make_pair("eventConsumers", &eventConsumers_));
}


void EventConsumerMonitorCollection::do_updateInfoSpaceItems()
{
  boost::mutex::scoped_lock l( mutex_ );
  eventConsumers_ = smap_.size();
}