Integration/test/testESProducerUsingAcquire_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002
0003 process = cms.Process("TEST")
0004
0005 process.source = cms.Source("EmptySource",
0006     firstRun = cms.untracked.uint32(1),
0007     firstLuminosityBlock = cms.untracked.uint32(1),
0008     firstEvent = cms.untracked.uint32(1),
0009     numberEventsInLuminosityBlock = cms.untracked.uint32(1),
0010     numberEventsInRun = cms.untracked.uint32(100)
0011 )
0012
0013 process.maxEvents.input = 8
0014
0015 process.options = dict(
0016     numberOfThreads = 4,
0017     numberOfStreams = 4,
0018     numberOfConcurrentRuns = 1,
0019     numberOfConcurrentLuminosityBlocks = 4,
0020     eventSetup = dict(
0021         numberOfConcurrentIOVs = 2
0022     )
0023 )
0024
0025 process.emptyESSourceI = cms.ESSource("EmptyESSource",
0026     recordName = cms.string("ESTestRecordI"),
0027     firstValid = cms.vuint32(1),
0028     iovIsRunNotTime = cms.bool(True)
0029 )
0030
0031 process.concurrentIOVESSource = cms.ESSource("ConcurrentIOVESSource",
0032     iovIsRunNotTime = cms.bool(True),
0033     firstValidLumis = cms.vuint32(1, 4, 6, 7, 8, 9),
0034     invalidLumis = cms.vuint32(),
0035     concurrentFinder = cms.bool(True)
0036 )
0037
0038 process.concurrentIOVESProducer = cms.ESProducer("ConcurrentIOVESProducer")
0039
0040 process.acquireIntESProducer = cms.ESProducer("AcquireIntESProducer",
0041     numberOfIOVsToAccumulate = cms.untracked.uint32(2),
0042     secondsToWaitForWork = cms.untracked.uint32(1)
0043 )
0044
0045 process.test = cms.EDAnalyzer("ConcurrentIOVAnalyzer",
0046                               checkExpectedValues = cms.untracked.bool(True),
0047                               # first 3 just ignored (indexed by cacheIdentifier that starts at 3 in this test)
0048                               # beginRun 1 + endRun 1 + beginLumi 1 + endLumi 3 + cacheIdentifier 3 = 9
0049                               # 9 + 5 (external work increments each of the 5 values by 1) = 14,
0050                               # runs are always 1, lumi ranges 1-3, 4-5, 6, 7, 8
0051                               # cacheIdentifier increments by 1 each time 3, 4, 5, 6, 7
0052                               expectedESAcquireTestResults = cms.untracked.vint32(0, 0, 0, 14, 20, 24, 27, 30),
0053                               expectedUniquePtrTestValue = cms.untracked.int32(102),
0054                               expectedOptionalTestValue = cms.untracked.int32(202)
0055 )
0056
0057 process.emptyESSourceB = cms.ESSource("EmptyESSource",
0058     recordName = cms.string("ESTestRecordB"),
0059     firstValid = cms.vuint32(1),
0060     iovIsRunNotTime = cms.bool(True)
0061 )
0062 process.esTestAnalyzerB = cms.EDAnalyzer("ESTestAnalyzerB",
0063     runsToGetDataFor = cms.vint32(1),
0064     expectedValues = cms.untracked.vint32(11, 11, 11, 11, 11, 11, 11, 11)
0065 )
0066
0067 process.busy1 = cms.EDProducer("BusyWaitIntProducer",ivalue = cms.int32(1), iterations = cms.uint32(10*1000*1000))
0068
0069 process.p1 = cms.Path(process.busy1 * process.test * process.esTestAnalyzerB)