#include <Configuration.h>

Inheritance diagram for smproxy::Configuration:

Public Member Functions
virtual void	actionPerformed (xdata::Event &isEvt)

	Configuration (xdata::InfoSpace *infoSpace, unsigned long instanceNumber)

struct AlarmParams	getAlarmParams () const

struct DataRetrieverParams	getDataRetrieverParams () const

struct DQMArchivingParams	getDQMArchivingParams () const

struct stor::DQMProcessingParams	getDQMProcessingParams () const

struct stor::EventServingParams	getEventServingParams () const

struct QueueConfigurationParams	getQueueConfigurationParams () const

void	updateAllParams ()

virtual	~Configuration ()

Private Member Functions
void	setAlarmDefaults ()

void	setDataRetrieverDefaults (unsigned long instanceNumber)

void	setDQMArchivingDefaults ()

void	setDQMProcessingDefaults ()

void	setEventServingDefaults ()

void	setQueueConfigurationDefaults ()

void	setupAlarmInfoSpaceParams (xdata::InfoSpace *infoSpace)

void	setupDataRetrieverInfoSpaceParams (xdata::InfoSpace *)

void	setupDQMArchivingInfoSpaceParams (xdata::InfoSpace *)

void	setupDQMProcessingInfoSpaceParams (xdata::InfoSpace *)

void	setupEventServingInfoSpaceParams (xdata::InfoSpace *)

void	setupQueueConfigurationInfoSpaceParams (xdata::InfoSpace *)

void	updateLocalAlarmData ()

void	updateLocalDataRetrieverData ()

void	updateLocalDQMArchivingData ()

void	updateLocalDQMProcessingData ()

void	updateLocalEventServingData ()

void	updateLocalQueueConfigurationData ()

Private Attributes
xdata::Integer	_DQMactiveConsumerTimeout

xdata::String	_DQMconsumerQueuePolicy

xdata::Integer	_DQMconsumerQueueSize

xdata::Integer	activeConsumerTimeout_

struct AlarmParams	alarmParamCopy_

xdata::Boolean	allowMissingSM_

xdata::Boolean	archiveDQM_

xdata::Integer	archiveIntervalDQM_

xdata::String	archiveTopLevelFolder_

xdata::Boolean	collateDQM_

xdata::Integer	compressionLevelDQM_

xdata::UnsignedInteger32	connectTrySleepTime_

xdata::String	consumerQueuePolicy_

xdata::Integer	consumerQueueSize_

xdata::Double	corruptedEventRate_

struct DataRetrieverParams	dataRetrieverParamCopy_

struct DQMArchivingParams	dqmArchivingParamCopy_

struct stor::DQMProcessingParams	dqmProcessingParamCopy_

struct stor::EventServingParams	eventServeParamCopy_

xdata::String	filePrefixDQM_

boost::mutex	generalMutex_

xdata::UnsignedInteger32	headerRetryInterval_

xdata::UnsignedInteger32	maxConnectionRetries_

xdata::Double	monitoringSleepSec_

struct QueueConfigurationParams	queueConfigParamCopy_

xdata::Integer	readyTimeDQM_

xdata::UnsignedInteger32	registrationQueueSize_

xdata::UnsignedInteger32	retryInterval_

xdata::Boolean	sendAlarms_

xdata::UnsignedInteger32	sleepTimeIfIdle_

xdata::Vector< xdata::String >	smRegistrationList_

xdata::Boolean	useCompressionDQM_

Detailed Description

Class for managing configuration information from the infospace and providing local copies of that information that are updated only at requested times.

Author:: mommsen

Revision:: 1.3

Date:: 2011/05/09 11:03:25

Definition at line 90 of file Configuration.h.

Constructor & Destructor Documentation

smproxy::Configuration::Configuration	(	xdata::InfoSpace *	infoSpace,
		unsigned long	instanceNumber
	)

Constructs a Configuration instance for the specified infospace and application instance number.

