Integration/test/testConcurrentIOVs_cfg.py

0001 # This test should almost always be running 4 lumis concurrently
0002 # and 2 IOVs concurrently. It prints out times that allow one
0003 # to verify this by manually looking at the log file. We did
0004 # not make the relationship between these times into a unit test
0005 # pass/fail criteria because in unusual cases the relationship
0006 # between times could vary. For example, if a thread got stuck on
0007 # a very busy machine the times could be very different. We do not
0008 # want unit tests that sometimes fail.
0009
0010 import FWCore.ParameterSet.Config as cms
0011
0012 process = cms.Process("TEST")
0013
0014 process.source = cms.Source("EmptySource",
0015     firstRun = cms.untracked.uint32(1),
0016     firstLuminosityBlock = cms.untracked.uint32(1),
0017     firstEvent = cms.untracked.uint32(1),
0018     numberEventsInLuminosityBlock = cms.untracked.uint32(1),
0019     numberEventsInRun = cms.untracked.uint32(100)
0020 )
0021
0022 process.maxEvents = cms.untracked.PSet(
0023     input = cms.untracked.int32(8)
0024 )
0025
0026 process.options = dict(
0027     numberOfThreads = 4,
0028     numberOfStreams = 4,
0029     numberOfConcurrentRuns = 1,
0030     numberOfConcurrentLuminosityBlocks = 4,
0031     eventSetup = dict(
0032         numberOfConcurrentIOVs = 2
0033     )
0034 )
0035
0036 process.emptyESSourceI = cms.ESSource("EmptyESSource",
0037     recordName = cms.string("ESTestRecordI"),
0038     firstValid = cms.vuint32(1,100),
0039     iovIsRunNotTime = cms.bool(True)
0040 )
0041
0042 process.emptyESSourceK = cms.ESSource("EmptyESSource",
0043     recordName = cms.string("ESTestRecordK"),
0044     firstValid = cms.vuint32(1,100),
0045     iovIsRunNotTime = cms.bool(True)
0046 )
0047
0048 process.concurrentIOVESSource = cms.ESSource("ConcurrentIOVESSource",
0049     iovIsRunNotTime = cms.bool(True),
0050     firstValidLumis = cms.vuint32(1, 4, 6, 7, 8, 9),
0051     invalidLumis = cms.vuint32(),
0052     concurrentFinder = cms.bool(True)
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)