Back to home page

Project CMSSW displayed by LXR

 
 

    


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

0001 import FWCore.ParameterSet.Config as cms
0002 
0003 process = cms.Process("PROD1")
0004 
0005 process.Tracer = cms.Service('Tracer',
0006     dumpPathsAndConsumes = cms.untracked.bool(True)
0007 )
0008 
0009 process.MessageLogger = cms.Service("MessageLogger",
0010     cout = cms.untracked.PSet(
0011         Tracer = cms.untracked.PSet(
0012             limit = cms.untracked.int32(100000000)
0013         ),
0014         default = cms.untracked.PSet(
0015             limit = cms.untracked.int32(0)
0016         ),
0017         enable = cms.untracked.bool(True)
0018     )
0019 )
0020 
0021 process.options = cms.untracked.PSet(
0022     numberOfStreams = cms.untracked.uint32(1),
0023     numberOfConcurrentRuns = cms.untracked.uint32(1),
0024     numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
0025 )
0026 
0027 process.source = cms.Source("IntSource")
0028 process.maxEvents = cms.untracked.PSet(
0029     input = cms.untracked.int32(3)
0030 )
0031 
0032 process.out = cms.OutputModule("PoolOutputModule",
0033     fileName = cms.untracked.string('testConsumesInfo.root'),
0034     outputCommands = cms.untracked.vstring(
0035         'keep *',
0036         'drop *_intProducerA_*_*',
0037         'drop *_intProducerB_*_*',
0038         'drop *_intProducerC_*_*',
0039         'drop *_intProducerD_*_*',
0040         'drop *_intProducerE_*_*',
0041         'drop *_intProducerF_*_*',
0042         'drop *_intProducerG_*_*',
0043         'drop *_intProducerH_*_*',
0044         'drop *_intProducerI_*_*'
0045     )
0046 )
0047 
0048 process.a1 = cms.EDAnalyzer("TestFindProduct",
0049   inputTags = cms.untracked.VInputTag( cms.InputTag("source") ),
0050   expectedSum = cms.untracked.int32(12),
0051   inputTagsNotFound = cms.untracked.VInputTag(
0052     cms.InputTag("source", processName=cms.InputTag.skipCurrentProcess()),
0053     cms.InputTag("intProducer", processName=cms.InputTag.skipCurrentProcess()),
0054     cms.InputTag("intProducerU", processName=cms.InputTag.skipCurrentProcess())
0055   )
0056 )
0057 
0058 process.a2 = cms.EDAnalyzer("TestFindProduct",
0059   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerA") ),
0060   expectedSum = cms.untracked.int32(300)
0061 )
0062 
0063 process.a3 = cms.EDAnalyzer("TestFindProduct",
0064   inputTags = cms.untracked.VInputTag( cms.InputTag("aliasForInt") ),
0065   expectedSum = cms.untracked.int32(300)
0066 )
0067 
0068 process.a4 = cms.EDAnalyzer("TestFindProduct",
0069   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerA", processName=cms.InputTag.currentProcess()) ),
0070   expectedSum = cms.untracked.int32(300)
0071 )
0072 
0073 process.intProducer = cms.EDProducer("IntProducer", ivalue = cms.int32(1))
0074 
0075 process.intProducerU = cms.EDProducer("IntProducer", ivalue = cms.int32(10))
0076 
0077 process.intProducerA = cms.EDProducer("IntProducer", ivalue = cms.int32(100))
0078 
0079 process.aliasForInt = cms.EDAlias(
0080   intProducerA  = cms.VPSet(
0081     cms.PSet(type = cms.string('edmtestIntProduct')
0082     )
0083   )
0084 )
0085 
0086 process.intVectorProducer = cms.EDProducer("IntVectorProducer",
0087   count = cms.int32(9),
0088   ivalue = cms.int32(11)
0089 )
0090 
0091 process.test = cms.EDAnalyzer("TestContextAnalyzer",
0092                               pathname = cms.untracked.string("p"),
0093                               modlable = cms.untracked.string("test"))
0094 
0095 process.testView1 = cms.EDAnalyzer("TestFindProduct",
0096   inputTags = cms.untracked.VInputTag(),
0097   inputTagsView = cms.untracked.VInputTag( cms.InputTag("intVectorProducer", "", "PROD1") )
0098 )
0099 
0100 process.testStreamingProducer = cms.EDProducer("IntProducer",
0101   ivalue = cms.int32(111)
0102 )
0103 
0104 process.testManyConsumingProducer = cms.EDProducer("ConsumingIntProducer",
0105                                                ivalue = cms.int32(111)
0106                                                )
0107 
0108 
0109 process.testStreamingAnalyzer = cms.EDAnalyzer("ConsumingStreamAnalyzer",
0110   valueMustMatch = cms.untracked.int32(111),
0111   moduleLabel = cms.untracked.string("testStreamingProducer")
0112 )
0113 
0114 process.intProducerB = cms.EDProducer("IntProducer", ivalue = cms.int32(1000))
0115 process.intProducerC = cms.EDProducer("IntProducer", ivalue = cms.int32(1001))
0116 process.intProducerD = cms.EDProducer("IntProducer", ivalue = cms.int32(1002))
0117 process.intProducerE = cms.EDProducer("IntProducer", ivalue = cms.int32(1003))
0118 process.intProducerF = cms.EDProducer("IntProducer", ivalue = cms.int32(1004))
0119 process.intProducerG = cms.EDProducer("IntProducer", ivalue = cms.int32(1005))
0120 process.intProducerH = cms.EDProducer("IntProducer", ivalue = cms.int32(1006))
0121 process.intProducerI = cms.EDProducer("IntProducer", ivalue = cms.int32(1007))
0122 
0123 process.intProducerBeginProcessBlock = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(10000))
0124 
0125 process.intProducerEndProcessBlock = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(100000))
0126 
0127 process.processBlockTest1 = cms.EDAnalyzer("TestFindProduct",
0128   inputTags = cms.untracked.VInputTag(),
0129   expectedSum = cms.untracked.int32(220000),
0130   inputTagsBeginProcessBlock = cms.untracked.VInputTag(
0131     cms.InputTag("intProducerBeginProcessBlock"),
0132     cms.InputTag("intProducerBeginProcessBlock", "", "PROD1")
0133   ),
0134   inputTagsEndProcessBlock = cms.untracked.VInputTag(
0135     cms.InputTag("intProducerEndProcessBlock"),
0136     cms.InputTag("intProducerEndProcessBlock", "", "PROD1"),
0137   )
0138 )
0139 
0140 process.p = cms.Path(process.intProducer * process.a1 * process.a2 * process.a3 *
0141                      process.a4 *
0142                      process.test * process.testView1 *
0143                      process.testStreamingProducer * process.testStreamingAnalyzer *
0144                      process.intProducerBeginProcessBlock *
0145                      process.intProducerEndProcessBlock *
0146                      process.processBlockTest1
0147 )
0148 
0149 process.p2 = cms.Path(process.intProducer * process.a1 * process.a2 * process.a3)
0150 
0151 process.p3 = cms.Path(
0152     process.intProducerB *
0153     process.intProducerC *
0154     process.intProducerD *
0155     process.intProducerE
0156 )
0157 
0158 
0159 process.p11 = cms.Path()
0160 
0161 process.t = cms.Task(
0162     process.intProducerU,
0163     process.intProducerA,
0164     process.intVectorProducer,
0165     process.intProducerF,
0166     process.intProducerG,
0167     process.intProducerH,
0168     process.intProducerI
0169 )
0170 
0171 process.e = cms.EndPath(process.testManyConsumingProducer+process.out, process.t)
0172 
0173 process.p1ep2 = cms.EndPath()
0174 
0175 process2 = cms.Process("PROD2")
0176 
0177 process.addSubProcess(cms.SubProcess(process2,
0178     outputCommands = cms.untracked.vstring(
0179         "keep *",
0180         "drop *_intProducerA_*_*"
0181     )
0182 ))
0183 
0184 process2.intProducerB = cms.EDProducer("IntProducer", ivalue = cms.int32(2000))
0185 process2.intProducerD = cms.EDProducer("IntProducer", ivalue = cms.int32(2002))
0186 process2.intProducerF = cms.EDProducer("IntProducer", ivalue = cms.int32(2004))
0187 process2.intProducerH = cms.EDProducer("IntProducer", ivalue = cms.int32(2006))
0188 
0189 process2.task1 = cms.Task(
0190     process2.intProducerF,
0191     process2.intProducerH
0192 )
0193 
0194 process2.path1 = cms.Path(
0195     process2.intProducerB *
0196     process2.intProducerD,
0197     process2.task1
0198 )
0199 
0200 copyProcess = cms.Process("COPY")
0201 process2.addSubProcess(cms.SubProcess(copyProcess,
0202     outputCommands = cms.untracked.vstring(
0203         "keep *",
0204         "drop *_intProducerA_*_*"
0205     )
0206 ))
0207 
0208 copyProcess.intVectorProducer = cms.EDProducer("IntVectorProducer",
0209   count = cms.int32(9),
0210   ivalue = cms.int32(12)
0211 )
0212 
0213 copyProcess.testView1 = cms.EDAnalyzer("TestFindProduct",
0214   inputTags = cms.untracked.VInputTag(),
0215   inputTagsView = cms.untracked.VInputTag( cms.InputTag("intVectorProducer", "", "PROD1") ),
0216   expectedSum = cms.untracked.int32(33)
0217 )
0218 
0219 copyProcess.testView2 = cms.EDAnalyzer("TestFindProduct",
0220   inputTags = cms.untracked.VInputTag(),
0221   inputTagsView = cms.untracked.VInputTag( cms.InputTag("intVectorProducer", "", "COPY") ),
0222   expectedSum = cms.untracked.int32(36)
0223 )
0224 
0225 copyProcess.testView3 = cms.EDAnalyzer("TestFindProduct",
0226   inputTags = cms.untracked.VInputTag(),
0227   inputTagsView = cms.untracked.VInputTag( cms.InputTag("intVectorProducer", "", processName=cms.InputTag.currentProcess()) ),
0228   expectedSum = cms.untracked.int32(36)
0229 )
0230 
0231 copyProcess.test = cms.EDAnalyzer("TestContextAnalyzer",
0232                                   pathname = cms.untracked.string("p3"),
0233                                   modlable = cms.untracked.string("test")
0234 )
0235 
0236 copyProcess.thingWithMergeProducer = cms.EDProducer("ThingWithMergeProducer")
0237 copyProcess.testMergeResults = cms.EDAnalyzer("TestMergeResults")
0238 
0239 copyProcess.testStreamingProducer = cms.EDProducer("IntProducer",
0240   ivalue = cms.int32(11)
0241 )
0242 copyProcess.testManyConsumingProducer = cms.EDProducer("ConsumingIntProducer",
0243                                                    ivalue = cms.int32(11)
0244                                                    )
0245 
0246 
0247 copyProcess.testStreamingAnalyzer = cms.EDAnalyzer("ConsumingStreamAnalyzer",
0248   valueMustMatch = cms.untracked.int32(11),
0249   moduleLabel = cms.untracked.string("testStreamingProducer")
0250 )
0251 
0252 copyProcess.p3 = cms.Path(copyProcess.intVectorProducer * copyProcess.test * copyProcess.thingWithMergeProducer *
0253                           copyProcess.testMergeResults * copyProcess.testView1 * copyProcess.testView2 * copyProcess.testView3 *
0254                           copyProcess.testStreamingProducer * copyProcess.testStreamingAnalyzer)
0255 
0256 copyProcess.ep1 = cms.EndPath(copyProcess.intVectorProducer+copyProcess.testManyConsumingProducer)
0257 copyProcess.ep2 = cms.EndPath()
0258 
0259 copyProcess.intProducerB = cms.EDProducer("IntProducer", ivalue = cms.int32(3000))
0260 copyProcess.intProducerC = cms.EDProducer("IntProducer", ivalue = cms.int32(3001))
0261 copyProcess.intProducerF = cms.EDProducer("IntProducer", ivalue = cms.int32(3004))
0262 copyProcess.intProducerG = cms.EDProducer("IntProducer", ivalue = cms.int32(3005))
0263 
0264 copyProcess.task1 = cms.Task(
0265     copyProcess.intProducerF,
0266     copyProcess.intProducerG
0267 )
0268 
0269 copyProcess.path1 = cms.Path(
0270     copyProcess.intProducerB *
0271     copyProcess.intProducerC,
0272     copyProcess.task1
0273 )
0274 
0275 copyProcess.a1 = cms.EDAnalyzer("TestFindProduct",
0276   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerB") ),
0277   expectedSum = cms.untracked.int32(9000)
0278 )
0279 
0280 copyProcess.a2 = cms.EDAnalyzer("TestFindProduct",
0281   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerB", processName=cms.InputTag.skipCurrentProcess()) ),
0282   expectedSum = cms.untracked.int32(6000)
0283 )
0284 
0285 copyProcess.a3 = cms.EDAnalyzer("TestFindProduct",
0286   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerC") ),
0287   expectedSum = cms.untracked.int32(9003)
0288 )
0289 
0290 copyProcess.a4 = cms.EDAnalyzer("TestFindProduct",
0291   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerC", processName=cms.InputTag.skipCurrentProcess()) ),
0292   expectedSum = cms.untracked.int32(3003)
0293 )
0294 
0295 copyProcess.a5 = cms.EDAnalyzer("TestFindProduct",
0296   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerD") ),
0297   expectedSum = cms.untracked.int32(6006)
0298 )
0299 
0300 copyProcess.a6 = cms.EDAnalyzer("TestFindProduct",
0301   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerD", processName=cms.InputTag.skipCurrentProcess()) ),
0302   expectedSum = cms.untracked.int32(6006)
0303 )
0304 
0305 copyProcess.a7 = cms.EDAnalyzer("TestFindProduct",
0306   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerE") ),
0307   expectedSum = cms.untracked.int32(3009)
0308 )
0309 
0310 copyProcess.a8 = cms.EDAnalyzer("TestFindProduct",
0311   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerE", processName=cms.InputTag.skipCurrentProcess()) ),
0312   expectedSum = cms.untracked.int32(3009)
0313 )
0314 
0315 copyProcess.a9 = cms.EDAnalyzer("TestFindProduct",
0316   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerF") ),
0317   expectedSum = cms.untracked.int32(9012)
0318 )
0319 
0320 copyProcess.a10 = cms.EDAnalyzer("TestFindProduct",
0321   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerF", processName=cms.InputTag.skipCurrentProcess()) ),
0322   expectedSum = cms.untracked.int32(6012)
0323 )
0324 
0325 copyProcess.a11 = cms.EDAnalyzer("TestFindProduct",
0326   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerG") ),
0327   expectedSum = cms.untracked.int32(9015)
0328 )
0329 
0330 copyProcess.a12 = cms.EDAnalyzer("TestFindProduct",
0331   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerG", processName=cms.InputTag.skipCurrentProcess()) ),
0332   expectedSum = cms.untracked.int32(3015)
0333 )
0334 
0335 copyProcess.a13 = cms.EDAnalyzer("TestFindProduct",
0336   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerH") ),
0337   expectedSum = cms.untracked.int32(6018)
0338 )
0339 
0340 copyProcess.a14 = cms.EDAnalyzer("TestFindProduct",
0341   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerH", processName=cms.InputTag.skipCurrentProcess()) ),
0342   expectedSum = cms.untracked.int32(6018)
0343 )
0344 
0345 copyProcess.a15 = cms.EDAnalyzer("TestFindProduct",
0346   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerI") ),
0347   expectedSum = cms.untracked.int32(3021)
0348 )
0349 
0350 copyProcess.a16 = cms.EDAnalyzer("TestFindProduct",
0351   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerI", processName=cms.InputTag.skipCurrentProcess()) ),
0352   expectedSum = cms.untracked.int32(3021)
0353 )
0354 
0355 copyProcess.a17 = cms.EDAnalyzer("TestFindProduct",
0356   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerB", processName=cms.InputTag.currentProcess()) ),
0357   expectedSum = cms.untracked.int32(9000)
0358 )
0359 
0360 copyProcess.a18 = cms.EDAnalyzer("TestFindProduct",
0361   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerC", processName=cms.InputTag.currentProcess()) ),
0362   expectedSum = cms.untracked.int32(9003)
0363 )
0364 
0365 copyProcess.a19 = cms.EDAnalyzer("TestFindProduct",
0366   inputTags = cms.untracked.VInputTag(),
0367   inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("intProducerD", processName=cms.InputTag.currentProcess()) )
0368 )
0369 
0370 copyProcess.a20 = cms.EDAnalyzer("TestFindProduct",
0371   inputTags = cms.untracked.VInputTag(),
0372   inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("intProducerE", processName=cms.InputTag.currentProcess()) )
0373 )
0374 
0375 copyProcess.a21 = cms.EDAnalyzer("TestFindProduct",
0376   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerF", processName=cms.InputTag.currentProcess()) ),
0377   expectedSum = cms.untracked.int32(9012)
0378 )
0379 
0380 copyProcess.a22 = cms.EDAnalyzer("TestFindProduct",
0381   inputTags = cms.untracked.VInputTag( cms.InputTag("intProducerG", processName=cms.InputTag.currentProcess()) ),
0382   expectedSum = cms.untracked.int32(9015)
0383 )
0384 
0385 copyProcess.a23 = cms.EDAnalyzer("TestFindProduct",
0386   inputTags = cms.untracked.VInputTag(),
0387   inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("intProducerH", processName=cms.InputTag.currentProcess()) )
0388 )
0389 
0390 copyProcess.a24 = cms.EDAnalyzer("TestFindProduct",
0391   inputTags = cms.untracked.VInputTag(),
0392   inputTagsNotFound = cms.untracked.VInputTag( cms.InputTag("intProducerI", processName=cms.InputTag.currentProcess()) )
0393 )
0394 
0395 copyProcess.a25 = cms.EDAnalyzer("TestFindProduct",
0396   inputTags = cms.untracked.VInputTag(
0397     cms.InputTag("intProducerB", processName=cms.InputTag.currentProcess()),
0398     cms.InputTag("intProducerC"),
0399     cms.InputTag("intProducerD"),
0400     cms.InputTag("intProducerF", processName=cms.InputTag.currentProcess()),
0401     cms.InputTag("intProducerG", processName=cms.InputTag.currentProcess()),
0402     cms.InputTag("intProducerI")
0403   ),
0404   inputTagsNotFound = cms.untracked.VInputTag(
0405     cms.InputTag("intProducerE", processName=cms.InputTag.currentProcess()),
0406     cms.InputTag("intProducerH", processName=cms.InputTag.currentProcess()),
0407     cms.InputTag("intProducerQ", "INSTANCE", "DOESNOTEXIST")
0408   )
0409 )
0410 
0411 copyProcess.path2 = cms.Path(
0412   copyProcess.a1 *
0413   copyProcess.a2 *
0414   copyProcess.a3 *
0415   copyProcess.a4 *
0416   copyProcess.a5 *
0417   copyProcess.a6 *
0418   copyProcess.a7 *
0419   copyProcess.a8 *
0420   copyProcess.a9 *
0421   copyProcess.a10 *
0422   copyProcess.a11 *
0423   copyProcess.a12 *
0424   copyProcess.a13 *
0425   copyProcess.a14 *
0426   copyProcess.a15 *
0427   copyProcess.a16 *
0428   copyProcess.a17 *
0429   copyProcess.a18 *
0430   copyProcess.a19 *
0431   copyProcess.a20 *
0432   copyProcess.a21 *
0433   copyProcess.a22 *
0434   copyProcess.a23 *
0435   copyProcess.a24 *
0436   copyProcess.a25
0437 )
0438 
0439 copyProcess.intProducerBeginProcessBlock = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(10001))
0440 
0441 copyProcess.intProducerEndProcessBlock = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(100010))
0442 
0443 copyProcess.processBlockTest1 = cms.EDAnalyzer("TestFindProduct",
0444   inputTags = cms.untracked.VInputTag(),
0445   expectedSum = cms.untracked.int32(450034),
0446   # This does not work in a SubProcess because the accessInputProcessBlock
0447   # transition does not occur until after event processing is over
0448   # expectedCache = cms.untracked.int32(110000),
0449   inputTagsBeginProcessBlock = cms.untracked.VInputTag(
0450     cms.InputTag("intProducerBeginProcessBlock"),
0451     cms.InputTag("intProducerBeginProcessBlock", "", "COPY")
0452   ),
0453   inputTagsEndProcessBlock = cms.untracked.VInputTag(
0454     cms.InputTag("intProducerBeginProcessBlock"),
0455     cms.InputTag("intProducerBeginProcessBlock", "", "COPY"),
0456     cms.InputTag("intProducerEndProcessBlock"),
0457     cms.InputTag("intProducerEndProcessBlock", "", "COPY"),
0458     cms.InputTag("intProducerEndProcessBlock", "", cms.InputTag.currentProcess())
0459   ),
0460   inputTagsInputProcessBlock = cms.untracked.VInputTag(
0461     cms.InputTag("intProducerBeginProcessBlock", "", "PROD1"),
0462     cms.InputTag("intProducerEndProcessBlock", "", "PROD1")
0463   )
0464 )
0465 
0466 copyProcess.testOneOutput = cms.OutputModule("TestOneOutput",
0467     verbose = cms.untracked.bool(False),
0468     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'COPY'),
0469     expectedWriteProcessBlockTransitions = cms.untracked.int32(2),
0470     expectedProductsFromInputKept = cms.untracked.bool(False)
0471 )
0472 
0473 copyProcess.path3 = cms.Path(
0474     copyProcess.intProducerBeginProcessBlock *
0475     copyProcess.intProducerEndProcessBlock *
0476     copyProcess.processBlockTest1
0477 )
0478 
0479 copyProcess.endPath = cms.EndPath(copyProcess.testOneOutput)