CMS 3D CMS Logo

stor Namespace Reference

This class serves as the base class for the smart counters used as part of storage manager monitoring. More...


Classes

class  BaseCounter
class  Configurator
class  ConsumerPipe
class  DataProcessManager
class  DQMConsumerPipe
class  DQMEventServer
class  DQMFolder
class  DQMGroup
class  DQMGroupDescriptor
class  DQMInstance
class  DQMServiceManager
class  EPRunner
class  ESRingBuffer
class  EventServer
class  EvtMsgRingBuffer
class  ForeverAverageCounter
class  ForeverCounter
struct  FragEntry
struct  FragKey
class  FragmentCollector
struct  FragmentContainer
class  FUProxy
class  HLTInfo
class  InitMsgCollection
class  JobController
class  Parameter
class  ProgressMarker
class  RateLimiter
struct  ReadData
class  RollingIntervalCounter
class  RollingSampleCounter
struct  SMFC_thread_data
struct  SMFUSenderDatCollection
struct  SMFUSenderEntry
class  SMFUSenderList
struct  SMFUSenderRegCollection
struct  SMFUSenderStats
struct  SMOnlyStats
class  SMPerformanceMeter
struct  SMPerfStats
class  SMProxyServer
class  StorageManager

Typedefs

typedef std::vector< unsigned
char > 		InitMsgBuffer
typedef boost::shared_ptr
< InitMsgBuffer > 		InitMsgSharedPtr

Functions

string changeToPhony (const string &config)
size_t func (void *buf, size_t size, size_t nmemb, void *userp)
bool getSMFC_exceptionStatus ()
std::string getSMFC_reason4Exception ()
static const std::string PROXY_SERVER_NAME ("SMProxyServer")
template<class Han, class Opt, class Par>
int setopt (Han han, Opt opt, Par par)

Variables

static SMFC_thread_data SMFragCollThread

Detailed Description

This class serves as the base class for the smart counters used as part of storage manager monitoring.

This will eventually be an interface class for curl common functions but now is just some common utility.

This class keeps track of a sum of values over a fixed number of samples.

This class keeps track of a sum of values over a fixed period of time.

This class provides functionality to limit events to consumers based on maximum event and data rates.

This class is used to manage the set of INIT messages that have been received by the storage manager and will be sent to event consumers and written to output streams.

This class keeps track of a sum of values over an infinite interval (forever).

This class keeps track of a the average of a value and also the the minimum and maximum values, and the rms.

This class manages the distribution of events to consumers from within the storage manager.

This class manages the distribution of DQMevents to consumers from within the storage manager or SM Proxy Server.

This class is used to manage the subscriptions, DQMevents, and lost connections associated with an DQMevent consumer within the event server part of the storage manager.

This class is used to manage the subscriptions, events, and lost connections associated with an event consumer within the event server part of the storage manager.

Currently, it simply provides a single method to determine the current time, but there may be more functionality that can be factored out later.

Id
BaseCounter.h,v 1.1 2008/04/14 15:42:28 biery Exp

In this initial version, a consumer is treated as being in one of three states: active, idle, or disconnected. Operationally, these states are meant to indicate the following:

Id
ConsumerPipe.h,v 1.14 2008/05/04 12:34:05 biery Exp

In this initial version, a consumer is treated as being in one of three states: active, idle, or disconnected. Operationally, these states are meant to indicate the following:

Initial Implementation based on Kurt's ConsumerPipe We can think about a common class later...

Id
DQMConsumerPipe.h,v 1.7 2008/08/06 15:52:08 biery Exp

Two ways of throttling events are supported: specifying a maximimum allowed rate of accepted events and specifying a fixed prescale. If the fixed prescale value is greater than zero, it takes precendence. That is, the maximum rate is ignored if the prescale is in effect.

Initial Implementation based on Kurt's EventServer we can think about a common class later...

Id
DQMEventServer.h,v 1.3 2007/11/09 23:08:34 badgett Exp

Two ways of throttling events are supported: specifying a maximimum allowed rate of accepted events and specifying a fixed prescale. If the fixed prescale value is greater than zero, it takes precendence. That is, the maximum rate is ignored if the prescale is in effect.

16-Aug-2006 - KAB - Initial Implementation

Id
EventServer.h,v 1.11 2008/06/12 16:02:12 biery Exp

Id
ForeverAverageCounter.h,v 1.1 2008/10/12 15:18:14 hcheung Exp

It provides functionality to track and report rates and averages which is the additional value over a simple integer or double.

Id
ForeverCounter.h,v 1.1 2008/04/14 15:42:28 biery Exp

Id
InitMsgCollection.h,v 1.5 2008/12/19 22:30:11 biery Exp

Id
RateLimiter.h,v 1.1 2008/04/16 02:46:34 biery Exp

As time passes, values that are no longer included in the time window are dropped from the counter.

Id
RollingIntervalCounter.h,v 1.1 2008/04/14 15:42:28 biery Exp

After a specified number of samples are added to the counter, old values are removed from the counter to make room for the new ones.

Id
RollingSampleCounter.h,v 1.2 2008/04/16 01:22:09 biery Exp

Id
SMCurlInterface.h,v 1.1 2007/04/26 00:58:17 hcheung Exp

Id
SMCurlInterface.cc,v 1.1 2007/04/26 01:02:34 hcheung Exp

Typedef Documentation