Definition at line 14 of file Configuration.cc.

   {
     // default values are used to initialize infospace values,
     // so they should be set first
     setDataRetrieverDefaults(instanceNumber);
     setEventServingDefaults();
     setDQMProcessingDefaults();
     setDQMArchivingDefaults();
     setQueueConfigurationDefaults();
     setAlarmDefaults();
 
     setupDataRetrieverInfoSpaceParams(infoSpace);
     setupEventServingInfoSpaceParams(infoSpace);
     setupDQMProcessingInfoSpaceParams(infoSpace);
     setupDQMArchivingInfoSpaceParams(infoSpace);
     setupQueueConfigurationInfoSpaceParams(infoSpace);
     setupAlarmInfoSpaceParams(infoSpace);
   }

virtual smproxy::Configuration::~Configuration ( )

inlinevirtual

Destructor.

Definition at line 103 of file Configuration.h.

     {
       // should we detach from the infospace???
     }

Member Function Documentation

void smproxy::Configuration::actionPerformed ( xdata::Event & isEvt )

virtual

Gets invoked when a operation is performed on the infospace that we are interested in knowing about.

Definition at line 307 of file Configuration.cc.

References generalMutex_.

   {
     boost::mutex::scoped_lock sl(generalMutex_);
   }

struct AlarmParams smproxy::Configuration::getAlarmParams ( ) const

Returns a copy of the alarm parameters. These values will be current as of the most recent global update of the local cache from the infospace (see the updateAllParams() method).

Definition at line 66 of file Configuration.cc.

   {
     boost::mutex::scoped_lock sl(generalMutex_);
     return alarmParamCopy_;
   }

struct DataRetrieverParams smproxy::Configuration::getDataRetrieverParams ( ) const

Returns a copy of the event retriever parameters. These values will be current as of the most recent global update of the local cache from the infospace (see the updateAllParams() method) or the most recent update of only the event retrieved parameters (see the updateDataRetrieverParams() method).

Definition at line 36 of file Configuration.cc.

   {
     boost::mutex::scoped_lock sl(generalMutex_);
     return dataRetrieverParamCopy_;
   }

struct DQMArchivingParams smproxy::Configuration::getDQMArchivingParams ( ) const

Returns a copy of the DQM archiving parameters. These values will be current as of the most recent global update of the local cache from the infospace (see the updateAllParams() method).

Definition at line 54 of file Configuration.cc.

   {
     boost::mutex::scoped_lock sl(generalMutex_);
     return dqmArchivingParamCopy_;
   }

struct stor::DQMProcessingParams smproxy::Configuration::getDQMProcessingParams ( ) const

Returns a copy of the DQM processing parameters. These values will be current as of the most recent global update of the local cache from the infospace (see the updateAllParams() method).

Definition at line 48 of file Configuration.cc.

   {
     boost::mutex::scoped_lock sl(generalMutex_);
     return dqmProcessingParamCopy_;
   }

struct stor::EventServingParams smproxy::Configuration::getEventServingParams ( ) const

Returns a copy of the event serving parameters. These values will be current as of the most recent global update of the local cache from the infospace (see the updateAllParams() method).

Definition at line 42 of file Configuration.cc.

   {
     boost::mutex::scoped_lock sl(generalMutex_);
     return eventServeParamCopy_;
   }

struct QueueConfigurationParams smproxy::Configuration::getQueueConfigurationParams ( ) const

Returns a copy of the queue configuration parameters. These values will be current as of the most recent global update of the local cache from the infospace (see the updateAllParams() method).

Definition at line 60 of file Configuration.cc.

   {
     boost::mutex::scoped_lock sl(generalMutex_);
     return queueConfigParamCopy_;
   }

void smproxy::Configuration::setAlarmDefaults ( )

private

Definition at line 137 of file Configuration.cc.

References alarmParamCopy_, smproxy::AlarmParams::corruptedEventRate_, and smproxy::AlarmParams::sendAlarms_.

   {
     // set defaults
     alarmParamCopy_.sendAlarms_ = true;
     alarmParamCopy_.corruptedEventRate_ = 0.1;
   }

void smproxy::Configuration::setDataRetrieverDefaults ( unsigned long instanceNumber )

private

Definition at line 83 of file Configuration.cc.

