Public Types | |
using | EventSetupRecordKey = edm::eventsetup::EventSetupRecordKey |
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 > | count_ |
std::atomic< unsigned int > | count_initializeForNewIOV_ |
std::atomic< unsigned int > | count_setIntervalFor_ |
std::atomic< unsigned int > | maxCount_ |
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 &) |
Definition at line 55 of file TestESConcurrentSource.cc.
Definition at line 57 of file TestESConcurrentSource.cc.
|
explicit |
Definition at line 121 of file TestESConcurrentSource.cc.
References muonDTDigis_cfi::pset, setOfIOV_, groupFilesInBlocks::temp, and heppy_batch::val.
|
override |
Definition at line 139 of file TestESConcurrentSource.cc.
References maxCount_.
void edmtest::TestESConcurrentSource::busyWait | ( | char const * | msg | ) | const |
Definition at line 233 of file TestESConcurrentSource.cc.
References funct::cos(), mps_fire::i, iterations_, mps_check::msg, and pi_.
Referenced by edmtest::TestESConcurrentSourceTestProxy::prefetch(), and setIntervalFor().
|
static |
Definition at line 143 of file TestESConcurrentSource.cc.
References edm::ConfigurationDescriptions::addDefault(), and submitPVResolutionJobs::desc.
|
inline |
Definition at line 65 of file TestESConcurrentSource.cc.
References count_, visualization-live-secondInstance_cfg::m, maxCount_, and findQualityFiles::v.
Referenced by edmtest::TestESConcurrentSourceTestProxy::prefetch(), and setIntervalFor().
|
overrideprivatevirtual |
Reimplemented from edm::eventsetup::DataProxyProvider.
Definition at line 219 of file TestESConcurrentSource.cc.
References Exception, expectedNumberOfConcurrentIOVs_, crabWrapper::key, and nConcurrentIOVs_.
|
inlineoverrideprivatevirtual |
Reimplemented from edm::EventSetupRecordIntervalFinder.
Definition at line 78 of file TestESConcurrentSource.cc.
|
overrideprivatevirtual |
Implements edm::eventsetup::DataProxyProvider.
Definition at line 197 of file TestESConcurrentSource.cc.
References Exception, expectedNumberOfConcurrentIOVs_, and nConcurrentIOVs_.
|
overrideprivatevirtual |
Implements edm::EventSetupRecordIntervalFinder.
Definition at line 153 of file TestESConcurrentSource.cc.
References busyWait(), checkIOVInitialization_, count_, count_initializeForNewIOV_, count_setIntervalFor_, edm::IOVSyncValue::endOfTime(), Exception, incrementCount(), edm::ValidityInterval::invalidInterval(), edm::EventID::maxEventNumber(), and setOfIOV_.
|
private |
Definition at line 88 of file TestESConcurrentSource.cc.
Referenced by setIntervalFor().
std::atomic<unsigned int> edmtest::TestESConcurrentSource::count_ |
Definition at line 72 of file TestESConcurrentSource.cc.
Referenced by incrementCount(), edmtest::TestESConcurrentSourceTestProxy::prefetch(), and setIntervalFor().
std::atomic<unsigned int> edmtest::TestESConcurrentSource::count_initializeForNewIOV_ |
Definition at line 75 of file TestESConcurrentSource.cc.
Referenced by edmtest::TestESConcurrentSourceTestProxy::initializeForNewIOV(), and setIntervalFor().
std::atomic<unsigned int> edmtest::TestESConcurrentSource::count_setIntervalFor_ |
Definition at line 74 of file TestESConcurrentSource.cc.
Referenced by setIntervalFor().
|
private |
Definition at line 86 of file TestESConcurrentSource.cc.
Referenced by initConcurrentIOVs(), and registerProxies().
|
private |
Definition at line 84 of file TestESConcurrentSource.cc.
Referenced by busyWait().
std::atomic<unsigned int> edmtest::TestESConcurrentSource::maxCount_ |
Definition at line 73 of file TestESConcurrentSource.cc.
Referenced by incrementCount(), and ~TestESConcurrentSource().
|
private |
Definition at line 87 of file TestESConcurrentSource.cc.
Referenced by initConcurrentIOVs(), and registerProxies().
|
private |
Definition at line 85 of file TestESConcurrentSource.cc.
Referenced by busyWait().
|
private |
Definition at line 83 of file TestESConcurrentSource.cc.
Referenced by setIntervalFor(), and TestESConcurrentSource().