Inheritance diagram for edmtest::TestESSource:

Public Types
using	EventSetupRecordKey = edm::eventsetup::EventSetupRecordKey

Public Member Functions
void	busyWait (char const *msg) const

	TestESSource (edm::ParameterSet const &)

	~TestESSource () override

Public Member Functions inherited from edm::eventsetup::DataProxyProvider
void	createKeyedProxies (EventSetupRecordKey const &key, unsigned int nConcurrentIOVs)

	DataProxyProvider ()

	DataProxyProvider (const DataProxyProvider &)=delete

const ComponentDescription &	description () const

void	fillRecordsNotAllowingConcurrentIOVs (std::set< EventSetupRecordKey > &recordsNotAllowingConcurrentIOVs) const

bool	isUsingRecord (const EventSetupRecordKey &key) const

KeyedProxies &	keyedProxies (const EventSetupRecordKey &iRecordKey, unsigned int iovIndex=0)

const DataProxyProvider &	operator= (const DataProxyProvider &)=delete

void	setAppendToDataLabel (const edm::ParameterSet &)

void	setDescription (const ComponentDescription &iDescription)

virtual void	updateLookup (ESRecordsToProxyIndices const &)

std::set< EventSetupRecordKey >	usingRecords () const

virtual	~DataProxyProvider () noexcept(false)

Public Member Functions inherited from edm::EventSetupRecordIntervalFinder
bool	concurrentFinder () const

const eventsetup::ComponentDescription &	descriptionForFinder () const

	EventSetupRecordIntervalFinder ()

	EventSetupRecordIntervalFinder (const EventSetupRecordIntervalFinder &)=delete

std::set< eventsetup::EventSetupRecordKey >	findingForRecords () const

const ValidityInterval &	findIntervalFor (const eventsetup::EventSetupRecordKey &, const IOVSyncValue &)

bool	nonconcurrentAndIOVNeedsUpdate (const eventsetup::EventSetupRecordKey &key, const IOVSyncValue &syncValue) const

const EventSetupRecordIntervalFinder &	operator= (const EventSetupRecordIntervalFinder &)=delete

void	resetInterval (const eventsetup::EventSetupRecordKey &)

void	setDescriptionForFinder (const eventsetup::ComponentDescription &iDescription)

virtual	~EventSetupRecordIntervalFinder () noexcept(false)

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Static Public Member Functions inherited from edm::eventsetup::DataProxyProvider
static void	prevalidate (ConfigurationDescriptions &)

Public Attributes
std::atomic< unsigned int >	count1_

std::atomic< unsigned int >	count2_

std::atomic< unsigned int >	count_

std::mutex	mutex_

edm::SerialTaskQueue	queue_

Private Member Functions
void	initConcurrentIOVs (EventSetupRecordKey const &, unsigned int nConcurrentIOVs) override

bool	isConcurrentFinder () const override

KeyedProxiesVector	registerProxies (EventSetupRecordKey const &, unsigned int iovIndex) override

void	setIntervalFor (EventSetupRecordKey const &, edm::IOVSyncValue const &, edm::ValidityInterval &) override

Private Attributes
bool	checkIOVInitialization_

unsigned int	expectedNumberOfConcurrentIOVs_

const unsigned int	iterations_

unsigned int	nConcurrentIOVs_ = 0

const double	pi_

std::set< edm::IOVSyncValue >	setOfIOV_

Additional Inherited Members
Protected Types inherited from edm::eventsetup::DataProxyProvider
using	KeyedProxiesVector = std::vector< std::pair< DataKey, std::shared_ptr< DataProxy > >>

Protected Member Functions inherited from edm::eventsetup::DataProxyProvider
template<class T >
void	usingRecord ()

void	usingRecordWithKey (const EventSetupRecordKey &key)

Protected Member Functions inherited from edm::EventSetupRecordIntervalFinder
template<class T >
void	findingRecord ()

void	findingRecordWithKey (const eventsetup::EventSetupRecordKey &)

Detailed Description

Definition at line 56 of file TestESSource.cc.

Member Typedef Documentation

◆ EventSetupRecordKey

using edmtest::TestESSource::EventSetupRecordKey = edm::eventsetup::EventSetupRecordKey

Definition at line 58 of file TestESSource.cc.

Constructor & Destructor Documentation

◆ TestESSource()

edmtest::TestESSource::TestESSource ( edm::ParameterSet const & pset )

explicit

Definition at line 119 of file TestESSource.cc.

References muonDTDigis_cfi::pset, setOfIOV_, groupFilesInBlocks::temp, and heppy_batch::val.

       : count_(0),
         count1_(0),
         count2_(0),
         iterations_(pset.getParameter<unsigned int>("iterations")),
         pi_(std::acos(-1)),
         expectedNumberOfConcurrentIOVs_(pset.getParameter<unsigned int>("expectedNumberOfConcurrentIOVs")),
         checkIOVInitialization_(pset.getParameter<bool>("checkIOVInitialization")) {
     std::vector<unsigned int> temp(pset.getParameter<std::vector<unsigned int>>("firstValidLumis"));
     for (auto val : temp) {
       setOfIOV_.insert(edm::IOVSyncValue(edm::EventID(1, val, 0)));
     }
 
     findingRecord<ESTestRecordI>();
     usingRecord<ESTestRecordI>();
   }

