Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 08:41:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make invalid channel initialization cancellable through pending state

Browse Source
This commit is contained in:
Alexey Rybalchenko 2022-11-16 19:55:22 +01:00
parent 1c8d1245ad
commit 9172a4aa04
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
fairmq/Device.cxx
View File

@ -304,7 +304,7 @@ void Device::ConnectWrapper()
// first attempt // first attempt
AttachChannels(fUninitializedConnectingChannels); AttachChannels(fUninitializedConnectingChannels);
// if not all channels could be connected, update their address values from config and retry // 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)); this_thread::sleep_for(chrono::milliseconds(sleepTimeInMS));
for (auto& chan : fUninitializedConnectingChannels) { for (auto& chan : fUninitializedConnectingChannels) {