#include <RegistrationInfoBase.h>

Inheritance diagram for stor::RegistrationInfoBase:

Public Member Functions
const int &	connectTrySleepTime () const
void	consumerContact ()
const ConsumerID &	consumerId () const
const std::string &	consumerName () const
void	eventType (std::ostream &) const
edm::ParameterSet	getPSet () const
bool	isStale (const utils::TimePoint_t &) const
bool	isValid () const
double	lastContactSecondsAgo (const utils::TimePoint_t &) const
const int &	maxConnectTries () const
const utils::Duration_t &	minEventRequestInterval () const
virtual bool	operator!= (const RegistrationInfoBase &) const
virtual bool	operator< (const RegistrationInfoBase &) const
virtual bool	operator== (const RegistrationInfoBase &) const
const QueueID &	queueId () const
void	queueInfo (std::ostream &) const
const enquing_policy::PolicyTag &	queuePolicy () const
const int &	queueSize () const
void	registerMe (EventDistributor *dist)
	RegistrationInfoBase (const edm::ParameterSet &pset, const std::string &remoteHost, const EventServingParams &eventServingParams, const bool useEventServingParams)
	RegistrationInfoBase (const std::string &consumerName, const std::string &remoteHost, const int &queueSize, const enquing_policy::PolicyTag &queuePolicy, const utils::Duration_t &secondsToStale)
const std::string &	remoteHost () const
const int &	retryInterval () const
const utils::Duration_t &	secondsToStale () const
void	setConsumerId (const ConsumerID &id)
void	setMinEventRequestInterval (const utils::Duration_t &interval)
void	setQueueId (const QueueID &id)
void	setSourceURL (const std::string &url)
const std::string &	sourceURL () const
virtual	~RegistrationInfoBase ()
Protected Member Functions
virtual void	do_appendToPSet (edm::ParameterSet &) const =0
virtual void	do_eventType (std::ostream &) const =0
virtual void	do_registerMe (EventDistributor *)=0
Private Attributes
int	connectTrySleepTime_
ConsumerID	consumerId_
std::string	consumerName_
utils::TimePoint_t	lastConsumerContact_
int	maxConnectTries_
utils::Duration_t	minEventRequestInterval_
QueueID	queueId_
enquing_policy::PolicyTag	queuePolicy_
int	queueSize_
const std::string	remoteHost_
int	retryInterval_
utils::Duration_t	secondsToStale_
std::string	sourceURL_

Detailed Description

Defines the common interface for event and DQM consumer registration info objects.

Author:: mommsen

Revision:: 1.7

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

Definition at line 32 of file RegistrationInfoBase.h.

Constructor & Destructor Documentation

stor::RegistrationInfoBase::RegistrationInfoBase	(	const std::string &	consumerName,
		const std::string &	remoteHost,
		const int &	queueSize,
		const enquing_policy::PolicyTag &	queuePolicy,
		const utils::Duration_t &	secondsToStale
	)

Definition at line 13 of file RegistrationInfoBase.cc.

    :
  remoteHost_(remoteHost),
  consumerName_(consumerName),
  queueSize_(queueSize),
  queuePolicy_(queuePolicy),
  secondsToStale_(secondsToStale),
  consumerId_(0),
  lastConsumerContact_(utils::getCurrentTime())
  { }

stor::RegistrationInfoBase::RegistrationInfoBase	(	const edm::ParameterSet &	pset,
		const std::string &	remoteHost,
		const EventServingParams &	eventServingParams,
		const bool	useEventServingParams
	)

Definition at line 30 of file RegistrationInfoBase.cc.

