File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
Framework/AnalysisSupport/src Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -299,13 +299,19 @@ AlgorithmSpec AODJAlienReaderHelpers::rootFileReaderCallback()
299299 std::string nextFileRead = info.file ->GetPath ();
300300 if (currentFileRead != nextFileRead) {
301301 currentFileRead = nextFileRead;
302+ std::string monitoringInfo (currentFileRead);
303+ monitoringInfo += " ," ;
304+ monitoringInfo += std::to_string (info.file ->GetSize ());
302305#if __has_include(<TJAlienFile.h>)
303306 auto alienFile = dynamic_cast <TJAlienFile*>(info.file );
304307 if (alienFile) {
305- // / FIXME: get the JAlien stats
308+ monitoringInfo += " ," ;
309+ monitoringInfo += alienFile->GetSE ();
306310 }
307311#endif
308- monitoring.send (Metric{currentFileRead, " aod-file-read-path" }.addTag (Key::Subsystem, monitoring::tags::Value::DPL));
312+ monitoring.send (Metric{monitoringInfo, " aod-file-read-info" }.addTag (Key::Subsystem, monitoring::tags::Value::DPL));
313+ LOGP (INFO, " File read info: {}" , monitoringInfo);
314+ // TODO extend to publish at the end of the file (or on each TF?) the sizes read *per file*
309315 }
310316 }
311317 monitoring.send (Metric{(double )ps.GetReadCalls (), " aod-tree-read-calls" }.addTag (Key::Subsystem, monitoring::tags::Value::DPL));
You can’t perform that action at this time.
0 commit comments