◆ ~TestESSource()

edmtest::TestESSource::~TestESSource ( )

override

Definition at line 136 of file TestESSource.cc.

136 {}

Member Function Documentation

◆ busyWait()

void edmtest::TestESSource::busyWait ( char const * msg ) const

Definition at line 225 of file TestESSource.cc.

References funct::cos(), mps_fire::i, iterations_, mps_check::msg, and pi_.

Referenced by edmtest::TestESSourceTestProxy::prefetch(), and setIntervalFor().

                                                    {
     edm::LogAbsolute("TestESSource::busyWait") << "Start TestESSource::busyWait " << msg;
     double sum = 0.;
     const double stepSize = pi_ / iterations_;
     for (unsigned int i = 0; i < iterations_; ++i) {
       sum += stepSize * cos(i * stepSize);
     }
     edm::LogAbsolute("TestESSource::busyWait") << "Stop TestESSource::busyWait " << msg << " " << sum;
   }

◆ fillDescriptions()

void edmtest::TestESSource::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 138 of file TestESSource.cc.

References edm::ConfigurationDescriptions::addDefault(), and submitPVResolutionJobs::desc.

                                                                                 {
     edm::ParameterSetDescription desc;
     std::vector<unsigned int> emptyVector;
     desc.add<unsigned int>("iterations", 10 * 1000 * 1000);
     desc.add<bool>("checkIOVInitialization", false);
     desc.add<unsigned int>("expectedNumberOfConcurrentIOVs", 0);
     desc.add<std::vector<unsigned int>>("firstValidLumis", emptyVector);
     descriptions.addDefault(desc);
   }

◆ initConcurrentIOVs()

void edmtest::TestESSource::initConcurrentIOVs	(	EventSetupRecordKey const &	key,
		unsigned int	nConcurrentIOVs
	)

overrideprivatevirtual

Reimplemented from edm::eventsetup::DataProxyProvider.

Definition at line 211 of file TestESSource.cc.

References Exception, expectedNumberOfConcurrentIOVs_, crabWrapper::key, and nConcurrentIOVs_.

                                                                                                     {
     edm::LogAbsolute("TestESSource::initConcurrentIOVs")
         << "Start TestESSource::initConcurrentIOVs " << nConcurrentIOVs << " " << key.name();
     if (EventSetupRecordKey::makeKey<ESTestRecordI>() != key) {
       throw cms::Exception("TestFailure") << "TestESSource::initConcurrentIOVs,"
                                           << " unexpected EventSetupRecordKey";
     }
     if (expectedNumberOfConcurrentIOVs_ != 0 && nConcurrentIOVs != expectedNumberOfConcurrentIOVs_) {
       throw cms::Exception("TestFailure") << "TestESSource::initConcurrentIOVs,"
                                           << " unexpected number of concurrent IOVs";
     }
     nConcurrentIOVs_ = nConcurrentIOVs;
   }

◆ isConcurrentFinder()

bool edmtest::TestESSource::isConcurrentFinder ( ) const

inlineoverrideprivatevirtual

Reimplemented from edm::EventSetupRecordIntervalFinder.

Definition at line 73 of file TestESSource.cc.

73 { return true; }

◆ registerProxies()

edm::eventsetup::DataProxyProvider::KeyedProxiesVector edmtest::TestESSource::registerProxies	(	EventSetupRecordKey const &	,
		unsigned int	iovIndex
	)

overrideprivatevirtual

Implements edm::eventsetup::DataProxyProvider.

Definition at line 197 of file TestESSource.cc.

References Exception, expectedNumberOfConcurrentIOVs_, and nConcurrentIOVs_.

                                                                                                               {
     if (expectedNumberOfConcurrentIOVs_ != 0 && nConcurrentIOVs_ != expectedNumberOfConcurrentIOVs_) {
       throw cms::Exception("TestFailure") << "TestESSource::registerProxies,"
                                           << " unexpected number of concurrent IOVs";
     }
     KeyedProxiesVector keyedProxiesVector;
 
     edm::eventsetup::DataKey dataKey(edm::eventsetup::DataKey::makeTypeTag<IOVTestInfo>(), edm::eventsetup::IdTags(""));
     keyedProxiesVector.emplace_back(dataKey, std::make_shared<TestESSourceTestProxy>(this));
 
     return keyedProxiesVector;
   }

◆ setIntervalFor()

void edmtest::TestESSource::setIntervalFor	(	EventSetupRecordKey const &	,
		edm::IOVSyncValue const &	syncValue,
		edm::ValidityInterval &	iov
	)

