From 2b7ee8adbeb325e1a254638bff460cdaebf526c8 Mon Sep 17 00:00:00 2001 From: Jan Fiete Date: Fri, 15 Jan 2021 14:29:53 +0100 Subject: [PATCH] fix for 2 readers and 1 input file --- Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx b/Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx index 07bdcb31b774e..8a6ab20de40d8 100644 --- a/Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx +++ b/Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx @@ -147,6 +147,9 @@ static inline auto extractOriginalsTuple(framework::pack, ProcessingConte void AODJAlienReaderHelpers::dumpFileMetrics(Monitoring& monitoring, TFile* currentFile, uint64_t startedAt, int tfPerFile, int tfRead) { + if (currentFile == nullptr) { + return; + } std::string monitoringInfo(fmt::format("lfn={},size={},total_tf={},read_tf={},read_bytes={},read_calls={},run_time={:.1f}", currentFile->GetName(), currentFile->GetSize(), tfPerFile, tfRead, currentFile->GetBytesRead(), currentFile->GetReadCalls(), ((float)(uv_hrtime() - startedAt) / 1e9))); #if __has_include() @@ -236,9 +239,7 @@ AlgorithmSpec AODJAlienReaderHelpers::rootFileReaderCallback() if (!watchdog->update()) { LOGP(INFO, "Run time exceeds run time limit of {} seconds!", watchdog->runTimeLimit); LOGP(INFO, "Stopping reader {} after time frame {}.", device.inputTimesliceId, watchdog->numberTimeFrames - 1); - if (currentFile) { - dumpFileMetrics(monitoring, currentFile, currentFileStartedAt, tfCurrentFile, ntf); - } + dumpFileMetrics(monitoring, currentFile, currentFileStartedAt, tfCurrentFile, ntf); monitoring.flushBuffer(); didir->closeInputFiles(); control.endOfStream();