Back to home page

Project CMSSW displayed by LXR

 
 

    


File indexing completed on 2021-07-05 04:09:48

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)