References smproxy::DataRetrieverParams::allowMissingSM_, smproxy::DataRetrieverParams::connectTrySleepTime_, dataRetrieverParamCopy_, smproxy::DataRetrieverParams::headerRetryInterval_, smproxy::DataRetrieverParams::hostName_, smproxy::DataRetrieverParams::maxConnectionRetries_, pos, smproxy::DataRetrieverParams::retryInterval_, smproxy::DataRetrieverParams::sleepTimeIfIdle_, smproxy::DataRetrieverParams::smpsInstance_, and smproxy::DataRetrieverParams::smRegistrationList_.

   {
     dataRetrieverParamCopy_.smpsInstance_ = instanceNumber;
     dataRetrieverParamCopy_.smRegistrationList_.clear();
     dataRetrieverParamCopy_.allowMissingSM_ = true;
     dataRetrieverParamCopy_.maxConnectionRetries_ = 5;
     dataRetrieverParamCopy_.connectTrySleepTime_ = 10;
     dataRetrieverParamCopy_.headerRetryInterval_ = 5;
     dataRetrieverParamCopy_.retryInterval_ = 1;
     dataRetrieverParamCopy_.sleepTimeIfIdle_ =
       boost::posix_time::milliseconds(100);
 
     std::string tmpString(toolbox::net::getHostName());
     // strip domainame
     std::string::size_type pos = tmpString.find('.');  
     if (pos != std::string::npos) {  
       std::string basename = tmpString.substr(0,pos);  
       tmpString = basename;
     }
     dataRetrieverParamCopy_.hostName_ = tmpString;
   }

void smproxy::Configuration::setDQMArchivingDefaults ( )

private

Definition at line 123 of file Configuration.cc.

References smproxy::DQMArchivingParams::archiveDQM_, smproxy::DQMArchivingParams::archiveIntervalDQM_, smproxy::DQMArchivingParams::archiveTopLevelFolder_, dqmArchivingParamCopy_, and smproxy::DQMArchivingParams::filePrefixDQM_.

   {
     dqmArchivingParamCopy_.archiveDQM_ = false;
     dqmArchivingParamCopy_.archiveTopLevelFolder_ = "*";
     dqmArchivingParamCopy_.filePrefixDQM_ = "/tmp/DQM";
     dqmArchivingParamCopy_.archiveIntervalDQM_ = 0;
   }

void smproxy::Configuration::setDQMProcessingDefaults ( )

private

Definition at line 115 of file Configuration.cc.

References stor::DQMProcessingParams::collateDQM_, stor::DQMProcessingParams::compressionLevelDQM_, dqmProcessingParamCopy_, stor::DQMProcessingParams::readyTimeDQM_, seconds(), and stor::DQMProcessingParams::useCompressionDQM_.

   {
     dqmProcessingParamCopy_.collateDQM_ = true;
     dqmProcessingParamCopy_.readyTimeDQM_ = boost::posix_time::seconds(120);
     dqmProcessingParamCopy_.useCompressionDQM_ = true;
     dqmProcessingParamCopy_.compressionLevelDQM_ = 1;
   }

void smproxy::Configuration::setEventServingDefaults ( )

private

Definition at line 105 of file Configuration.cc.

References stor::EventServingParams::_DQMactiveConsumerTimeout, stor::EventServingParams::_DQMconsumerQueuePolicy, stor::EventServingParams::_DQMconsumerQueueSize, stor::EventServingParams::activeConsumerTimeout_, stor::EventServingParams::consumerQueuePolicy_, stor::EventServingParams::consumerQueueSize_, eventServeParamCopy_, and seconds().

   {
     eventServeParamCopy_.activeConsumerTimeout_ = boost::posix_time::seconds(60);
     eventServeParamCopy_.consumerQueueSize_ = 10;
     eventServeParamCopy_.consumerQueuePolicy_ = "DiscardOld";
     eventServeParamCopy_._DQMactiveConsumerTimeout = boost::posix_time::seconds(60);
     eventServeParamCopy_._DQMconsumerQueueSize = 15;
     eventServeParamCopy_._DQMconsumerQueuePolicy = "DiscardOld";
   }

void smproxy::Configuration::setQueueConfigurationDefaults ( )

private

Definition at line 131 of file Configuration.cc.

