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