DPL: allow larger grace period for dispatching non-DPL incoming messages (#13639)

ktf · web-flow · commit 096694b4a397 · 2024-11-07T06:54:40.000+01:00
diff --git a/Framework/Core/src/ExternalFairMQDeviceProxy.cxx b/Framework/Core/src/ExternalFairMQDeviceProxy.cxx
@@ -108,8 +108,8 @@ void sendOnChannel(fair::mq::Device& device, fair::mq::Parts& messages, std::str
   }
 
   // FIXME: we need a better logic for avoiding message spam
-  if (timeout > 1 && timeout <= maxTimeout) {
-    LOG(warning) << "dispatching on channel " << channel << " was delayed by " << timeout << " ms";
+  if (timeout > 100 && timeout <= maxTimeout) {
+    LOG(warning) << "dispatching on channel " << channel << " was delayed by " << timeout / 1000.f << " s";
   }
   // TODO: feeling this is a bit awkward, but the interface of fair::mq::Parts does not provide a
   // method to clear the content.

Original file line number	Diff line number	Diff line change
`@@ -108,8 +108,8 @@ void sendOnChannel(fair::mq::Device& device, fair::mq::Parts& messages, std::str`
`108`	`108`	`}`
`109`	`109`
`110`	`110`	`// FIXME: we need a better logic for avoiding message spam`
`111`		`- if (timeout > 1 && timeout <= maxTimeout) {`
`112`		`- LOG(warning) << "dispatching on channel " << channel << " was delayed by " << timeout << " ms";`
	`111`	`+ if (timeout > 100 && timeout <= maxTimeout) {`
	`112`	`+ LOG(warning) << "dispatching on channel " << channel << " was delayed by " << timeout / 1000.f << " s";`
`113`	`113`	`}`
`114`	`114`	`// TODO: feeling this is a bit awkward, but the interface of fair::mq::Parts does not provide a`
`115`	`115`	`// method to clear the content.`