References smproxy::QueueConfigurationParams::monitoringSleepSec_, queueConfigParamCopy_, smproxy::QueueConfigurationParams::registrationQueueSize_, and seconds().

   {
     queueConfigParamCopy_.registrationQueueSize_ = 128;
     queueConfigParamCopy_.monitoringSleepSec_ = boost::posix_time::seconds(1);
   }

void smproxy::Configuration::setupAlarmInfoSpaceParams ( xdata::InfoSpace * infoSpace )

private

Definition at line 232 of file Configuration.cc.

References alarmParamCopy_, smproxy::AlarmParams::corruptedEventRate_, corruptedEventRate_, smproxy::AlarmParams::sendAlarms_, and sendAlarms_.

   {
     // copy the initial defaults to the xdata variables
     sendAlarms_ = alarmParamCopy_.sendAlarms_;
     corruptedEventRate_ = alarmParamCopy_.corruptedEventRate_;
  
     // bind the local xdata variables to the infospace
     infoSpace->fireItemAvailable("sendAlarms", &sendAlarms_);
     infoSpace->fireItemAvailable("corruptedEventRate", &corruptedEventRate_);
   }

void smproxy::Configuration::setupDataRetrieverInfoSpaceParams ( xdata::InfoSpace * infoSpace )

private

Definition at line 145 of file Configuration.cc.

References smproxy::DataRetrieverParams::allowMissingSM_, allowMissingSM_, smproxy::DataRetrieverParams::connectTrySleepTime_, connectTrySleepTime_, dataRetrieverParamCopy_, stor::utils::getXdataVector(), smproxy::DataRetrieverParams::headerRetryInterval_, headerRetryInterval_, smproxy::DataRetrieverParams::maxConnectionRetries_, maxConnectionRetries_, smproxy::DataRetrieverParams::retryInterval_, retryInterval_, smproxy::DataRetrieverParams::sleepTimeIfIdle_, sleepTimeIfIdle_, smproxy::DataRetrieverParams::smRegistrationList_, and smRegistrationList_.

   {
     // copy the initial defaults into the xdata variables
     stor::utils::getXdataVector(dataRetrieverParamCopy_.smRegistrationList_, smRegistrationList_);
     allowMissingSM_ = dataRetrieverParamCopy_.allowMissingSM_;
     maxConnectionRetries_ = dataRetrieverParamCopy_.maxConnectionRetries_;
     connectTrySleepTime_ = dataRetrieverParamCopy_.connectTrySleepTime_;
     headerRetryInterval_ = dataRetrieverParamCopy_.headerRetryInterval_;
     retryInterval_ = dataRetrieverParamCopy_.retryInterval_;
     sleepTimeIfIdle_ = dataRetrieverParamCopy_.sleepTimeIfIdle_.total_milliseconds();
 
     // bind the local xdata variables to the infospace
     infoSpace->fireItemAvailable("SMRegistrationList", &smRegistrationList_);
     infoSpace->fireItemAvailable("allowMissingSM", &allowMissingSM_);
     infoSpace->fireItemAvailable("maxConnectionRetries", &maxConnectionRetries_);
     infoSpace->fireItemAvailable("connectTrySleepTime", &connectTrySleepTime_);
     infoSpace->fireItemAvailable("headerRetryInterval", &headerRetryInterval_);
     infoSpace->fireItemAvailable("retryInterval", &retryInterval_);
     infoSpace->fireItemAvailable("sleepTimeIfIdle", &sleepTimeIfIdle_);
   }

void smproxy::Configuration::setupDQMArchivingInfoSpaceParams ( xdata::InfoSpace * infoSpace )

private

Definition at line 203 of file Configuration.cc.