References stor::EventServingParams::activeConsumerTimeout_, stor::EventServingParams::consumerQueuePolicy_, stor::EventServingParams::consumerQueueSize_, stor::enquing_policy::DiscardNew, stor::enquing_policy::DiscardOld, edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), stor::enquing_policy::Max, reco_skim_cfg_mod::maxEventRequestRate, evf::utils::policy, seconds(), and stor::utils::secondsToDuration().

    :
  remoteHost_(remoteHost),
  consumerId_(0),
  lastConsumerContact_(utils::getCurrentTime())
  {
    try
    {
      consumerName_ = pset.getUntrackedParameter<std::string>("consumerName");
    }
    catch( edm::Exception& e )
    {
      consumerName_ = pset.getUntrackedParameter<std::string>("DQMconsumerName", "Unknown");
    }

    try
    {
      sourceURL_ = pset.getParameter<std::string>("sourceURL");
    }
    catch( edm::Exception& e )
    {
      sourceURL_ = pset.getUntrackedParameter<std::string>("sourceURL", "Unknown");
    }

    const double maxEventRequestRate = pset.getUntrackedParameter<double>("maxEventRequestRate", 0);
    if ( maxEventRequestRate > 0 )
      minEventRequestInterval_ = utils::secondsToDuration(1 / maxEventRequestRate);
    else
      minEventRequestInterval_ = boost::posix_time::not_a_date_time;

    maxConnectTries_ = pset.getUntrackedParameter<int>("maxConnectTries", 300);

    connectTrySleepTime_ = pset.getUntrackedParameter<int>("connectTrySleepTime", 10);

    retryInterval_ = pset.getUntrackedParameter<int>("retryInterval", 5);

    queueSize_ = pset.getUntrackedParameter<int>("queueSize",
      useEventServingParams ? eventServingParams.consumerQueueSize_ : 0);

    const std::string policy =
      pset.getUntrackedParameter<std::string>("queuePolicy",
        useEventServingParams ? eventServingParams.consumerQueuePolicy_ : "Default");
    if ( policy == "DiscardNew" )
    {
      queuePolicy_ = enquing_policy::DiscardNew;
    }
    else if ( policy == "DiscardOld" )
    {
      queuePolicy_ = enquing_policy::DiscardOld;
    }
    else if ( policy == "Default" )
    {
      queuePolicy_ = enquing_policy::Max;
    }
    else
    {
      XCEPT_RAISE( stor::exception::ConsumerRegistration,
        "Unknown enqueuing policy: " + policy );
    }

    secondsToStale_ = utils::secondsToDuration(
      pset.getUntrackedParameter<double>("consumerTimeOut", 0)
    );
    if ( useEventServingParams && secondsToStale_ < boost::posix_time::seconds(1) )
      secondsToStale_ = eventServingParams.activeConsumerTimeout_;
  }

virtual stor::RegistrationInfoBase::~RegistrationInfoBase ( ) [inline, virtual]

The virtual destructor allows polymorphic containment-by-reference.

Definition at line 58 of file RegistrationInfoBase.h.

{};

Member Function Documentation

const int& stor::RegistrationInfoBase::connectTrySleepTime ( ) const [inline]

Definition at line 99 of file RegistrationInfoBase.h.

References connectTrySleepTime_.

{ return connectTrySleepTime_; }

void stor::RegistrationInfoBase::consumerContact ( ) [inline]

Mark time when consumer last contacted us

Definition at line 145 of file RegistrationInfoBase.h.

References stor::utils::getCurrentTime(), and lastConsumerContact_.

  {
    lastConsumerContact_ = utils::getCurrentTime();
  }

const ConsumerID& stor::RegistrationInfoBase::consumerId ( ) const [inline]

Definition at line 96 of file RegistrationInfoBase.h.

References consumerId_.

Referenced by stor::operator<<().

{ return consumerId_; }

const std::string& stor::RegistrationInfoBase::consumerName ( ) const [inline]

Definition at line 93 of file RegistrationInfoBase.h.

References consumerName_.

Referenced by stor::operator<<().

{ return consumerName_; }

virtual void stor::RegistrationInfoBase::do_appendToPSet ( edm::ParameterSet & ) const [protected, pure virtual]

Implemented in stor::DQMEventConsumerRegistrationInfo, and stor::EventConsumerRegistrationInfo.

Referenced by getPSet().

