#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 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	setDataRetrieverDefaults (unsigned long instanceNumber)

void	setDQMArchivingDefaults ()

void	setDQMProcessingDefaults ()

void	setEventServingDefaults ()

void	setQueueConfigurationDefaults ()

void	setupDataRetrieverInfoSpaceParams (xdata::InfoSpace *)

void	setupDQMArchivingInfoSpaceParams (xdata::InfoSpace *)

void	setupDQMProcessingInfoSpaceParams (xdata::InfoSpace *)

void	setupEventServingInfoSpaceParams (xdata::InfoSpace *)

void	setupQueueConfigurationInfoSpaceParams (xdata::InfoSpace *)

void	updateLocalDataRetrieverData ()

void	updateLocalDQMArchivingData ()

void	updateLocalDQMProcessingData ()

void	updateLocalEventServingData ()

void	updateLocalQueueConfigurationData ()

Private Attributes
xdata::Integer	_DQMactiveConsumerTimeout

xdata::String	_DQMconsumerQueuePolicy

xdata::Integer	_DQMconsumerQueueSize

xdata::Integer	activeConsumerTimeout_

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_

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::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.1.2.14

Date:: 2011/03/02 10:59:37

Definition at line 75 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();
 
     setupDataRetrieverInfoSpaceParams(infoSpace);
     setupEventServingInfoSpaceParams(infoSpace);
     setupDQMProcessingInfoSpaceParams(infoSpace);
     setupDQMArchivingInfoSpaceParams(infoSpace);
     setupQueueConfigurationInfoSpaceParams(infoSpace);
   }

virtual smproxy::Configuration::~Configuration ( )

inlinevirtual

Destructor.

Definition at line 88 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 273 of file Configuration.cc.

References generalMutex_.

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

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 34 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 52 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 46 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 40 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 58 of file Configuration.cc.

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

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

private

Definition at line 74 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 114 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 106 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 96 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 122 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::setupDataRetrieverInfoSpaceParams ( xdata::InfoSpace * infoSpace )

private

Definition at line 129 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 187 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 171 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 151 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 203 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 64 of file Configuration.cc.

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

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

void smproxy::Configuration::updateLocalDataRetrieverData ( )

private

Definition at line 215 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 258 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 249 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 227 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 266 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_);
   }