References smproxy::DQMArchivingParams::archiveDQM_, archiveDQM_, smproxy::DQMArchivingParams::archiveIntervalDQM_, archiveIntervalDQM_, smproxy::DQMArchivingParams::archiveTopLevelFolder_, archiveTopLevelFolder_, dqmArchivingParamCopy_, smproxy::DQMArchivingParams::filePrefixDQM_, and filePrefixDQM_.

   {
     // copy the initial defaults to the xdata variables
     archiveDQM_ = dqmArchivingParamCopy_.archiveDQM_;
     archiveTopLevelFolder_ = dqmArchivingParamCopy_.archiveTopLevelFolder_;
     archiveIntervalDQM_ = dqmArchivingParamCopy_.archiveIntervalDQM_;
     filePrefixDQM_ = dqmArchivingParamCopy_.filePrefixDQM_;
 
     // bind the local xdata variables to the infospace
     infoSpace->fireItemAvailable("archiveDQM", &archiveDQM_);
     infoSpace->fireItemAvailable("archiveTopLevelFolder", &archiveTopLevelFolder_);
     infoSpace->fireItemAvailable("archiveIntervalDQM", &archiveIntervalDQM_);
     infoSpace->fireItemAvailable("filePrefixDQM", &filePrefixDQM_);
   }

void smproxy::Configuration::setupDQMProcessingInfoSpaceParams ( xdata::InfoSpace * infoSpace )

private

Definition at line 187 of file Configuration.cc.

References stor::DQMProcessingParams::collateDQM_, collateDQM_, stor::DQMProcessingParams::compressionLevelDQM_, compressionLevelDQM_, dqmProcessingParamCopy_, stor::DQMProcessingParams::readyTimeDQM_, readyTimeDQM_, stor::DQMProcessingParams::useCompressionDQM_, and useCompressionDQM_.

   {
     // copy the initial defaults to the xdata variables
     collateDQM_ = dqmProcessingParamCopy_.collateDQM_;
     readyTimeDQM_ = dqmProcessingParamCopy_.readyTimeDQM_.total_seconds();
     useCompressionDQM_ = dqmProcessingParamCopy_.useCompressionDQM_;
     compressionLevelDQM_ = dqmProcessingParamCopy_.compressionLevelDQM_;
 
     // bind the local xdata variables to the infospace
     infoSpace->fireItemAvailable("collateDQM", &collateDQM_);
     infoSpace->fireItemAvailable("readyTimeDQM", &readyTimeDQM_);
     infoSpace->fireItemAvailable("useCompressionDQM", &useCompressionDQM_);
     infoSpace->fireItemAvailable("compressionLevelDQM", &compressionLevelDQM_);
   }

void smproxy::Configuration::setupEventServingInfoSpaceParams ( xdata::InfoSpace * infoSpace )

private

Definition at line 167 of file Configuration.cc.

References stor::EventServingParams::_DQMactiveConsumerTimeout, _DQMactiveConsumerTimeout, stor::EventServingParams::_DQMconsumerQueuePolicy, _DQMconsumerQueuePolicy, stor::EventServingParams::_DQMconsumerQueueSize, _DQMconsumerQueueSize, stor::EventServingParams::activeConsumerTimeout_, activeConsumerTimeout_, stor::EventServingParams::consumerQueuePolicy_, consumerQueuePolicy_, stor::EventServingParams::consumerQueueSize_, consumerQueueSize_, and eventServeParamCopy_.

   {
     // copy the initial defaults to the xdata variables
     activeConsumerTimeout_ = eventServeParamCopy_.activeConsumerTimeout_.total_seconds();
     consumerQueueSize_ = eventServeParamCopy_.consumerQueueSize_;
     consumerQueuePolicy_ = eventServeParamCopy_.consumerQueuePolicy_;
     _DQMactiveConsumerTimeout = eventServeParamCopy_._DQMactiveConsumerTimeout.total_seconds();
     _DQMconsumerQueueSize = eventServeParamCopy_._DQMconsumerQueueSize;
     _DQMconsumerQueuePolicy = eventServeParamCopy_._DQMconsumerQueuePolicy;
 
     // bind the local xdata variables to the infospace
     infoSpace->fireItemAvailable("activeConsumerTimeout", &activeConsumerTimeout_);
     infoSpace->fireItemAvailable("consumerQueueSize", &consumerQueueSize_);
     infoSpace->fireItemAvailable("consumerQueuePolicy", &consumerQueuePolicy_);
     infoSpace->fireItemAvailable("DQMactiveConsumerTimeout", &_DQMactiveConsumerTimeout);
     infoSpace->fireItemAvailable("DQMconsumerQueueSize", &_DQMconsumerQueueSize);
     infoSpace->fireItemAvailable("DQMconsumerQueuePolicy",&_DQMconsumerQueuePolicy);
   }

