From bf4b538542616b198c7cbb9b8b977a25f33c4bdf Mon Sep 17 00:00:00 2001 From: Florine de Geus Date: Thu, 9 Jan 2025 15:39:46 +0100 Subject: [PATCH] [ntuple] Update chain processing tutorial --- tutorials/io/ntuple/ntpl012_processor_chain.C | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/tutorials/io/ntuple/ntpl012_processor_chain.C b/tutorials/io/ntuple/ntpl012_processor_chain.C index 1b019b119f631c..983c6b52ed8ec5 100644 --- a/tutorials/io/ntuple/ntpl012_processor_chain.C +++ b/tutorials/io/ntuple/ntpl012_processor_chain.C @@ -74,12 +74,14 @@ void Read(const std::vector &ntuples) // Access to the entry values in this case can be achieved through RNTupleProcessor::GetEntry() or through its // iterator. auto processor = RNTupleProcessor::CreateChain(ntuples, std::move(model)); + int prevProcessorNumber{-1}; for (const auto &entry : *processor) { // The RNTupleProcessor provides some additional bookkeeping information. The local entry number is reset each // a new ntuple in the chain is opened for processing. - if (processor->GetLocalEntryNumber() == 0) { - std::cout << "Processing " << ntuples.at(processor->GetCurrentNTupleNumber()).fNTupleName << " (" + if (static_cast(processor->GetCurrentProcessorNumber()) > prevProcessorNumber) { + prevProcessorNumber = processor->GetCurrentProcessorNumber(); + std::cout << "Processing " << ntuples.at(prevProcessorNumber).fNTupleName << " (" << processor->GetNEntriesProcessed() << " total entries processed so far)" << std::endl; }