virtual void stor::RegistrationInfoBase::do_eventType ( std::ostream & ) const [protected, pure virtual]

Implemented in stor::DQMEventConsumerRegistrationInfo, and stor::EventConsumerRegistrationInfo.

Referenced by eventType().

virtual void stor::RegistrationInfoBase::do_registerMe ( EventDistributor * ) [protected, pure virtual]

Implemented in stor::DQMEventConsumerRegistrationInfo, and stor::EventConsumerRegistrationInfo.

Referenced by registerMe().

void stor::RegistrationInfoBase::eventType ( std::ostream & os ) const [inline]

Returns a formatted string which contains the information about the event type.

Definition at line 157 of file RegistrationInfoBase.h.

References do_eventType().

  {
    do_eventType(os);
  }

edm::ParameterSet stor::RegistrationInfoBase::getPSet ( ) const

Return the ParameterSet containing the consumer registration infos

Definition at line 101 of file RegistrationInfoBase.cc.

References edm::ParameterSet::addParameter(), edm::ParameterSet::addUntrackedParameter(), connectTrySleepTime_, consumerName_, stor::enquing_policy::DiscardNew, stor::enquing_policy::DiscardOld, do_appendToPSet(), stor::utils::durationToSeconds(), maxConnectTries_, minEventRequestInterval_, MultipleCompare::pset, queuePolicy_, queueSize_, retryInterval_, secondsToStale(), secondsToStale_, and sourceURL_.

  {
    edm::ParameterSet pset;

    if ( consumerName_ != "Unknown" )
      pset.addUntrackedParameter<std::string>("consumerName", consumerName_);

    if ( sourceURL_  != "Unknown" )
      pset.addParameter<std::string>("sourceURL", sourceURL_);

    if ( maxConnectTries_ != 300 )
      pset.addUntrackedParameter<int>("maxConnectTries", maxConnectTries_);
    
    if ( connectTrySleepTime_ != 10 )
      pset.addUntrackedParameter<int>("connectTrySleepTime", connectTrySleepTime_);

    if ( retryInterval_ != 5 )
      pset.addUntrackedParameter<int>("retryInterval", retryInterval_);
    
    if ( queueSize_ > 0 )
      pset.addUntrackedParameter<int>("queueSize", queueSize_);
    
    if ( ! minEventRequestInterval_.is_not_a_date_time() )
    {
      const double rate = 1 / utils::durationToSeconds(minEventRequestInterval_);
      pset.addUntrackedParameter<double>("maxEventRequestRate", rate);
    }

    const double secondsToStale = utils::durationToSeconds(secondsToStale_);
    if ( secondsToStale > 0 )
      pset.addUntrackedParameter<double>("consumerTimeOut", secondsToStale);

    if ( queuePolicy_ == enquing_policy::DiscardNew )
      pset.addUntrackedParameter<std::string>("queuePolicy", "DiscardNew");
    if ( queuePolicy_ == enquing_policy::DiscardOld )
      pset.addUntrackedParameter<std::string>("queuePolicy", "DiscardOld");

    do_appendToPSet(pset);

    return pset;
  }

bool stor::RegistrationInfoBase::isStale ( const utils::TimePoint_t & now ) const [inline]

Definition at line 163 of file RegistrationInfoBase.h.

References lastConsumerContact_, and secondsToStale().

  {
    return ( now > lastConsumerContact_ + secondsToStale() );
  }

bool stor::RegistrationInfoBase::isValid ( void ) const [inline]

Definition at line 90 of file RegistrationInfoBase.h.

References consumerId_, and stor::ConsumerID::isValid().

{ return consumerId_.isValid(); }

double stor::RegistrationInfoBase::lastContactSecondsAgo ( const utils::TimePoint_t & now ) const [inline]

Definition at line 169 of file RegistrationInfoBase.h.

References stor::utils::durationToSeconds(), and lastConsumerContact_.

  {
    return utils::durationToSeconds( now - lastConsumerContact_ );
  }

const int& stor::RegistrationInfoBase::maxConnectTries ( ) const [inline]

