Framework/test/test_limited_modules_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002
0003 nEvtLumi = 4
0004 nEvtRun = 2*nEvtLumi
0005 nRuns = 64
0006 nStreams = 4
0007 nEvt = nRuns*nEvtRun
0008
0009 process = cms.Process("TESTGLOBALMODULES")
0010
0011 import FWCore.Framework.test.cmsExceptionsFatalOption_cff
0012
0013 process.options = cms.untracked.PSet(
0014     numberOfStreams = cms.untracked.uint32(nStreams),
0015     numberOfThreads = cms.untracked.uint32(nStreams),
0016     numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
0017 )
0018
0019
0020 process.maxEvents = cms.untracked.PSet(
0021     input = cms.untracked.int32(nEvt)
0022 )
0023
0024 process.source = cms.Source("EmptySource",
0025     timeBetweenEvents = cms.untracked.uint64(1000),
0026     firstTime = cms.untracked.uint64(1000000),
0027     numberEventsInRun = cms.untracked.uint32(nEvtRun),
0028     numberEventsInLuminosityBlock = cms.untracked.uint32(nEvtLumi)
0029 )
0030
0031 process.StreamIntProd = cms.EDProducer("edmtest::limited::StreamIntProducer",
0032     concurrencyLimit = cms.untracked.uint32(1),
0033     transitions = cms.int32(nEvt+nStreams*(2*int(nEvt/nEvtRun)+2))
0034     ,cachevalue = cms.int32(1)
0035     ,nLumis = cms.untracked.uint32(int(nEvt/nEvtLumi))
0036 )
0037
0038 process.RunIntProd = cms.EDProducer("edmtest::limited::RunIntProducer",
0039                                     concurrencyLimit = cms.untracked.uint32(1),
0040     transitions = cms.int32(2*int(nEvt/nEvtRun))
0041     ,cachevalue = cms.int32(nEvtRun)
0042 )
0043
0044 process.LumiIntProd = cms.EDProducer("edmtest::limited::LumiIntProducer",
0045                                      concurrencyLimit = cms.untracked.uint32(1),
0046     transitions = cms.int32(2*int(nEvt/nEvtLumi))
0047     ,cachevalue = cms.int32(nEvtLumi)
0048 )
0049
0050 process.RunSumIntProd = cms.EDProducer("edmtest::limited::RunSummaryIntProducer",
0051                                        concurrencyLimit = cms.untracked.uint32(1),
0052     transitions = cms.int32(nStreams*int(nEvt/nEvtRun)+2*int(nEvt/nEvtRun))
0053     ,cachevalue = cms.int32(nEvtRun)
0054 )
0055
0056 process.LumiSumIntProd = cms.EDProducer("edmtest::limited::LumiSummaryIntProducer",
0057                                         concurrencyLimit = cms.untracked.uint32(1),
0058     transitions = cms.int32(nStreams+nEvt+2*int(nEvt/nEvtLumi))
0059     ,cachevalue = cms.int32(nEvtLumi)
0060 )
0061
0062 process.ProcessBlockIntProd = cms.EDProducer("edmtest::limited::ProcessBlockIntProducer",
0063     concurrencyLimit = cms.untracked.uint32(1),
0064     transitions = cms.int32(int(nEvt + 2)),
0065     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockProd" ,"begin"),
0066     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockProd", "end")
0067 )
0068
0069 process.TestBeginProcessBlockProd = cms.EDProducer("edmtest::limited::TestBeginProcessBlockProducer",
0070     concurrencyLimit = cms.untracked.uint32(1),
0071     transitions = cms.int32(int(nEvt + 1)),
0072     consumesBeginProcessBlock = cms.InputTag("")
0073 )
0074
0075 process.TestBeginProcessBlockProdRead = cms.EDProducer("edmtest::limited::TestBeginProcessBlockProducer",
0076     concurrencyLimit = cms.untracked.uint32(1),
0077     transitions = cms.int32(int(nEvt + 1)),
0078     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockProd" ,"begin")
0079 )
0080
0081 process.TestEndProcessBlockProd = cms.EDProducer("edmtest::limited::TestEndProcessBlockProducer",
0082     concurrencyLimit = cms.untracked.uint32(1),
0083     transitions = cms.int32(int(nEvt + 1)),
0084     consumesEndProcessBlock = cms.InputTag("")
0085 )
0086
0087 process.TestEndProcessBlockProdRead = cms.EDProducer("edmtest::limited::TestEndProcessBlockProducer",
0088     concurrencyLimit = cms.untracked.uint32(1),
0089     transitions = cms.int32(int(nEvt + 1)),
0090     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockProd", "end")
0091 )
0092
0093 process.TestBeginRunProd = cms.EDProducer("edmtest::limited::TestBeginRunProducer",
0094                                           concurrencyLimit = cms.untracked.uint32(1),
0095     transitions = cms.int32(int(nEvt/nEvtRun))
0096 )
0097
0098 process.TestEndRunProd = cms.EDProducer("edmtest::limited::TestEndRunProducer",
0099                                         concurrencyLimit = cms.untracked.uint32(1),
0100     transitions = cms.int32(int(nEvt/nEvtRun))
0101 )
0102
0103 process.TestBeginLumiBlockProd = cms.EDProducer("edmtest::limited::TestBeginLumiBlockProducer",
0104                                                 concurrencyLimit = cms.untracked.uint32(1),
0105     transitions = cms.int32(int(nEvt/nEvtLumi))
0106 )
0107
0108 process.TestEndLumiBlockProd = cms.EDProducer("edmtest::limited::TestEndLumiBlockProducer",
0109                                               concurrencyLimit = cms.untracked.uint32(1),
0110     transitions = cms.int32(int(nEvt/nEvtLumi))
0111 )
0112
0113 process.StreamIntAn = cms.EDAnalyzer("edmtest::limited::StreamIntAnalyzer",
0114                                      concurrencyLimit = cms.untracked.uint32(1),
0115     transitions = cms.int32(nEvt+nStreams*(2*int(nEvt/nEvtRun)+2))
0116     ,cachevalue = cms.int32(1)
0117     ,nLumis = cms.untracked.uint32(int(nEvt/nEvtLumi))
0118 )
0119
0120 process.RunIntAn= cms.EDAnalyzer("edmtest::limited::RunIntAnalyzer",
0121                                  concurrencyLimit = cms.untracked.uint32(1),
0122     transitions = cms.int32(nEvt+2*int(nEvt/nEvtRun))
0123     ,cachevalue = cms.int32(nEvtRun)
0124 )
0125
0126 process.LumiIntAn = cms.EDAnalyzer("edmtest::limited::LumiIntAnalyzer",
0127                                    concurrencyLimit = cms.untracked.uint32(1),
0128     transitions = cms.int32(nEvt+2*int(nEvt/nEvtLumi))
0129     ,cachevalue = cms.int32(nEvtLumi)
0130     # needed to avoid deleting TestAccumulator1
0131     ,moduleLabel = cms.InputTag("TestAccumulator1")
0132 )
0133
0134 process.RunSumIntAn = cms.EDAnalyzer("edmtest::limited::RunSummaryIntAnalyzer",
0135                                      concurrencyLimit = cms.untracked.uint32(1),
0136     transitions = cms.int32(nEvt+nStreams*(int(nEvt/nEvtRun)+1)+2*int(nEvt/nEvtRun))
0137     ,cachevalue = cms.int32(nEvtRun)
0138 )
0139
0140 process.LumiSumIntAn = cms.EDAnalyzer("edmtest::limited::LumiSummaryIntAnalyzer",
0141                                       concurrencyLimit = cms.untracked.uint32(1),
0142     transitions = cms.int32(nEvt+nStreams+2*int(nEvt/nEvtLumi))
0143     ,cachevalue = cms.int32(nEvtLumi)
0144 )
0145
0146 process.ProcessBlockIntAn = cms.EDAnalyzer("edmtest::limited::ProcessBlockIntAnalyzer",
0147     concurrencyLimit = cms.untracked.uint32(1),
0148     transitions = cms.int32(int(nEvt + 2)),
0149     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockProd" ,"begin"),
0150     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockProd", "end")
0151 )
0152
0153 process.StreamIntFil = cms.EDFilter("edmtest::limited::StreamIntFilter",
0154                                     concurrencyLimit = cms.untracked.uint32(1),
0155     transitions = cms.int32(nEvt+nStreams*(2*int(nEvt/nEvtRun)+2))
0156     ,cachevalue = cms.int32(1)
0157     ,nLumis = cms.untracked.uint32(int(nEvt/nEvtLumi))
0158 )
0159
0160 process.RunIntFil = cms.EDFilter("edmtest::limited::RunIntFilter",
0161                                  concurrencyLimit = cms.untracked.uint32(1),
0162     transitions = cms.int32(nEvt+2*int(nEvt/nEvtRun))
0163     ,cachevalue = cms.int32(nEvtRun)
0164 )
0165
0166 process.LumiIntFil = cms.EDFilter("edmtest::limited::LumiIntFilter",
0167                                   concurrencyLimit = cms.untracked.uint32(1),
0168     transitions = cms.int32(nEvt+2*int(nEvt/nEvtLumi))
0169     ,cachevalue = cms.int32(nEvtLumi)
0170 )
0171
0172 process.RunSumIntFil = cms.EDFilter("edmtest::limited::RunSummaryIntFilter",
0173                                     concurrencyLimit = cms.untracked.uint32(1),
0174     transitions = cms.int32(nEvt+nStreams*(int(nEvt/nEvtRun)+1)+2*int(nEvt/nEvtRun))
0175     ,cachevalue = cms.int32(nEvtRun)
0176 )
0177
0178 process.LumiSumIntFil = cms.EDFilter("edmtest::limited::LumiSummaryIntFilter",
0179                                      concurrencyLimit = cms.untracked.uint32(1),
0180     transitions = cms.int32(nEvt+nStreams+2*int(nEvt/nEvtLumi))
0181     ,cachevalue = cms.int32(nEvtLumi)
0182 )
0183
0184 process.ProcessBlockIntFil = cms.EDFilter("edmtest::limited::ProcessBlockIntFilter",
0185     concurrencyLimit = cms.untracked.uint32(1),
0186     transitions = cms.int32(int(nEvt + 2)),
0187     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockFil" ,"begin"),
0188     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockFil", "end")
0189 )
0190
0191 process.TestBeginProcessBlockFil = cms.EDFilter("edmtest::limited::TestBeginProcessBlockFilter",
0192     concurrencyLimit = cms.untracked.uint32(1),
0193     transitions = cms.int32(int(nEvt + 1)),
0194     consumesBeginProcessBlock = cms.InputTag("")
0195 )
0196
0197 process.TestBeginProcessBlockFilRead = cms.EDFilter("edmtest::limited::TestBeginProcessBlockFilter",
0198     concurrencyLimit = cms.untracked.uint32(1),
0199     transitions = cms.int32(int(nEvt + 1)),
0200     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockFil" ,"begin")
0201 )
0202
0203 process.TestEndProcessBlockFil = cms.EDFilter("edmtest::limited::TestEndProcessBlockFilter",
0204     concurrencyLimit = cms.untracked.uint32(1),
0205     transitions = cms.int32(int(nEvt + 1)),
0206     consumesEndProcessBlock = cms.InputTag("")
0207 )
0208
0209 process.TestEndProcessBlockFilRead = cms.EDFilter("edmtest::limited::TestEndProcessBlockFilter",
0210     concurrencyLimit = cms.untracked.uint32(1),
0211     transitions = cms.int32(int(nEvt + 1)),
0212     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockFil", "end")
0213 )
0214
0215 process.TestBeginRunFil = cms.EDFilter("edmtest::limited::TestBeginRunFilter",
0216                                        concurrencyLimit = cms.untracked.uint32(1),
0217     transitions = cms.int32(int(nEvt/nEvtRun))
0218 )
0219
0220 process.TestEndRunFil = cms.EDFilter("edmtest::limited::TestEndRunFilter",
0221                                      concurrencyLimit = cms.untracked.uint32(1),
0222     transitions = cms.int32(int(nEvt/nEvtRun))
0223 )
0224
0225 process.TestBeginLumiBlockFil = cms.EDFilter("edmtest::limited::TestBeginLumiBlockFilter",
0226                                              concurrencyLimit = cms.untracked.uint32(1),
0227     transitions = cms.int32(int(nEvt/nEvtLumi))
0228 )
0229
0230 process.TestEndLumiBlockFil = cms.EDFilter("edmtest::limited::TestEndLumiBlockFilter",
0231                                            concurrencyLimit = cms.untracked.uint32(1),
0232     transitions = cms.int32(int(nEvt/nEvtLumi))
0233 )
0234
0235 process.TestAccumulator1 = cms.EDProducer("edmtest::limited::TestAccumulator",
0236   expectedCount = cms.uint32(512),
0237   concurrencyLimit = cms.untracked.uint32(2)
0238 )
0239
0240 process.TestAccumulator2 = cms.EDProducer("edmtest::limited::TestAccumulator",
0241   expectedCount = cms.uint32(35),
0242   concurrencyLimit = cms.untracked.uint32(2)
0243 )
0244
0245 process.testFilterModule = cms.EDFilter("TestFilterModule",
0246   acceptValue = cms.untracked.int32(5),
0247   onlyOne = cms.untracked.bool(False)
0248 )
0249
0250 process.task = cms.Task(process.TestAccumulator1)
0251
0252
0253 process.p = cms.Path(process.StreamIntProd +
0254                      process.RunIntProd +
0255                      process.LumiIntProd +
0256                      process.RunSumIntProd +
0257                      process.LumiSumIntProd +
0258                      process.ProcessBlockIntProd +
0259                      process.TestBeginProcessBlockProd +
0260                      process.TestBeginProcessBlockProdRead +
0261                      process.TestEndProcessBlockProd +
0262                      process.TestEndProcessBlockProdRead +
0263                      process.TestBeginRunProd +
0264                      process.TestEndRunProd +
0265                      process.TestBeginLumiBlockProd +
0266                      process.TestEndLumiBlockProd +
0267                      process.StreamIntAn +
0268                      process.RunIntAn +
0269                      process.LumiIntAn +
0270                      process.RunSumIntAn +
0271                      process.LumiSumIntAn +
0272                      process.ProcessBlockIntAn +
0273                      process.StreamIntFil +
0274                      process.RunIntFil +
0275                      process.LumiIntFil +
0276                      process.RunSumIntFil +
0277                      process.LumiSumIntFil +
0278                      process.ProcessBlockIntFil +
0279                      process.TestBeginProcessBlockFil +
0280                      process.TestBeginProcessBlockFilRead +
0281                      process.TestEndProcessBlockFil +
0282                      process.TestEndProcessBlockFilRead +
0283                      process.TestBeginRunFil +
0284                      process.TestEndRunFil +
0285                      process.TestBeginLumiBlockFil +
0286                      process.TestEndLumiBlockFil +
0287                      process.testFilterModule +
0288                      process.TestAccumulator2,
0289                      process.task)