void smproxy::Configuration::setupQueueConfigurationInfoSpaceParams ( xdata::InfoSpace * infoSpace )

private

Definition at line 219 of file Configuration.cc.

References stor::utils::durationToSeconds(), smproxy::QueueConfigurationParams::monitoringSleepSec_, monitoringSleepSec_, queueConfigParamCopy_, smproxy::QueueConfigurationParams::registrationQueueSize_, and registrationQueueSize_.

   {
     // copy the initial defaults to the xdata variables
     registrationQueueSize_ = queueConfigParamCopy_.registrationQueueSize_;
     monitoringSleepSec_ =
       stor::utils::durationToSeconds(queueConfigParamCopy_.monitoringSleepSec_);
     
     // bind the local xdata variables to the infospace
     infoSpace->fireItemAvailable("registrationQueueSize", &registrationQueueSize_);
     infoSpace->fireItemAvailable("monitoringSleepSec", &monitoringSleepSec_);
   }

void smproxy::Configuration::updateAllParams ( )

Updates the local copy of all configuration parameters from the infospace.

Definition at line 72 of file Configuration.cc.

References generalMutex_, updateLocalAlarmData(), updateLocalDataRetrieverData(), updateLocalDQMArchivingData(), updateLocalDQMProcessingData(), updateLocalEventServingData(), and updateLocalQueueConfigurationData().

   {
     boost::mutex::scoped_lock sl(generalMutex_);
     updateLocalDataRetrieverData();
     updateLocalEventServingData();
     updateLocalDQMProcessingData();
     updateLocalDQMArchivingData();
     updateLocalQueueConfigurationData();
     updateLocalAlarmData();
   }

void smproxy::Configuration::updateLocalAlarmData ( )

private

Definition at line 301 of file Configuration.cc.

References alarmParamCopy_, smproxy::AlarmParams::corruptedEventRate_, corruptedEventRate_, smproxy::AlarmParams::sendAlarms_, and sendAlarms_.

Referenced by updateAllParams().

   {
     alarmParamCopy_.sendAlarms_ = sendAlarms_;
     alarmParamCopy_.corruptedEventRate_ = corruptedEventRate_;
   }

void smproxy::Configuration::updateLocalDataRetrieverData ( )

private

Definition at line 243 of file Configuration.cc.

References smproxy::DataRetrieverParams::allowMissingSM_, allowMissingSM_, smproxy::DataRetrieverParams::connectTrySleepTime_, connectTrySleepTime_, dataRetrieverParamCopy_, stor::utils::getStdVector(), smproxy::DataRetrieverParams::headerRetryInterval_, headerRetryInterval_, smproxy::DataRetrieverParams::maxConnectionRetries_, maxConnectionRetries_, smproxy::DataRetrieverParams::retryInterval_, retryInterval_, smproxy::DataRetrieverParams::sleepTimeIfIdle_, sleepTimeIfIdle_, smproxy::DataRetrieverParams::smRegistrationList_, and smRegistrationList_.

Referenced by updateAllParams().

   {
     stor::utils::getStdVector(smRegistrationList_, dataRetrieverParamCopy_.smRegistrationList_);
     dataRetrieverParamCopy_.allowMissingSM_ = allowMissingSM_;
     dataRetrieverParamCopy_.maxConnectionRetries_ = maxConnectionRetries_;
     dataRetrieverParamCopy_.connectTrySleepTime_ = connectTrySleepTime_;
     dataRetrieverParamCopy_.headerRetryInterval_ = headerRetryInterval_;
     dataRetrieverParamCopy_.retryInterval_ = retryInterval_;
     dataRetrieverParamCopy_.sleepTimeIfIdle_ =
       boost::posix_time::milliseconds(sleepTimeIfIdle_);
   }

void smproxy::Configuration::updateLocalDQMArchivingData ( )

private

Definition at line 286 of file Configuration.cc.

