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:testProcessBlockMergeOfMergedFiles.root',
0015 'file:testProcessBlockMergeOfMergedFiles2.root'
0016 ),
0017 inputCommands=cms.untracked.vstring(
0018 'keep *',
0019 'drop *_intProducerBeginProcessBlockB_*_*',
0020 'drop *_intProducerEndProcessBlockB_*_*',
0021 'drop *_intProducerBeginProcessBlockM_*_*',
0022 'drop *_intProducerEndProcessBlockM_*_*'
0023 )
0024 )
0025
0026 process.readProcessBlocksOneAnalyzer1 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0027 transitions = cms.int32(37),
0028 consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlock", ""),
0029 consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlock", ""),
0030 consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0031 consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0032 expectedByRun = cms.vint32(11, 22, 3300, 4400, 7707),
0033 expectedSum = cms.int32(15440),
0034 consumesProcessBlockNotFound1 = cms.InputTag("intProducerBeginProcessBlockB"),
0035 consumesProcessBlockNotFound2 = cms.InputTag("intProducerEndProcessBlockB"),
0036 consumesProcessBlockNotFound3 = cms.InputTag("intProducerBeginProcessBlockM"),
0037 consumesProcessBlockNotFound4 = cms.InputTag("intProducerEndProcessBlockM")
0038 )
0039
0040 process.readProcessBlocksOneAnalyzer2 = cms.EDAnalyzer("edmtest::one::InputProcessBlockIntAnalyzer",
0041 transitions = cms.int32(28),
0042 consumesBeginProcessBlock = cms.InputTag("intProducerBeginProcessBlockMM", ""),
0043 consumesEndProcessBlock = cms.InputTag("intProducerEndProcessBlockMM", ""),
0044 consumesBeginProcessBlockM = cms.InputTag("intProducerBeginProcessBlockM", ""),
0045 consumesEndProcessBlockM = cms.InputTag("intProducerEndProcessBlockM", ""),
0046 expectedByRun = cms.vint32(644, 644, 644, 644, 844),
0047 expectedSum = cms.int32(0),
0048 consumesProcessBlockNotFound1 = cms.InputTag("intProducerBeginProcessBlockB"),
0049 consumesProcessBlockNotFound2 = cms.InputTag("intProducerEndProcessBlockB"),
0050 consumesProcessBlockNotFound3 = cms.InputTag("intProducerBeginProcessBlockM"),
0051 consumesProcessBlockNotFound4 = cms.InputTag("intProducerEndProcessBlockM")
0052 )
0053
0054 process.out = cms.OutputModule("PoolOutputModule",
0055 fileName = cms.untracked.string('testProcessBlockDropOnInput.root'),
0056 outputCommands = cms.untracked.vstring(
0057 "keep *",
0058 "drop *_*_*_READ"
0059 )
0060 )
0061
0062 process.testOneOutput = cms.OutputModule("TestOneOutput",
0063 verbose = cms.untracked.bool(False),
0064 expectedProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGEOFMERGED'),
0065 expectedTopProcessesWithProcessBlockProducts = cms.untracked.vstring('PROD1', 'MERGEOFMERGED'),
0066 expectedTopAddedProcesses = cms.untracked.vstring(),
0067 expectedTopCacheIndices0 = cms.untracked.vuint32(0, 4, 1, 4, 2, 4, 3, 4),
0068 expectedTopCacheIndices1 = cms.untracked.vuint32(0, 4, 1, 4, 2, 4, 3, 4, 5, 6),
0069 expectedWriteProcessBlockTransitions = cms.untracked.int32(8),
0070 expectedProcessesInFirstFile = cms.untracked.uint32(2),
0071 expectedCacheIndexVectorsPerFile = cms.untracked.vuint32(4),
0072 expectedNEntries0 = cms.untracked.vuint32(4, 1),
0073 expectedCacheEntriesPerFile0 = cms.untracked.vuint32(5)
0074 )
0075
0076
0077 process.p = cms.Path(process.readProcessBlocksOneAnalyzer1 * process.readProcessBlocksOneAnalyzer2)
0078
0079 process.e = cms.EndPath(
0080 process.out *
0081 process.testOneOutput
0082 )