overrideprivatevirtual

Implements edm::EventSetupRecordIntervalFinder.

Definition at line 148 of file TestESSource.cc.

References busyWait(), checkIOVInitialization_, count1_, count2_, count_, edm::IOVSyncValue::endOfTime(), Exception, edm::ValidityInterval::invalidInterval(), edm::EventID::maxEventNumber(), mutex_, and setOfIOV_.

                                                               {
     std::lock_guard<std::mutex> guard(mutex_);
     if (checkIOVInitialization_) {
       // Note that this check should pass with the specific configuration where I enable
       // the check, but in general it does not have to be true. The counts are offset
       // by 1 because the beginRun IOV is invalid (no IOV initialization).
       if (count1_ > 0 && count2_ + 1 != count1_) {
         throw cms::Exception("TestFailure") << "TestESSource::setIntervalFor,"
                                             << " unexpected number of IOV initializations";
       }
     }
     ++count_;
     ++count1_;
     if (count_.load() > 1) {
       throw cms::Exception("TestFailure") << "TestESSource::setIntervalFor,"
                                           << " functions in mutex should not run concurrently";
     }
     busyWait("setIntervalFor");
     iov = edm::ValidityInterval::invalidInterval();
 
     if (setOfIOV_.empty()) {
       --count_;
       return;
     }
 
     std::pair<std::set<edm::IOVSyncValue>::iterator, std::set<edm::IOVSyncValue>::iterator> itFound =
         setOfIOV_.equal_range(syncValue);
 
     if (itFound.first == itFound.second) {
       if (itFound.first == setOfIOV_.begin()) {
         //request is before first valid interval, so fail
         --count_;
         return;
       }
       //go back one step
       --itFound.first;
     }
 
     edm::IOVSyncValue endOfInterval = edm::IOVSyncValue::endOfTime();
     if (itFound.second != setOfIOV_.end()) {
       endOfInterval = edm::IOVSyncValue(
           edm::EventID(1, itFound.second->eventID().luminosityBlock() - 1, edm::EventID::maxEventNumber()));
     }
     iov = edm::ValidityInterval(*(itFound.first), endOfInterval);
     --count_;
   }

Member Data Documentation

◆ checkIOVInitialization_

bool edmtest::TestESSource::checkIOVInitialization_

private

Definition at line 83 of file TestESSource.cc.

Referenced by setIntervalFor().

◆ count1_

std::atomic<unsigned int> edmtest::TestESSource::count1_

Definition at line 67 of file TestESSource.cc.

Referenced by setIntervalFor().

◆ count2_

std::atomic<unsigned int> edmtest::TestESSource::count2_

Definition at line 68 of file TestESSource.cc.

Referenced by edmtest::TestESSourceTestProxy::initializeForNewIOV(), and setIntervalFor().

◆ count_

std::atomic<unsigned int> edmtest::TestESSource::count_

Definition at line 66 of file TestESSource.cc.

Referenced by edmtest::TestESSourceTestProxy::prefetch(), and setIntervalFor().

◆ expectedNumberOfConcurrentIOVs_

unsigned int edmtest::TestESSource::expectedNumberOfConcurrentIOVs_

private

Definition at line 81 of file TestESSource.cc.

Referenced by initConcurrentIOVs(), and registerProxies().

◆ iterations_

const unsigned int edmtest::TestESSource::iterations_

private

Definition at line 79 of file TestESSource.cc.

Referenced by busyWait().

◆ mutex_

std::mutex edmtest::TestESSource::mutex_

Definition at line 70 of file TestESSource.cc.

Referenced by setIntervalFor().

◆ nConcurrentIOVs_

unsigned int edmtest::TestESSource::nConcurrentIOVs_ = 0

private

Definition at line 82 of file TestESSource.cc.

Referenced by initConcurrentIOVs(), and registerProxies().

◆ pi_

const double edmtest::TestESSource::pi_

private

Definition at line 80 of file TestESSource.cc.

Referenced by busyWait().

◆ queue_

edm::SerialTaskQueue edmtest::TestESSource::queue_

Definition at line 69 of file TestESSource.cc.

◆ setOfIOV_

std::set<edm::IOVSyncValue> edmtest::TestESSource::setOfIOV_

private

Definition at line 78 of file TestESSource.cc.

Referenced by setIntervalFor(), and TestESSource().

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ EventSetupRecordKey

Constructor & Destructor Documentation

◆ TestESSource()

◆ ~TestESSource()

Member Function Documentation

◆ busyWait()

◆ fillDescriptions()

◆ initConcurrentIOVs()

◆ isConcurrentFinder()

◆ registerProxies()

◆ setIntervalFor()

Member Data Documentation

◆ checkIOVInitialization_

◆ count1_

◆ count2_

◆ count_

◆ expectedNumberOfConcurrentIOVs_

◆ iterations_

◆ mutex_

◆ nConcurrentIOVs_

◆ pi_

◆ queue_

◆ setOfIOV_