From 99c81fc8a7a7b147e398b9ed0ed21ede98e6f9d5 Mon Sep 17 00:00:00 2001 From: Jan Fiete Date: Wed, 24 Apr 2024 12:06:22 +0200 Subject: [PATCH 1/3] Increase counter before sending metric --- run/dpl_eventgen.cxx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/run/dpl_eventgen.cxx b/run/dpl_eventgen.cxx index b1929482041b0..66dd1c8342990 100644 --- a/run/dpl_eventgen.cxx +++ b/run/dpl_eventgen.cxx @@ -101,8 +101,8 @@ struct GeneratorTask { } // report number of TFs injected for the rate limiter to work - pc.services().get().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL)); ++tfCounter; + pc.services().get().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL)); bool time_expired = false; if (ttl > 0) { timer.Stop(); From 427a2006eabe1d8276afa8c922deb9870ee5cf93 Mon Sep 17 00:00:00 2001 From: Jan Fiete Date: Wed, 24 Apr 2024 12:07:22 +0200 Subject: [PATCH 2/3] Update o2sim_kine_publisher.cxx --- run/o2sim_kine_publisher.cxx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/run/o2sim_kine_publisher.cxx b/run/o2sim_kine_publisher.cxx index 83f82fd69cca3..f72dd6eebaaf0 100644 --- a/run/o2sim_kine_publisher.cxx +++ b/run/o2sim_kine_publisher.cxx @@ -49,8 +49,8 @@ struct O2simKinePublisher { ++eventCounter; } // report number of TFs injected for the rate limiter to work - pc.services().get().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL)); ++tfCounter; + pc.services().get().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL)); if (eventCounter >= nEvents) { pc.services().get().endOfStream(); pc.services().get().readyToQuit(QuitRequest::Me); From 83b160c70dcacd39ba823d9518751c3b5d4b1e26 Mon Sep 17 00:00:00 2001 From: Jan Fiete Date: Wed, 24 Apr 2024 12:07:51 +0200 Subject: [PATCH 3/3] Update o2sim_hepmc_publisher.cxx --- run/o2sim_hepmc_publisher.cxx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/run/o2sim_hepmc_publisher.cxx b/run/o2sim_hepmc_publisher.cxx index ec049a44439a1..bf40abacb134f 100644 --- a/run/o2sim_hepmc_publisher.cxx +++ b/run/o2sim_hepmc_publisher.cxx @@ -148,8 +148,8 @@ struct O2simHepmcPublisher { } // report number of TFs injected for the rate limiter to work - pc.services().get().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL)); ++tfCounter; + pc.services().get().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL)); if (eos || (maxEvents > 0 && eventCounter == maxEvents)) { pc.services().get().endOfStream(); pc.services().get().readyToQuit(QuitRequest::Me);