Integration/test/testConcurrentIOVsForce_cfg.py

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