References smproxy::DQMArchivingParams::archiveDQM_, archiveDQM_, smproxy::DQMArchivingParams::archiveIntervalDQM_, archiveIntervalDQM_, smproxy::DQMArchivingParams::archiveTopLevelFolder_, archiveTopLevelFolder_, dqmArchivingParamCopy_, smproxy::DQMArchivingParams::filePrefixDQM_, and filePrefixDQM_.

Referenced by updateAllParams().

   {
     dqmArchivingParamCopy_.archiveDQM_ = archiveDQM_;
     dqmArchivingParamCopy_.archiveTopLevelFolder_ = archiveTopLevelFolder_;
     dqmArchivingParamCopy_.archiveIntervalDQM_ = archiveIntervalDQM_;
     dqmArchivingParamCopy_.filePrefixDQM_ = filePrefixDQM_;
   }

void smproxy::Configuration::updateLocalDQMProcessingData ( )

private

Definition at line 277 of file Configuration.cc.

References stor::DQMProcessingParams::collateDQM_, collateDQM_, stor::DQMProcessingParams::compressionLevelDQM_, compressionLevelDQM_, dqmProcessingParamCopy_, stor::DQMProcessingParams::readyTimeDQM_, readyTimeDQM_, seconds(), stor::DQMProcessingParams::useCompressionDQM_, and useCompressionDQM_.

Referenced by updateAllParams().

   {
     dqmProcessingParamCopy_.collateDQM_ = collateDQM_;
     dqmProcessingParamCopy_.readyTimeDQM_ =
       boost::posix_time::seconds( static_cast<int>(readyTimeDQM_) );
     dqmProcessingParamCopy_.useCompressionDQM_ = useCompressionDQM_;
     dqmProcessingParamCopy_.compressionLevelDQM_ = compressionLevelDQM_;
   }

void smproxy::Configuration::updateLocalEventServingData ( )

private

Definition at line 255 of file Configuration.cc.

References stor::EventServingParams::_DQMactiveConsumerTimeout, _DQMactiveConsumerTimeout, stor::EventServingParams::_DQMconsumerQueuePolicy, _DQMconsumerQueuePolicy, stor::EventServingParams::_DQMconsumerQueueSize, _DQMconsumerQueueSize, stor::EventServingParams::activeConsumerTimeout_, activeConsumerTimeout_, stor::EventServingParams::consumerQueuePolicy_, consumerQueuePolicy_, stor::EventServingParams::consumerQueueSize_, consumerQueueSize_, eventServeParamCopy_, and seconds().

Referenced by updateAllParams().

   {
     eventServeParamCopy_.activeConsumerTimeout_ =
       boost::posix_time::seconds( static_cast<int>(activeConsumerTimeout_) );
     eventServeParamCopy_.consumerQueueSize_ = consumerQueueSize_;
     eventServeParamCopy_.consumerQueuePolicy_ = consumerQueuePolicy_;
     eventServeParamCopy_._DQMactiveConsumerTimeout = 
       boost::posix_time::seconds( static_cast<int>(_DQMactiveConsumerTimeout) );
     eventServeParamCopy_._DQMconsumerQueueSize = _DQMconsumerQueueSize;
     eventServeParamCopy_._DQMconsumerQueuePolicy = _DQMconsumerQueuePolicy;
     
     // validation
     if (eventServeParamCopy_.consumerQueueSize_ < 1)
     {
       eventServeParamCopy_.consumerQueueSize_ = 1;
     }
     if (eventServeParamCopy_._DQMconsumerQueueSize < 1)
     {
       eventServeParamCopy_._DQMconsumerQueueSize = 1;
     }
   }

void smproxy::Configuration::updateLocalQueueConfigurationData ( )

private

Definition at line 294 of file Configuration.cc.

References smproxy::QueueConfigurationParams::monitoringSleepSec_, monitoringSleepSec_, queueConfigParamCopy_, smproxy::QueueConfigurationParams::registrationQueueSize_, registrationQueueSize_, and stor::utils::secondsToDuration().

Referenced by updateAllParams().

   {
     queueConfigParamCopy_.registrationQueueSize_ = registrationQueueSize_;
     queueConfigParamCopy_.monitoringSleepSec_ =
       stor::utils::secondsToDuration(monitoringSleepSec_);
   }