Back to home page

Project CMSSW displayed by LXR

 
 

    


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 )