Integration/test/testConcurrentIOVsLegacy_cfg.py

0001 # Similar to testConcurrentIOVsForce
0002 # The difference is the ConcurrentIOVESSource
0003 # has been configured to run with its concurrentFinder
0004 # parameter set to false.
0005 # in all cases the produce method will refer
0006 # to the IOV from the immediately preceding
0007 # setIntervalFor function call. This effectively
0008 # forces one IOV at a time for IOVs related to
0009 # records found by that ESSource.
0010
0011 import FWCore.ParameterSet.Config as cms
0012
0013 process = cms.Process("TEST")
0014
0015 process.source = cms.Source("EmptySource",
0016     firstRun = cms.untracked.uint32(1),
0017     firstLuminosityBlock = cms.untracked.uint32(1),
0018     firstEvent = cms.untracked.uint32(1),
0019     numberEventsInLuminosityBlock = cms.untracked.uint32(1),
0020     numberEventsInRun = cms.untracked.uint32(100)
0021 )
0022
0023 process.maxEvents = cms.untracked.PSet(
0024   input = cms.untracked.int32(8)
0025 )
0026
0027 process.options = dict(
0028     numberOfThreads = 4,
0029     numberOfStreams = 4,
0030     numberOfConcurrentRuns = 1,
0031     numberOfConcurrentLuminosityBlocks = 4,
0032     eventSetup = dict(
0033         numberOfConcurrentIOVs = 2
0034     )
0035 )
0036
0037 process.emptyESSourceI = cms.ESSource("EmptyESSource",
0038     recordName = cms.string("ESTestRecordI"),
0039     firstValid = cms.vuint32(1,100),
0040     iovIsRunNotTime = cms.bool(True)
0041 )
0042
0043 process.emptyESSourceK = cms.ESSource("EmptyESSource",
0044     recordName = cms.string("ESTestRecordK"),
0045     firstValid = cms.vuint32(1,100),
0046     iovIsRunNotTime = cms.bool(True)
0047 )
0048
0049 process.concurrentIOVESSource = cms.ESSource("ConcurrentIOVESSource",
0050     iovIsRunNotTime = cms.bool(True),
0051     firstValidLumis = cms.vuint32(1, 4, 6, 7, 8, 9),
0052     invalidLumis = cms.vuint32(),
0053     concurrentFinder = cms.bool(False)
0054 )
0055
0056 process.concurrentIOVESProducer = cms.ESProducer("ConcurrentIOVESProducer")
0057
0058 process.test = cms.EDAnalyzer("ConcurrentIOVAnalyzer",
0059                               checkExpectedValues = cms.untracked.bool(False)
0060 )
0061
0062 process.busy1 = cms.EDProducer("BusyWaitIntProducer",ivalue = cms.int32(1), iterations = cms.uint32(10*1000*1000))
0063
0064 process.p1 = cms.Path(process.busy1 * process.test)