From 5c3d3f7d9e5b5bc938ce6f655b1e9ab07e616c06 Mon Sep 17 00:00:00 2001 From: Giulio Eulisse Date: Mon, 15 Jun 2020 00:28:29 +0200 Subject: [PATCH] DPL: make proxy honor state changes --- Framework/Core/src/ExternalFairMQDeviceProxy.cxx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Framework/Core/src/ExternalFairMQDeviceProxy.cxx b/Framework/Core/src/ExternalFairMQDeviceProxy.cxx index 5f5be9fb9a6f7..6db25dd46f3c4 100644 --- a/Framework/Core/src/ExternalFairMQDeviceProxy.cxx +++ b/Framework/Core/src/ExternalFairMQDeviceProxy.cxx @@ -69,7 +69,7 @@ void sendOnChannel(FairMQDevice& device, FairMQParts& messages, std::string cons // TODO: we might want to treat this error condition some levels higher up, but for // the moment its an appropriate solution. The important thing is not to drop // messages and to be informed about the congestion. - while (device.Send(messages, channel, index, timeout) < 0) { + while (device.NewStatePending() == false && device.Send(messages, channel, index, timeout) < 0) { if (timeout == 0) { timeout = 1; } else if (timeout < maxTimeout) {