typedef std::vector<unsigned char> stor::InitMsgBuffer

Definition at line 20 of file InitMsgCollection.h.

typedef boost::shared_ptr<InitMsgBuffer> stor::InitMsgSharedPtr

Definition at line 21 of file InitMsgCollection.h.

Function Documentation

string stor::@6906::changeToPhony ( const string &  config  )  [static]

Definition at line 20 of file JobController.cc.

00021     {
00022       return config;
00023     }

size_t stor::func ( void *  buf,
size_t  size,
size_t  nmemb,
void *  userp 
)

Definition at line 12 of file SMCurlInterface.cc.

References stor::ReadData::d_.

Referenced by EcalTPGParamBuilder::computeLUT(), HFCherenkov::computeQEff(), stor::ConsumerPipe::ConsumerPipe(), stor::DQMConsumerPipe::DQMConsumerPipe(), pftools::SpaceManager::evolveCoefficient(), IgSoSplineTrack::findRoot(), RPCSimAverageNoiseEff::getClSize(), RPCSimAverageNoise::getClSize(), RPCSimAverage::getClSize(), stor::DataProcessManager::getHeaderFromSM(), edm::DQMHttpSource::getOneDQMEvent(), stor::DataProcessManager::getOneDQMEventFromSM(), edm::OnlineHttpReader::getOneEvent(), edm::EventStreamHttpReader::getOneEvent(), stor::DataProcessManager::getOneEventFromSM(), edm::refitem::GetPtrImpl< C, T, F, KEY >::getPtr_(), pftools::PFClusterCalibration::init(), IgTrace::initialize(), EcalUncalibRecHitFixedAlphaBetaAlgo< C >::PerformAnalyticFit(), stor::ConsumerPipe::pushEvent(), stor::DQMConsumerPipe::pushEvent(), edm::EventStreamHttpReader::readHeader(), edm::OnlineHttpReader::readHeader(), stdcomb::recursive_combination(), edm::DQMHttpSource::registerWithDQMEventServer(), stor::DataProcessManager::registerWithDQMSM(), edm::EventStreamHttpReader::registerWithEventServer(), edm::OnlineHttpReader::registerWithEventServer(), stor::DataProcessManager::registerWithSM(), pftools::PFClusterCalibration::setEvolutionParameters(), IgApplication::startProfiler(), edm::transform_into(), PATStringCutObjectSelector::tryEval(), and PATStringObjectFunction::tryEval().

00013   {
00014     ReadData* rdata = (ReadData*)userp;
00015     size_t sz = size * nmemb;
00016     char* cbuf = (char*)buf;
00017     rdata->d_.insert(rdata->d_.end(),cbuf,cbuf+sz);
00018     return sz;
00019   }

bool stor::getSMFC_exceptionStatus (  ) 

Definition at line 45 of file FragmentCollector.cc.

References stor::SMFC_thread_data::exception_in_thread, and SMFragCollThread.

Referenced by stor::StorageManager::addMeasurement(), and stor::StorageManager::monitoring().

00045 { return SMFragCollThread.exception_in_thread; }

std::string stor::getSMFC_reason4Exception (  ) 

Definition at line 46 of file FragmentCollector.cc.

References stor::SMFC_thread_data::reason_for_exception, and SMFragCollThread.

Referenced by stor::StorageManager::addMeasurement(), and stor::StorageManager::monitoring().

00046 { return SMFragCollThread.reason_for_exception; }

static const std::string stor::PROXY_SERVER_NAME ( "SMProxyServer"   )  [static]

Referenced by stor::DataProcessManager::init().

template<class Han, class Opt, class Par>
int stor::setopt ( Han  han,
Opt  opt,
Par  par 
) [inline]

Definition at line 24 of file SMCurlInterface.h.

References TestMuL1L2Filter_cff::cerr, and lat::endl().

Referenced by stor::ConsumerPipe::ConsumerPipe(), stor::DQMConsumerPipe::DQMConsumerPipe(), stor::DataProcessManager::getHeaderFromSM(), edm::DQMHttpSource::getOneDQMEvent(), stor::DataProcessManager::getOneDQMEventFromSM(), edm::OnlineHttpReader::getOneEvent(), edm::EventStreamHttpReader::getOneEvent(), stor::DataProcessManager::getOneEventFromSM(), stor::ConsumerPipe::pushEvent(), stor::DQMConsumerPipe::pushEvent(), edm::EventStreamHttpReader::readHeader(), edm::OnlineHttpReader::readHeader(), edm::DQMHttpSource::registerWithDQMEventServer(), stor::DataProcessManager::registerWithDQMSM(), edm::EventStreamHttpReader::registerWithEventServer(), edm::OnlineHttpReader::registerWithEventServer(), and stor::DataProcessManager::registerWithSM().

00025   {
00026     if(curl_easy_setopt(han,opt,par)!=0)
00027       {
00028         std::cerr << "could not stor::setopt " << opt << std::endl;
00029         abort();
00030       }
00031     return 0;
00032   }

Variable Documentation

SMFC_thread_data stor::SMFragCollThread [static]

Definition at line 43 of file FragmentCollector.cc.

Referenced by getSMFC_exceptionStatus(), getSMFC_reason4Exception(), and stor::FragmentCollector::run().

Generated on Tue Jun 9 18:52:48 2009 for CMSSW by  doxygen 1.5.4