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