Update o2sim_hepmc_publisher.cxx

jgrosseo · ktf · commit b005a9d86105 · 2024-04-24T20:15:14.000+02:00
diff --git 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<o2::monitoring::Monitoring>().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL));
     ++tfCounter;
+    pc.services().get<o2::monitoring::Monitoring>().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<ControlService>().endOfStream();
       pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);

Original file line number	Diff line number	Diff line change
`@@ -148,8 +148,8 @@ struct O2simHepmcPublisher {`
`148`	`148`	`}`
`149`	`149`
`150`	`150`	`// report number of TFs injected for the rate limiter to work`
`151`		`- pc.services().get<o2::monitoring::Monitoring>().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL));`
`152`	`151`	`++tfCounter;`
	`152`	`+ pc.services().get<o2::monitoring::Monitoring>().send(o2::monitoring::Metric{(uint64_t)tfCounter, "df-sent"}.addTag(o2::monitoring::tags::Key::Subsystem, o2::monitoring::tags::Value::DPL));`
`153`	`153`	`if (eos \|\| (maxEvents > 0 && eventCounter == maxEvents)) {`
`154`	`154`	`pc.services().get<ControlService>().endOfStream();`
`155`	`155`	`pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);`