From da9748da0d1afa3edfa3d576c330be079ae6cfa4 Mon Sep 17 00:00:00 2001 From: Jan Fiete Grosse-Oetringhaus Date: Tue, 12 Jan 2021 15:42:16 +0100 Subject: [PATCH] add alien SE --- .../AnalysisSupport/src/AODJAlienReaderHelpers.cxx | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx b/Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx index bb97107189eac..327358e2424ec 100644 --- a/Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx +++ b/Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx @@ -299,13 +299,19 @@ AlgorithmSpec AODJAlienReaderHelpers::rootFileReaderCallback() std::string nextFileRead = info.file->GetPath(); if (currentFileRead != nextFileRead) { currentFileRead = nextFileRead; + std::string monitoringInfo(currentFileRead); + monitoringInfo += ","; + monitoringInfo += std::to_string(info.file->GetSize()); #if __has_include() auto alienFile = dynamic_cast(info.file); if (alienFile) { - /// FIXME: get the JAlien stats + monitoringInfo += ","; + monitoringInfo += alienFile->GetSE(); } #endif - monitoring.send(Metric{currentFileRead, "aod-file-read-path"}.addTag(Key::Subsystem, monitoring::tags::Value::DPL)); + monitoring.send(Metric{monitoringInfo, "aod-file-read-info"}.addTag(Key::Subsystem, monitoring::tags::Value::DPL)); + LOGP(INFO, "File read info: {}", monitoringInfo); + // TODO extend to publish at the end of the file (or on each TF?) the sizes read *per file* } } monitoring.send(Metric{(double)ps.GetReadCalls(), "aod-tree-read-calls"}.addTag(Key::Subsystem, monitoring::tags::Value::DPL));