Integration/test/testProcessBlockMerge_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002
0003 process = cms.Process("MERGE")
0004
0005 process.options = cms.untracked.PSet(
0006     numberOfStreams = cms.untracked.uint32(1),
0007     numberOfConcurrentRuns = cms.untracked.uint32(1),
0008     numberOfConcurrentLuminosityBlocks = cms.untracked.uint32(1)
0009 )
0010
0011 process.source = cms.Source("PoolSource",
0012     fileNames = cms.untracked.vstring(
0013         'file:testProcessBlock1.root',
0014         'file:testProcessBlock2.root'
0015     )
0016 )
0017
0018 # transitions 14 = 6 events + 2 InputProcessBlock transitions + 3 x 2 cache filling calls
0019 process.readProcessBlocksOneAnalyzer1 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0020                                             transitions = cms.int32(14),
0021                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0022                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0023                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0024                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0025                                             expectedByRun = cms.vint32(11, 22, 3300, 4400, 7700),
0026                                             expectedSum = cms.int32(33)
0027 )
0028
0029 process.out = cms.OutputModule("PoolOutputModule",
0030     fileName = cms.untracked.string('testProcessBlockMerge.root'),
0031     outputCommands = cms.untracked.vstring(
0032         "keep *",
0033         "drop *_testEDAliasAlias_*_*"
0034     )
0035 )
0036
0037 process.testGlobalOutput = cms.OutputModule("TestGlobalOutput",
0038     verbose = cms.untracked.bool(False),
0039     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE'),
0040     expectedWriteProcessBlockTransitions = cms.untracked.int32(3)
0041 )
0042
0043 process.testLimitedOutput = cms.OutputModule("TestLimitedOutput",
0044     verbose = cms.untracked.bool(False),
0045     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE'),
0046     expectedWriteProcessBlockTransitions = cms.untracked.int32(3)
0047 )
0048
0049 process.testOneOutput = cms.OutputModule("TestOneOutput",
0050     verbose = cms.untracked.bool(False),
0051     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE'),
0052     expectedTopProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE'),
0053     expectedTopAddedProcesses = cms.untracked.vstring('MERGE'),
0054     expectedWriteProcessBlockTransitions = cms.untracked.int32(3),
0055     expectedNAddedProcesses = cms.untracked.uint32(1),
0056     expectedTopCacheIndices0 = cms.untracked.vuint32(0),
0057     expectedTopCacheIndices1 = cms.untracked.vuint32(0, 1)
0058 )
0059
0060 process.intProducerBeginProcessBlockM = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(4))
0061
0062 process.intProducerEndProcessBlockM = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(40))
0063
0064 process.intProducerBeginProcessBlockB = cms.EDProducer("IntProducerBeginProcessBlock", ivalue = cms.int32(8))
0065
0066 process.intProducerEndProcessBlockB = cms.EDProducer("IntProducerEndProcessBlock", ivalue = cms.int32(80))
0067
0068 process.a2000 = cms.EDAnalyzer("TestFindProduct",
0069   inputTags = cms.untracked.VInputTag(),
0070   inputTagsInputProcessBlock = cms.untracked.VInputTag( cms.InputTag("testEDAliasAlias")),
0071   expectedSum = cms.untracked.int32(222),
0072   expectedCache = cms.untracked.int32(111)
0073 )
0074
0075 process.p = cms.Path(process.intProducerBeginProcessBlockM *
0076                      process.intProducerEndProcessBlockM *
0077                      process.intProducerBeginProcessBlockB *
0078                      process.intProducerEndProcessBlockB *
0079                      process.readProcessBlocksOneAnalyzer1 *
0080                      process.a2000
0081 )
0082
0083 process.e = cms.EndPath(process.out *
0084                         process.testGlobalOutput *
0085                         process.testLimitedOutput *
0086                         process.testOneOutput
0087 )