Definition at line 98 of file RegistrationInfoBase.h.

References maxConnectTries_.

{ return maxConnectTries_; }

const utils::Duration_t& stor::RegistrationInfoBase::minEventRequestInterval ( ) const [inline]

Definition at line 101 of file RegistrationInfoBase.h.

References minEventRequestInterval_.

{ return minEventRequestInterval_; }

bool stor::RegistrationInfoBase::operator!= ( const RegistrationInfoBase & other ) const [virtual]

Definition at line 161 of file RegistrationInfoBase.cc.

  {
    return ! ( *this == other );
  }

bool stor::RegistrationInfoBase::operator< ( const RegistrationInfoBase & other ) const [virtual]

Definition at line 143 of file RegistrationInfoBase.cc.

References queuePolicy(), queueSize(), and secondsToStale().

  {
    if ( queueSize() != other.queueSize() )
      return ( queueSize() < other.queueSize() );
    if ( queuePolicy() != other.queuePolicy() )
      return ( queuePolicy() < other.queuePolicy() );
    return ( secondsToStale() < other.secondsToStale() );
  }

bool stor::RegistrationInfoBase::operator== ( const RegistrationInfoBase & other ) const [virtual]

Definition at line 152 of file RegistrationInfoBase.cc.

References queuePolicy(), queueSize(), and secondsToStale().

  {
    return (
      queueSize() == other.queueSize() &&
      queuePolicy() == other.queuePolicy() &&
      secondsToStale() == other.secondsToStale()
    );
  }

const QueueID& stor::RegistrationInfoBase::queueId ( ) const [inline]

Definition at line 91 of file RegistrationInfoBase.h.

References queueId_.

Referenced by stor::operator<<().

{ return queueId_; }

void stor::RegistrationInfoBase::queueInfo ( std::ostream & os ) const

Print queue information into ostream

Definition at line 166 of file RegistrationInfoBase.cc.

References queuePolicy_, queueSize_, and secondsToStale_.

Referenced by stor::EventConsumerRegistrationInfo::do_eventType(), and stor::DQMEventConsumerRegistrationInfo::do_eventType().

  {
    os << "Queue type: " << queuePolicy_ <<
      ", size " << queueSize_ << 
      ", timeout " << secondsToStale_.total_seconds() << "s";
  }

const enquing_policy::PolicyTag& stor::RegistrationInfoBase::queuePolicy ( ) const [inline]

Definition at line 92 of file RegistrationInfoBase.h.

References queuePolicy_.

Referenced by operator<(), stor::operator<<(), and operator==().

{ return queuePolicy_; }

const int& stor::RegistrationInfoBase::queueSize ( ) const [inline]

Definition at line 97 of file RegistrationInfoBase.h.

References queueSize_.

Referenced by operator<(), stor::operator<<(), and operator==().

{ return queueSize_; }

void stor::RegistrationInfoBase::registerMe ( EventDistributor * dist ) [inline]

Register the consumer represented by this registration with the specified EventDistributor.

Definition at line 151 of file RegistrationInfoBase.h.

References do_registerMe().

  {
    do_registerMe(dist);
  }

const std::string& stor::RegistrationInfoBase::remoteHost ( ) const [inline]

Definition at line 94 of file RegistrationInfoBase.h.

References remoteHost_.

Referenced by stor::operator<<().

{ return remoteHost_; }

const int& stor::RegistrationInfoBase::retryInterval ( ) const [inline]

Definition at line 100 of file RegistrationInfoBase.h.

References retryInterval_.

{ return retryInterval_; }

const utils::Duration_t& stor::RegistrationInfoBase::secondsToStale ( ) const [inline]

Definition at line 102 of file RegistrationInfoBase.h.

References secondsToStale_.

Referenced by getPSet(), isStale(), operator<(), stor::operator<<(), and operator==().

{ return secondsToStale_; }

void stor::RegistrationInfoBase::setConsumerId ( const ConsumerID & id ) [inline]

