Back to home page

Project CMSSW displayed by LXR

 
 

    


File indexing completed on 2024-04-06 12:12:41

0001 import FWCore.ParameterSet.Config as cms
0002 
0003 process = cms.Process("READ")
0004 
0005 process.options = cms.untracked.PSet(
0006     numberOfStreams = cms.untracked.uint32(1),
0007     numberOfThreads = cms.untracked.uint32(1),
0008     numberOfConcurrentRuns = cms.untracked.uint32(1),
0009     numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
0010 )
0011 
0012 process.source = cms.Source("PoolSource",
0013     fileNames = cms.untracked.vstring(
0014         'file:testProcessBlockTest.root'
0015     )
0016 )
0017 
0018 process.out = cms.OutputModule("PoolOutputModule",
0019     fileName = cms.untracked.string('testProcessBlockRead.root')
0020 )
0021 
0022 process.testGlobalOutput = cms.OutputModule("TestGlobalOutput",
0023     verbose = cms.untracked.bool(False),
0024     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'READ'),
0025     expectedWriteProcessBlockTransitions = cms.untracked.int32(4)
0026 )
0027 
0028 process.testLimitedOutput = cms.OutputModule("TestLimitedOutput",
0029     verbose = cms.untracked.bool(False),
0030     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'READ'),
0031     expectedWriteProcessBlockTransitions = cms.untracked.int32(4)
0032 )
0033 
0034 process.testOneOutput = cms.OutputModule("TestOneOutput",
0035     verbose = cms.untracked.bool(False),
0036     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE', 'READ'),
0037     expectedWriteProcessBlockTransitions = cms.untracked.int32(4)
0038 )
0039 
0040 process.intProducerBeginProcessBlockR = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(100))
0041 
0042 process.intProducerEndProcessBlockR = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(1000))
0043 
0044 process.readProcessBlocks = cms.EDAnalyzer("edmtest::stream::InputProcessBlockIntAnalyzer",
0045                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0046                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0047                                             expectedByRun = cms.vint32(11, 22),
0048                                             sleepTime = cms.uint32(10000)
0049 )
0050 
0051 process.readProcessBlocksG = cms.EDAnalyzer("edmtest::stream::InputProcessBlockIntAnalyzerG",
0052                                             transitions = cms.int32(15),
0053                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0054                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0055                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0056                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0057                                             expectedByRun = cms.vint32(11, 22),
0058                                             expectedSum = cms.int32(77),
0059                                             sleepTime = cms.uint32(10000)
0060 )
0061 
0062 process.readProcessBlocksNS = cms.EDAnalyzer("edmtest::stream::InputProcessBlockIntAnalyzerNS")
0063 process.readProcessBlocksGNS = cms.EDAnalyzer("edmtest::stream::InputProcessBlockIntAnalyzerGNS")
0064 
0065 process.readProcessBlocksStreamFilter = cms.EDFilter("edmtest::stream::InputProcessBlockIntFilter",
0066                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0067                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0068                                             expectedByRun = cms.vint32(11, 22),
0069                                             sleepTime = cms.uint32(10000)
0070 )
0071 
0072 process.readProcessBlocksGStreamFilter = cms.EDFilter("edmtest::stream::InputProcessBlockIntFilterG",
0073                                             transitions = cms.int32(15),
0074                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0075                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0076                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0077                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0078                                             expectedByRun = cms.vint32(11, 22),
0079                                             expectedSum = cms.int32(77),
0080                                             sleepTime = cms.uint32(10000)
0081 )
0082 
0083 process.readProcessBlocksStreamProducer = cms.EDProducer("edmtest::stream::InputProcessBlockIntProducer",
0084                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0085                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0086                                             expectedByRun = cms.vint32(11, 22),
0087                                             sleepTime = cms.uint32(10000)
0088 )
0089 
0090 process.readProcessBlocksGStreamProducer = cms.EDProducer("edmtest::stream::InputProcessBlockIntProducerG",
0091                                             transitions = cms.int32(15),
0092                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0093                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0094                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0095                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0096                                             expectedByRun = cms.vint32(11, 22),
0097                                             expectedSum = cms.int32(77),
0098                                             sleepTime = cms.uint32(10000)
0099 )
0100 
0101 process.readProcessBlocksOneAnalyzer = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0102                                             transitions = cms.int32(15),
0103                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0104                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0105                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0106                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0107                                             expectedByRun = cms.vint32(11, 22),
0108                                             expectedSum = cms.int32(77),
0109                                             consumesBeginProcessBlockNotFound = cms.InputTag("intProducerBeginProcessBlock"),
0110                                             consumesEndProcessBlockNotFound = cms.InputTag("intProducerEndProcessBlock")
0111 )
0112 
0113 process.readProcessBlocksOneFilter = cms.EDFilter("edmtest::one::InputProcessBlockIntFilter",
0114                                             transitions = cms.int32(15),
0115                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0116                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0117                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0118                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0119                                             expectedByRun = cms.vint32(11, 22),
0120                                             expectedSum = cms.int32(77)
0121 )
0122 
0123 process.readProcessBlocksOneProducer = cms.EDProducer("edmtest::one::InputProcessBlockIntProducer",
0124                                             transitions = cms.int32(15),
0125                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0126                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0127                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0128                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0129                                             expectedByRun = cms.vint32(11, 22),
0130                                             expectedSum = cms.int32(77)
0131 )
0132 
0133 process.readProcessBlocksGlobalAnalyzer = cms.EDAnalyzer("edmtest::global::InputProcessBlockIntAnalyzer",
0134                                             transitions = cms.int32(15),
0135                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0136                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0137                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0138                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0139                                             expectedByRun = cms.vint32(11, 22),
0140                                             expectedSum = cms.int32(77)
0141 )
0142 
0143 process.readProcessBlocksGlobalFilter = cms.EDFilter("edmtest::global::InputProcessBlockIntFilter",
0144                                             transitions = cms.int32(15),
0145                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0146                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0147                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0148                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0149                                             expectedByRun = cms.vint32(11, 22),
0150                                             expectedSum = cms.int32(77)
0151 )
0152 
0153 process.readProcessBlocksGlobalProducer = cms.EDProducer("edmtest::global::InputProcessBlockIntProducer",
0154                                             transitions = cms.int32(15),
0155                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0156                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0157                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0158                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0159                                             expectedByRun = cms.vint32(11, 22),
0160                                             expectedSum = cms.int32(77)
0161 )
0162 
0163 process.readProcessBlocksLimitedAnalyzer = cms.EDAnalyzer("edmtest::limited::InputProcessBlockIntAnalyzer",
0164                                             transitions = cms.int32(15),
0165                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0166                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0167                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0168                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0169                                             expectedByRun = cms.vint32(11, 22),
0170                                             expectedSum = cms.int32(77),
0171                                             concurrencyLimit = cms.untracked.uint32(4)
0172 )
0173 
0174 process.readProcessBlocksLimitedFilter = cms.EDFilter("edmtest::limited::InputProcessBlockIntFilter",
0175                                             transitions = cms.int32(15),
0176                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0177                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0178                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0179                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0180                                             expectedByRun = cms.vint32(11, 22),
0181                                             expectedSum = cms.int32(77),
0182                                             concurrencyLimit = cms.untracked.uint32(4)
0183 )
0184 
0185 process.readProcessBlocksLimitedProducer = cms.EDProducer("edmtest::limited::InputProcessBlockIntProducer",
0186                                             transitions = cms.int32(15),
0187                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0188                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0189                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0190                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0191                                             expectedByRun = cms.vint32(11, 22),
0192                                             expectedSum = cms.int32(77),
0193                                             concurrencyLimit = cms.untracked.uint32(4)
0194 )
0195 
0196 process.readProcessBlocksGlobalAnalyzerNoRegistration = cms.EDAnalyzer("edmtest::global::InputProcessBlockIntAnalyzerNoRegistration",
0197                                             transitions = cms.int32(6),
0198 )
0199 
0200 process.readProcessBlocksDoesNotExist = cms.EDAnalyzer("edmtest::global::InputProcessBlockAnalyzerThreeTags",
0201                                             transitions = cms.int32(9),
0202                                             consumesBeginProcessBlock0 = cms.InputTag("intProducerBeginProcessBlock", ""),
0203                                             consumesEndProcessBlock0 = cms.InputTag("intProducerEndProcessBlock", ""),
0204                                             consumesBeginProcessBlock1 = cms.InputTag("doesNotExist", ""),
0205                                             consumesEndProcessBlock1 = cms.InputTag("doesNotExist", ""),
0206                                             consumesBeginProcessBlock2 = cms.InputTag("intProducerBeginProcessBlockM", ""),
0207                                             consumesEndProcessBlock2 = cms.InputTag("intProducerEndProcessBlockM", ""),
0208                                             expectedByRun0 = cms.vint32(11, 22),
0209                                             expectedByRun1 = cms.vint32(),
0210                                             expectedByRun2 = cms.vint32(44, 44)
0211 )
0212 
0213 process.readProcessBlocksExplicitProcess = cms.EDAnalyzer("edmtest::global::InputProcessBlockAnalyzerThreeTags",
0214                                             transitions = cms.int32(10),
0215                                             consumesBeginProcessBlock0 = cms.InputTag("intProducerBeginProcessBlockB", ""),
0216                                             consumesEndProcessBlock0 = cms.InputTag("intProducerEndProcessBlockB", ""),
0217                                             consumesBeginProcessBlock1 = cms.InputTag("intProducerBeginProcessBlockB", "", "PROD1"),
0218                                             consumesEndProcessBlock1 = cms.InputTag("intProducerEndProcessBlockB", "", "PROD1"),
0219                                             consumesBeginProcessBlock2 = cms.InputTag("intProducerBeginProcessBlockB", "", "MERGE"),
0220                                             consumesEndProcessBlock2 = cms.InputTag("intProducerEndProcessBlockB", "", "MERGE"),
0221                                             expectedByRun0 = cms.vint32(88, 88),
0222                                             expectedByRun1 = cms.vint32(55, 77),
0223                                             expectedByRun2 = cms.vint32(88, 88)
0224 )
0225 
0226 process.readProcessBlocksExplicitProcess2 = cms.EDAnalyzer("edmtest::global::InputProcessBlockAnalyzerThreeTags",
0227                                             transitions = cms.int32(11),
0228                                             consumesBeginProcessBlock0 = cms.InputTag("intProducerBeginProcessBlock", ""),
0229                                             consumesEndProcessBlock0 = cms.InputTag("intProducerEndProcessBlock", ""),
0230                                             consumesBeginProcessBlock1 = cms.InputTag("intProducerBeginProcessBlock", "", "PROD1"),
0231                                             consumesEndProcessBlock1 = cms.InputTag("intProducerEndProcessBlock", "", "PROD1"),
0232                                             consumesBeginProcessBlock2 = cms.InputTag("intProducerBeginProcessBlockM", "", "MERGE"),
0233                                             consumesEndProcessBlock2 = cms.InputTag("intProducerEndProcessBlockM", "", "MERGE"),
0234                                             expectedByRun0 = cms.vint32(11, 22),
0235                                             expectedByRun1 = cms.vint32(11, 22),
0236                                             expectedByRun2 = cms.vint32(44, 44)
0237 )
0238 
0239 process.readProcessBlocksReuseCache = cms.EDAnalyzer("edmtest::global::InputProcessBlockAnalyzerReuseCache",
0240                                             transitions = cms.int32(8),
0241                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0242                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0243                                             expectedByRun = cms.vint32(11, 11)
0244 )
0245 
0246 process.p = cms.Path(process.intProducerBeginProcessBlockR *
0247                      process.intProducerEndProcessBlockR *
0248                      process.readProcessBlocks *
0249                      process.readProcessBlocksG *
0250                      process.readProcessBlocksNS *
0251                      process.readProcessBlocksGNS *
0252                      process.readProcessBlocksStreamFilter *
0253                      process.readProcessBlocksGStreamFilter *
0254                      process.readProcessBlocksStreamProducer *
0255                      process.readProcessBlocksGStreamProducer *
0256                      process.readProcessBlocksOneAnalyzer *
0257                      process.readProcessBlocksOneFilter *
0258                      process.readProcessBlocksOneProducer *
0259                      process.readProcessBlocksGlobalAnalyzer *
0260                      process.readProcessBlocksGlobalFilter *
0261                      process.readProcessBlocksGlobalProducer *
0262                      process.readProcessBlocksLimitedAnalyzer *
0263                      process.readProcessBlocksLimitedFilter *
0264                      process.readProcessBlocksLimitedProducer *
0265                      process.readProcessBlocksDoesNotExist *
0266                      process.readProcessBlocksGlobalAnalyzerNoRegistration *
0267                      process.readProcessBlocksExplicitProcess *
0268                      process.readProcessBlocksExplicitProcess2 *
0269                      process.readProcessBlocksReuseCache
0270 )
0271 
0272 process.e = cms.EndPath(
0273     process.out *
0274     process.testGlobalOutput *
0275     process.testLimitedOutput *
0276     process.testOneOutput
0277 )