Framework/test/testRunLumiCaches_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002
0003 # These next 4 variables can be modified and the tests should still pass
0004 nStreams = 4
0005 nRuns = 17
0006 nLumisPerRun = 1
0007 nEventsPerLumi = 6
0008
0009 nEventsPerRun = nLumisPerRun*nEventsPerLumi
0010 nLumis = nRuns*nLumisPerRun
0011 nEvents = nRuns*nEventsPerRun
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(nEventsPerLumi),
0020     numberEventsInRun = cms.untracked.uint32(nEventsPerRun)
0021 )
0022
0023 process.maxEvents = cms.untracked.PSet(
0024     input = cms.untracked.int32(nEvents)
0025 )
0026
0027 process.options = cms.untracked.PSet(
0028     numberOfThreads = cms.untracked.uint32(4),
0029     numberOfStreams = cms.untracked.uint32(nStreams),
0030     numberOfConcurrentRuns = cms.untracked.uint32(4),
0031     numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(4)
0032 )
0033
0034 process.busy1 = cms.EDProducer("BusyWaitIntProducer",ivalue = cms.int32(1), iterations = cms.uint32(10*1000*1000))
0035
0036 process.globalRunIntProd = cms.EDProducer("edmtest::global::RunIntProducer",
0037     transitions = cms.int32(2*nRuns)
0038     ,cachevalue = cms.int32(nEventsPerRun)
0039 )
0040
0041 process.globalRunSumIntProd = cms.EDProducer("edmtest::global::RunSummaryIntProducer",
0042     transitions = cms.int32(nRuns*nStreams+2*nRuns)
0043     ,cachevalue = cms.int32(nEventsPerRun)
0044 )
0045
0046 process.globalLumiIntProd = cms.EDProducer("edmtest::global::LumiIntProducer",
0047     transitions = cms.int32(2*nLumis)
0048     ,cachevalue = cms.int32(nEventsPerLumi)
0049 )
0050
0051 process.globalLumiSumIntProd = cms.EDProducer("edmtest::global::LumiSummaryIntProducer",
0052     transitions = cms.int32(nStreams+2*nLumis+nEvents)
0053     ,cachevalue = cms.int32(nEventsPerLumi)
0054 )
0055
0056 process.globalRunIntFilt = cms.EDFilter("edmtest::global::RunIntFilter",
0057     transitions = cms.int32(2*nRuns+nEvents)
0058     ,cachevalue = cms.int32(nEventsPerRun)
0059 )
0060
0061 process.globalRunSumIntFilt = cms.EDFilter("edmtest::global::RunSummaryIntFilter",
0062     transitions = cms.int32(nStreams+nStreams*nRuns+2*nRuns+nEvents)
0063     ,cachevalue = cms.int32(nEventsPerRun)
0064 )
0065
0066 process.globalLumiIntFilt = cms.EDFilter("edmtest::global::LumiIntFilter",
0067     transitions = cms.int32(2*nLumis+nEvents)
0068     ,cachevalue = cms.int32(nEventsPerLumi)
0069 )
0070
0071 process.globalLumiSumIntFilt = cms.EDFilter("edmtest::global::LumiSummaryIntFilter",
0072     transitions = cms.int32(nStreams+2*nLumis+nEvents)
0073     ,cachevalue = cms.int32(nEventsPerLumi)
0074 )
0075
0076 process.globalRunIntAna = cms.EDAnalyzer("edmtest::global::RunIntAnalyzer",
0077     transitions = cms.int32(2*nRuns+nEvents)
0078     ,cachevalue = cms.int32(nEventsPerRun)
0079 )
0080
0081 process.globalRunSumIntAna = cms.EDAnalyzer("edmtest::global::RunSummaryIntAnalyzer",
0082     transitions = cms.int32(nStreams+nStreams*nRuns+2*nRuns+nEvents)
0083     ,cachevalue = cms.int32(nEventsPerRun)
0084 )
0085
0086 process.globalLumiIntAna = cms.EDAnalyzer("edmtest::global::LumiIntAnalyzer",
0087     transitions = cms.int32(2*nLumis+nEvents)
0088     ,cachevalue = cms.int32(nEventsPerLumi)
0089     ,moduleLabel = cms.InputTag("TestAccumulator1")
0090 )
0091
0092 process.globalLumiSumIntAna = cms.EDAnalyzer("edmtest::global::LumiSummaryIntAnalyzer",
0093     transitions = cms.int32(nStreams+2*nLumis+nEvents)
0094     ,cachevalue = cms.int32(nEventsPerLumi)
0095 )
0096
0097 process.limitedRunIntProd = cms.EDProducer("edmtest::limited::RunIntProducer",
0098     concurrencyLimit = cms.untracked.uint32(1),
0099     transitions = cms.int32(2*nRuns)
0100     ,cachevalue = cms.int32(nEventsPerRun)
0101 )
0102
0103 process.limitedRunSumIntProd = cms.EDProducer("edmtest::limited::RunSummaryIntProducer",
0104     concurrencyLimit = cms.untracked.uint32(1),
0105     transitions = cms.int32(nStreams*nRuns+2*nRuns)
0106     ,cachevalue = cms.int32(nEventsPerRun)
0107 )
0108
0109 process.limitedLumiIntProd = cms.EDProducer("edmtest::limited::LumiIntProducer",
0110     concurrencyLimit = cms.untracked.uint32(1),
0111     transitions = cms.int32(2*nLumis)
0112     ,cachevalue = cms.int32(nEventsPerLumi)
0113 )
0114
0115 process.limitedLumiSumIntProd = cms.EDProducer("edmtest::limited::LumiSummaryIntProducer",
0116     concurrencyLimit = cms.untracked.uint32(1),
0117     transitions = cms.int32(nStreams+2*nLumis+nEvents)
0118     ,cachevalue = cms.int32(nEventsPerLumi)
0119 )
0120
0121 process.limitedRunIntFilt = cms.EDFilter("edmtest::limited::RunIntFilter",
0122     concurrencyLimit = cms.untracked.uint32(1),
0123     transitions = cms.int32(2*nRuns+nEvents)
0124     ,cachevalue = cms.int32(nEventsPerRun)
0125 )
0126
0127 process.limitedRunSumIntFilt = cms.EDFilter("edmtest::limited::RunSummaryIntFilter",
0128     concurrencyLimit = cms.untracked.uint32(1),
0129     transitions = cms.int32(nStreams+nStreams*nRuns+2*nRuns+nEvents)
0130     ,cachevalue = cms.int32(nEventsPerRun)
0131 )
0132
0133 process.limitedLumiIntFilt = cms.EDFilter("edmtest::limited::LumiIntFilter",
0134     concurrencyLimit = cms.untracked.uint32(1),
0135     transitions = cms.int32(2*nLumis+nEvents)
0136     ,cachevalue = cms.int32(nEventsPerLumi)
0137 )
0138
0139 process.limitedLumiSumIntFilt = cms.EDFilter("edmtest::limited::LumiSummaryIntFilter",
0140     concurrencyLimit = cms.untracked.uint32(1),
0141     transitions = cms.int32(nStreams+2*nLumis+nEvents)
0142     ,cachevalue = cms.int32(nEventsPerLumi)
0143 )
0144
0145 process.limitedRunIntAna = cms.EDAnalyzer("edmtest::limited::RunIntAnalyzer",
0146     concurrencyLimit = cms.untracked.uint32(1),
0147     transitions = cms.int32(2*nRuns+nEvents)
0148     ,cachevalue = cms.int32(nEventsPerRun)
0149 )
0150
0151 process.limitedRunSumIntAna = cms.EDAnalyzer("edmtest::limited::RunSummaryIntAnalyzer",
0152     concurrencyLimit = cms.untracked.uint32(1),
0153     transitions = cms.int32(nStreams+nStreams*nRuns+2*nRuns+nEvents)
0154     ,cachevalue = cms.int32(nEventsPerRun)
0155 )
0156
0157 process.limitedLumiIntAna = cms.EDAnalyzer("edmtest::limited::LumiIntAnalyzer",
0158     concurrencyLimit = cms.untracked.uint32(1),
0159     transitions = cms.int32(2*nLumis+nEvents)
0160     ,cachevalue = cms.int32(nEventsPerLumi)
0161     ,moduleLabel = cms.InputTag("TestAccumulator1")
0162 )
0163
0164 process.limitedLumiSumIntAna = cms.EDAnalyzer("edmtest::limited::LumiSummaryIntAnalyzer",
0165     concurrencyLimit = cms.untracked.uint32(1),
0166     transitions = cms.int32(nStreams+2*nLumis+nEvents)
0167     ,cachevalue = cms.int32(nEventsPerLumi)
0168 )
0169
0170 process.oneRunCacheProd = cms.EDProducer("edmtest::one::RunCacheProducer",
0171     transitions = cms.int32(2*nRuns+nEvents)
0172 )
0173
0174 process.oneLumiBlockCacheProd = cms.EDProducer("edmtest::one::LumiBlockCacheProducer",
0175     transitions = cms.int32(2*nLumis+nEvents)
0176 )
0177
0178 process.oneRunCacheFilt = cms.EDFilter("edmtest::one::RunCacheFilter",
0179     transitions = cms.int32(2*nRuns+nEvents)
0180 )
0181
0182 process.oneLumiBlockCacheFilt = cms.EDFilter("edmtest::one::LumiBlockCacheFilter",
0183     transitions = cms.int32(2*nRuns+nEvents)
0184 )
0185
0186 process.oneRunCacheAna = cms.EDAnalyzer("edmtest::one::RunCacheAnalyzer",
0187     transitions = cms.int32(2*nRuns+nEvents)
0188 )
0189
0190 process.oneLumiBlockCacheAna = cms.EDAnalyzer("edmtest::one::LumiBlockCacheAnalyzer",
0191     transitions = cms.int32(2*nRuns+nEvents)
0192 )
0193
0194 process.streamRunIntProd = cms.EDProducer("edmtest::stream::RunIntProducer",
0195     transitions = cms.int32(2*nRuns+nEvents)
0196     ,cachevalue = cms.int32(nEventsPerRun)
0197 )
0198
0199 process.streamLumiIntProd = cms.EDProducer("edmtest::stream::LumiIntProducer",
0200     transitions = cms.int32(2*nLumis+nEvents)
0201     ,cachevalue = cms.int32(nEventsPerLumi)
0202 )
0203
0204 process.streamRunSumIntProd = cms.EDProducer("edmtest::stream::RunSummaryIntProducer",
0205     transitions = cms.int32(4*nRuns+nEvents)
0206     ,cachevalue = cms.int32(nEventsPerRun)
0207 )
0208
0209 process.streamLumiSumIntProd = cms.EDProducer("edmtest::stream::LumiSummaryIntProducer",
0210     transitions = cms.int32(4*nLumis+nEvents)
0211     ,cachevalue = cms.int32(nEventsPerLumi)
0212 )
0213
0214 process.streamRunIntFilt = cms.EDFilter("edmtest::stream::RunIntFilter",
0215     transitions = cms.int32(2*nRuns+nEvents)
0216     ,cachevalue = cms.int32(nEventsPerRun)
0217 )
0218
0219 process.streamLumiIntFilt = cms.EDFilter("edmtest::stream::LumiIntFilter",
0220     transitions = cms.int32(2*nLumis+nEvents)
0221     ,cachevalue = cms.int32(nEventsPerLumi)
0222 )
0223
0224 process.streamRunSumIntFilt = cms.EDFilter("edmtest::stream::RunSummaryIntFilter",
0225     transitions = cms.int32(4*nRuns+nEvents)
0226     ,cachevalue = cms.int32(nEventsPerRun)
0227 )
0228
0229 process.streamLumiSumIntFilt = cms.EDFilter("edmtest::stream::LumiSummaryIntFilter",
0230     transitions = cms.int32(4*nLumis+nEvents)
0231     ,cachevalue = cms.int32(nEventsPerLumi)
0232 )
0233
0234 process.streamRunIntAna = cms.EDAnalyzer("edmtest::stream::RunIntAnalyzer",
0235     transitions = cms.int32(2*nRuns+nEvents)
0236     ,cachevalue = cms.int32(nEventsPerRun)
0237 )
0238
0239 process.streamLumiIntAna = cms.EDAnalyzer("edmtest::stream::LumiIntAnalyzer",
0240     transitions = cms.int32(2*nLumis+nEvents)
0241     ,cachevalue = cms.int32(nEventsPerLumi)
0242     ,moduleLabel = cms.InputTag("TestAccumulator1")
0243 )
0244
0245 process.streamRunSumIntAna = cms.EDAnalyzer("edmtest::stream::RunSummaryIntAnalyzer",
0246     transitions = cms.int32(4*nRuns+nEvents)
0247     ,cachevalue = cms.int32(nEventsPerRun)
0248 )
0249
0250 process.streamLumiSumIntAna = cms.EDAnalyzer("edmtest::stream::LumiSummaryIntAnalyzer",
0251     transitions = cms.int32(4*nLumis+nEvents)
0252     ,cachevalue = cms.int32(nEventsPerLumi)
0253 )
0254
0255 process.path1 = cms.Path(
0256     process.busy1 *
0257     process.globalRunIntProd *
0258     process.globalRunSumIntProd *
0259     process.globalLumiIntProd *
0260     process.globalLumiSumIntProd *
0261     process.globalRunIntFilt *
0262     process.globalRunSumIntFilt *
0263     process.globalLumiIntFilt *
0264     process.globalLumiSumIntFilt *
0265     process.globalRunIntAna *
0266     process.globalRunSumIntAna *
0267     process.globalLumiIntAna *
0268     process.globalLumiSumIntAna *
0269     process.limitedRunIntProd *
0270     process.limitedRunSumIntProd *
0271     process.limitedLumiIntProd *
0272     process.limitedLumiSumIntProd *
0273     process.limitedRunIntFilt *
0274     process.limitedRunSumIntFilt *
0275     process.limitedLumiIntFilt *
0276     process.limitedLumiSumIntFilt *
0277     process.limitedRunIntAna *
0278     process.limitedRunSumIntAna *
0279     process.limitedLumiIntAna *
0280     process.limitedLumiSumIntAna *
0281     process.oneRunCacheProd *
0282     process.oneLumiBlockCacheProd *
0283     process.oneRunCacheFilt *
0284     process.oneLumiBlockCacheFilt *
0285     process.oneRunCacheAna *
0286     process.oneLumiBlockCacheAna *
0287     process.streamRunIntProd *
0288     process.streamLumiIntProd *
0289     process.streamRunSumIntProd *
0290     process.streamLumiSumIntProd *
0291     process.streamRunIntFilt *
0292     process.streamLumiIntFilt *
0293     process.streamRunSumIntFilt *
0294     process.streamLumiSumIntFilt *
0295     process.streamRunIntAna *
0296     process.streamLumiIntAna *
0297     process.streamRunSumIntAna *
0298     process.streamLumiSumIntAna
0299 )