Integration/test/testLooperEventNavigation2_cfg.py

0001 import FWCore.ParameterSet.Config as cms
0002
0003 process = cms.Process("TEST")
0004
0005 process.source = cms.Source("PoolSource",
0006     fileNames = cms.untracked.vstring(
0007         'file:testProcessBlockMerge.root',
0008         'file:testProcessBlockMerge2.root'
0009     )
0010 )
0011
0012 # 57 transitions = 12 events + 15 access input ProcessBlock transitions + 30 fill calls
0013 # sum 16442 = 2 x (3300 + 4400 + 444) + 3 x (11 + 22 + 44) = 16288 + 231 =
0014 process.readProcessBlocksOneAnalyzer = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0015                                             transitions = cms.int32(57),
0016                                             consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0017                                             consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0018                                             consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0019                                             consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0020                                             expectedByRun = cms.vint32(11, 22, 3300, 4400),
0021                                             expectedSum = cms.int32(16519)
0022 )
0023
0024 process.testOneOutput = cms.OutputModule("TestOneOutput",
0025     verbose = cms.untracked.bool(False),
0026     expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGE'),
0027     expectedProcessNamesAtWrite = cms.untracked.vstring('PROD1', 'PROD1', 'MERGE', 'PROD1', 'PROD1', 'MERGE', 'PROD1', 'PROD1', 'MERGE', 'PROD1', 'PROD1', 'MERGE', 'PROD1', 'PROD1', 'MERGE', 'TEST'),
0028     expectedWriteProcessBlockTransitions = cms.untracked.int32(16),
0029     testTTreesInFileBlock = cms.untracked.bool(True),
0030     expectedCacheIndexSize = cms.untracked.vuint32(2, 2, 2, 4, 4, 4, 6, 6, 6, 8, 8, 8, 10, 10, 10)
0031 )
0032
0033 process.looper = cms.Looper("NavigateEventsLooper")
0034
0035 process.out = cms.OutputModule("PoolOutputModule",
0036     fileName = cms.untracked.string('file:testLooperEventNavigation2.root'),
0037     fastCloning = cms.untracked.bool(False)
0038 )
0039
0040 process.path1 = cms.Path(process.readProcessBlocksOneAnalyzer)
0041 process.endpath1 = cms.EndPath(process.out * process.testOneOutput)