Skip to content

Commit 27eb1a3

Browse files
committed
DPL: Do not drain messages before START, this can break the FST
1 parent 2b43e7c commit 27eb1a3

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

Framework/Core/src/ExternalFairMQDeviceProxy.cxx

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -684,7 +684,11 @@ DataProcessorSpec specifyExternalFairMQDeviceProxy(char const* name,
684684
auto& deviceState = registry.get<DeviceState>();
685685
// We drop messages in input only when in ready.
686686
// FIXME: should we drop messages in input the first time we are in ready?
687-
if (fair::mq::State{state} != fair::mq::State::Ready) {
687+
static bool wasRunning = false;
688+
if (fair::mq::State{state} == fair::mq::State::Running) {
689+
wasRunning = true;
690+
}
691+
if (fair::mq::State{state} != fair::mq::State::Ready || !wasRunning) {
688692
return;
689693
}
690694
uv_update_time(deviceState.loop);

0 commit comments

Comments
 (0)