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