Framework/test/test_one_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("TESTONEMODULES")
0010
0011 import FWCore.Framework.test.cmsExceptionsFatalOption_cff
0012 process.options = dict(
0013     numberOfStreams = nStreams,
0014     numberOfThreads = nStreams,
0015     numberOfConcurrentLuminosityBlocks = 1
0016 )
0017
0018 process.maxEvents.input = nEvt
0019
0020 process.source = cms.Source("EmptySource",
0021     timeBetweenEvents = cms.untracked.uint64(10),
0022     firstTime = cms.untracked.uint64(1000000),
0023     numberEventsInRun = cms.untracked.uint32(nEvtRun),
0024     numberEventsInLuminosityBlock = cms.untracked.uint32(nEvtLumi)
0025 )
0026
0027 #process.Tracer = cms.Service("Tracer")
0028
0029 process.SharedResProd = cms.EDProducer("edmtest::one::SharedResourcesProducer",
0030     transitions = cms.int32(nEvt)
0031 )
0032
0033 process.WatchRunProd = cms.EDProducer("edmtest::one::WatchRunsProducer",
0034     transitions = cms.int32(nEvt+2*int(nEvt/nEvtRun))
0035 )
0036
0037 process.WatchLumiBlockProd = cms.EDProducer("edmtest::one::WatchLumiBlocksProducer",
0038     transitions = cms.int32(nEvt+2*int(nEvt/nEvtLumi))
0039 )
0040
0041 process.RunCacheProd = cms.EDProducer("edmtest::one::RunCacheProducer",
0042                                     transitions = cms.int32(nEvt+2*int(nEvt/nEvtRun))
0043                                     )
0044
0045 process.LumiBlockCacheProd = cms.EDProducer("edmtest::one::LumiBlockCacheProducer",
0046                                           transitions = cms.int32(nEvt+2*int(nEvt/nEvtLumi))
0047                                           )
0048
0049 process.ProcessBlockIntProd = cms.EDProducer("edmtest::one::ProcessBlockIntProducer",
0050     transitions = cms.int32(int(nEvt + 2)),
0051     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockProd" ,"begin"),
0052     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockProd", "end")
0053 )
0054
0055 process.TestBeginProcessBlockProd = cms.EDProducer("edmtest::one::TestBeginProcessBlockProducer",
0056     transitions = cms.int32(int(nEvt + 1)),
0057     consumesBeginProcessBlock = cms.InputTag("")
0058 )
0059
0060 process.TestBeginProcessBlockProdRead = cms.EDProducer("edmtest::one::TestBeginProcessBlockProducer",
0061     transitions = cms.int32(int(nEvt + 1)),
0062     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockProd" ,"begin")
0063 )
0064
0065 process.TestEndProcessBlockProd = cms.EDProducer("edmtest::one::TestEndProcessBlockProducer",
0066     transitions = cms.int32(int(nEvt + 1)),
0067     consumesEndProcessBlock = cms.InputTag("")
0068 )
0069
0070 process.TestEndProcessBlockProdRead = cms.EDProducer("edmtest::one::TestEndProcessBlockProducer",
0071     transitions = cms.int32(int(nEvt + 1)),
0072     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockProd", "end")
0073 )
0074
0075 process.BeginRunProd = cms.EDProducer("edmtest::one::TestBeginRunProducer",
0076     transitions = cms.int32(nEvt+int(nEvt/nEvtRun))
0077 )
0078
0079 process.BeginLumiBlockProd = cms.EDProducer("edmtest::one::TestBeginLumiBlockProducer",
0080     transitions = cms.int32(nEvt+int(nEvt/nEvtLumi))
0081 )
0082
0083 process.EndRunProd = cms.EDProducer("edmtest::one::TestEndRunProducer",
0084     transitions = cms.int32(nEvt+int(nEvt/nEvtRun))
0085 )
0086
0087 process.EndLumiBlockProd = cms.EDProducer("edmtest::one::TestEndLumiBlockProducer",
0088     transitions = cms.int32(nEvt+int(nEvt/nEvtLumi))
0089 )
0090
0091
0092 process.SharedResAn = cms.EDAnalyzer("edmtest::one::SharedResourcesAnalyzer",
0093     transitions = cms.int32(nEvt)
0094 )
0095
0096 process.WatchRunAn = cms.EDAnalyzer("edmtest::one::WatchRunsAnalyzer",
0097     transitions = cms.int32(nEvt+2*int(nEvt/nEvtRun))
0098 )
0099
0100 process.WatchLumiBlockAn = cms.EDAnalyzer("edmtest::one::WatchLumiBlocksAnalyzer",
0101     transitions = cms.int32(nEvt+2*int(nEvt/nEvtLumi))
0102     # needed to avoid deleting TestAccumulator1
0103     ,moduleLabel = cms.InputTag("TestAccumulator1")
0104 )
0105
0106 process.RunCacheAn = cms.EDAnalyzer("edmtest::one::RunCacheAnalyzer",
0107                                     transitions = cms.int32(nEvt+2*int(nEvt/nEvtRun))
0108                                     )
0109
0110 process.LumiBlockCacheAn = cms.EDAnalyzer("edmtest::one::LumiBlockCacheAnalyzer",
0111                                           transitions = cms.int32(nEvt+2*int(nEvt/nEvtLumi))
0112                                           )
0113
0114 process.ProcessBlockIntAn = cms.EDAnalyzer("edmtest::one::ProcessBlockIntAnalyzer",
0115     transitions = cms.int32(int(nEvt + 2)),
0116     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockProd" ,"begin"),
0117     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockProd", "end")
0118 )
0119
0120 process.SharedResFil = cms.EDFilter("edmtest::one::SharedResourcesFilter",
0121     transitions = cms.int32(nEvt)
0122 )
0123
0124 process.WatchRunFil = cms.EDFilter("edmtest::one::WatchRunsFilter",
0125     transitions = cms.int32(nEvt+2*int(nEvt/nEvtRun))
0126 )
0127
0128 process.WatchLumiBlockFil = cms.EDFilter("edmtest::one::WatchLumiBlocksFilter",
0129     transitions = cms.int32(nEvt+2*int(nEvt/nEvtLumi))
0130 )
0131 process.RunCacheFil = cms.EDFilter("edmtest::one::RunCacheFilter",
0132                                     transitions = cms.int32(nEvt+2*int(nEvt/nEvtRun))
0133                                     )
0134
0135 process.LumiBlockCacheFil = cms.EDFilter("edmtest::one::LumiBlockCacheFilter",
0136                                           transitions = cms.int32(nEvt+2*int(nEvt/nEvtLumi))
0137                                           )
0138
0139 process.ProcessBlockIntFil = cms.EDFilter("edmtest::one::ProcessBlockIntFilter",
0140     transitions = cms.int32(int(nEvt + 2)),
0141     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockFil" ,"begin"),
0142     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockFil", "end")
0143 )
0144
0145 process.TestBeginProcessBlockFil = cms.EDFilter("edmtest::one::TestBeginProcessBlockFilter",
0146     transitions = cms.int32(int(nEvt + 1)),
0147     consumesBeginProcessBlock = cms.InputTag("")
0148 )
0149
0150 process.TestBeginProcessBlockFilRead = cms.EDFilter("edmtest::one::TestBeginProcessBlockFilter",
0151     transitions = cms.int32(int(nEvt + 1)),
0152     consumesBeginProcessBlock = cms.InputTag("TestBeginProcessBlockFil" ,"begin")
0153 )
0154
0155 process.TestEndProcessBlockFil = cms.EDFilter("edmtest::one::TestEndProcessBlockFilter",
0156     transitions = cms.int32(int(nEvt + 1)),
0157     consumesEndProcessBlock = cms.InputTag("")
0158 )
0159
0160 process.TestEndProcessBlockFilRead = cms.EDFilter("edmtest::one::TestEndProcessBlockFilter",
0161     transitions = cms.int32(int(nEvt + 1)),
0162     consumesEndProcessBlock = cms.InputTag("TestEndProcessBlockFil", "end")
0163 )
0164
0165 process.BeginRunFil = cms.EDFilter("edmtest::one::BeginRunFilter",
0166     transitions = cms.int32(nEvt+int(nEvt/nEvtRun))
0167 )
0168
0169 process.BeginLumiBlockFil = cms.EDFilter("edmtest::one::BeginLumiBlockFilter",
0170     transitions = cms.int32(nEvt+int(nEvt/nEvtLumi))
0171 )
0172
0173 process.EndRunFil = cms.EDFilter("edmtest::one::EndRunFilter",
0174     transitions = cms.int32(nEvt+int(nEvt/nEvtRun))
0175 )
0176
0177 process.EndLumiBlockFil = cms.EDFilter("edmtest::one::EndLumiBlockFilter",
0178     transitions = cms.int32(nEvt+int(nEvt/nEvtLumi))
0179 )
0180
0181 process.TestAccumulator1 = cms.EDProducer("edmtest::one::TestAccumulator",
0182   expectedCount = cms.uint32(512)
0183 )
0184
0185 process.TestAccumulator2 = cms.EDProducer("edmtest::one::TestAccumulator",
0186   expectedCount = cms.uint32(35)
0187 )
0188
0189 process.testFilterModule = cms.EDFilter("TestFilterModule",
0190   acceptValue = cms.untracked.int32(5),
0191   onlyOne = cms.untracked.bool(False)
0192 )
0193
0194 process.task = cms.Task(process.TestAccumulator1)
0195
0196
0197 process.p = cms.Path(process.SharedResProd +
0198                      process.WatchRunProd +
0199                      process.WatchLumiBlockProd +
0200                      process.RunCacheProd +
0201                      process.LumiBlockCacheProd +
0202                      process.ProcessBlockIntProd +
0203                      process.TestBeginProcessBlockProd +
0204                      process.TestBeginProcessBlockProdRead +
0205                      process.TestEndProcessBlockProd +
0206                      process.TestEndProcessBlockProdRead +
0207                      process.BeginRunProd +
0208                      process.BeginLumiBlockProd +
0209                      process.EndRunProd +
0210                      process.EndLumiBlockProd +
0211                      process.SharedResAn +
0212                      process.WatchRunAn +
0213                      process.WatchLumiBlockAn +
0214                      process.RunCacheAn +
0215                      process.LumiBlockCacheAn +
0216                      process.ProcessBlockIntAn +
0217                      process.SharedResFil +
0218                      process.WatchRunFil +
0219                      process.WatchLumiBlockFil +
0220                      process.RunCacheFil +
0221                      process.LumiBlockCacheFil +
0222                      process.ProcessBlockIntFil +
0223                      process.TestBeginProcessBlockFil +
0224                      process.TestBeginProcessBlockFilRead +
0225                      process.TestEndProcessBlockFil +
0226                      process.TestEndProcessBlockFilRead +
0227                      process.BeginRunFil +
0228                      process.BeginLumiBlockFil +
0229                      process.EndRunFil +
0230                      process.EndLumiBlockFil +
0231                      process.testFilterModule +
0232                      process.TestAccumulator2,
0233                      process.task)