Definition at line 109 of file RegistrationInfoBase.h.

References consumerId_.

{ consumerId_ = id; }

void stor::RegistrationInfoBase::setMinEventRequestInterval ( const utils::Duration_t & interval ) [inline]

Definition at line 87 of file RegistrationInfoBase.h.

References MergeJob_cfg::interval, and minEventRequestInterval_.

{ minEventRequestInterval_ = interval; }

void stor::RegistrationInfoBase::setQueueId ( const QueueID & id ) [inline]

Definition at line 107 of file RegistrationInfoBase.h.

References queueId_.

{ queueId_ = id; }

void stor::RegistrationInfoBase::setSourceURL ( const std::string & url ) [inline]

Definition at line 108 of file RegistrationInfoBase.h.

References sourceURL_.

{ sourceURL_ = url; }

const std::string& stor::RegistrationInfoBase::sourceURL ( ) const [inline]

Definition at line 95 of file RegistrationInfoBase.h.

References sourceURL_.

Referenced by stor::EventConsumerRegistrationInfo::eventURL(), stor::DQMEventConsumerRegistrationInfo::eventURL(), stor::operator<<(), stor::DQMEventConsumerRegistrationInfo::registerURL(), and stor::EventConsumerRegistrationInfo::registerURL().

{ return sourceURL_; }

Member Data Documentation

int stor::RegistrationInfoBase::connectTrySleepTime_ [private]

Definition at line 133 of file RegistrationInfoBase.h.

Referenced by connectTrySleepTime(), and getPSet().

ConsumerID stor::RegistrationInfoBase::consumerId_ [private]

Definition at line 137 of file RegistrationInfoBase.h.

Referenced by consumerId(), isValid(), and setConsumerId().

std::string stor::RegistrationInfoBase::consumerName_ [private]

Definition at line 127 of file RegistrationInfoBase.h.

Referenced by consumerName(), and getPSet().

utils::TimePoint_t stor::RegistrationInfoBase::lastConsumerContact_ [private]

Definition at line 138 of file RegistrationInfoBase.h.

Referenced by consumerContact(), isStale(), and lastContactSecondsAgo().

int stor::RegistrationInfoBase::maxConnectTries_ [private]

Definition at line 132 of file RegistrationInfoBase.h.

Referenced by getPSet(), and maxConnectTries().

utils::Duration_t stor::RegistrationInfoBase::minEventRequestInterval_ [private]

Definition at line 135 of file RegistrationInfoBase.h.

Referenced by getPSet(), minEventRequestInterval(), and setMinEventRequestInterval().

QueueID stor::RegistrationInfoBase::queueId_ [private]

Definition at line 136 of file RegistrationInfoBase.h.

Referenced by queueId(), and setQueueId().

enquing_policy::PolicyTag stor::RegistrationInfoBase::queuePolicy_ [private]

Definition at line 130 of file RegistrationInfoBase.h.

Referenced by getPSet(), queueInfo(), and queuePolicy().

int stor::RegistrationInfoBase::queueSize_ [private]

Definition at line 129 of file RegistrationInfoBase.h.

Referenced by getPSet(), queueInfo(), and queueSize().

const std::string stor::RegistrationInfoBase::remoteHost_ [private]

Definition at line 126 of file RegistrationInfoBase.h.

Referenced by remoteHost().

int stor::RegistrationInfoBase::retryInterval_ [private]

Definition at line 134 of file RegistrationInfoBase.h.

Referenced by getPSet(), and retryInterval().

utils::Duration_t stor::RegistrationInfoBase::secondsToStale_ [private]

Definition at line 131 of file RegistrationInfoBase.h.

Referenced by getPSet(), queueInfo(), and secondsToStale().

std::string stor::RegistrationInfoBase::sourceURL_ [private]

Definition at line 128 of file RegistrationInfoBase.h.

Referenced by getPSet(), setSourceURL(), and sourceURL().

stor::RegistrationInfoBase Class Reference

Public Member Functions

Protected Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation