Integration/test/testAllowConcurrentIOVs_cfg.py

0001 # Similar to testConcurrentIOVsForce
0002 # Should only run 1 IOV at time for ESTestRecordA
0003 # because that limit is hard coded in the record's class definition.
0004
0005 import FWCore.ParameterSet.Config as cms
0006
0007 process = cms.Process("TEST")
0008
0009 process.source = cms.Source("EmptySource",
0010     firstRun = cms.untracked.uint32(1),
0011     firstLuminosityBlock = cms.untracked.uint32(1),
0012     firstEvent = cms.untracked.uint32(1),
0013     numberEventsInLuminosityBlock = cms.untracked.uint32(1),
0014     numberEventsInRun = cms.untracked.uint32(100)
0015 )
0016
0017 process.maxEvents = cms.untracked.PSet(
0018     input = cms.untracked.int32(8)
0019 )
0020
0021 process.options = dict(
0022     numberOfThreads = 4,
0023     numberOfStreams = 4,
0024     numberOfConcurrentRuns = 1,
0025     numberOfConcurrentLuminosityBlocks = 4,
0026     eventSetup = dict(
0027         numberOfConcurrentIOVs = 4
0028     )
0029 )
0030
0031 process.emptyESSourceI = cms.ESSource("EmptyESSource",
0032     recordName = cms.string("ESTestRecordI"),
0033     firstValid = cms.vuint32(1,100),
0034     iovIsRunNotTime = cms.bool(True)
0035 )
0036
0037 process.emptyESSourceK = cms.ESSource("EmptyESSource",
0038     recordName = cms.string("ESTestRecordK"),
0039     firstValid = cms.vuint32(1,100),
0040     iovIsRunNotTime = cms.bool(True)
0041 )
0042
0043 process.concurrentIOVESSource = cms.ESSource("ConcurrentIOVESSource",
0044     iovIsRunNotTime = cms.bool(True),
0045     firstValidLumis = cms.vuint32(1, 4, 6, 7, 8, 9),
0046     invalidLumis = cms.vuint32(),
0047     concurrentFinder = cms.bool(True),
0048     findForRecordA = cms.bool(True)
0049 )
0050
0051 process.esTestAnalyzerA = cms.EDAnalyzer("ESTestAnalyzerA",
0052     runsToGetDataFor = cms.vint32(1)
0053 )
0054
0055 process.concurrentIOVESProducer = cms.ESProducer("ConcurrentIOVESProducer")
0056
0057 process.test = cms.EDAnalyzer("ConcurrentIOVAnalyzer",
0058                               checkExpectedValues = cms.untracked.bool(True)
0059 )
0060
0061 process.busy1 = cms.EDProducer("BusyWaitIntProducer",ivalue = cms.int32(1), iterations = cms.uint32(10*1000*1000))
0062
0063 process.p1 = cms.Path(process.busy1 * process.test * process.esTestAnalyzerA)