From 87baf9749d2d0a467972cfe77151d4c245a1c84f Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Wed, 16 Nov 2022 19:55:22 +0100 Subject: [PATCH] Make invalid channel initialization cancellable through pending state --- fairmq/Device.cxx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fairmq/Device.cxx b/fairmq/Device.cxx index bfb7d87a..06c8ab89 100644 --- a/fairmq/Device.cxx +++ b/fairmq/Device.cxx @@ -304,7 +304,7 @@ void Device::ConnectWrapper() // first attempt AttachChannels(fUninitializedConnectingChannels); // if not all channels could be connected, update their address values from config and retry - while (!fUninitializedConnectingChannels.empty()) { + while (!fUninitializedConnectingChannels.empty() && !NewStatePending()) { this_thread::sleep_for(chrono::milliseconds(sleepTimeInMS)); for (auto& chan : fUninitializedConnectingChannels) {