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 )
