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

DDS plugin: improve error message on unexpected update

Browse Source
This commit is contained in:
Alexey Rybalchenko
2020-03-24 14:42:41 +01:00
parent cd83efadea
commit 96348b8462
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fairmq/plugins/DDS/DDS.cxx
View File

@@ -243,6 +243,12 @@ auto DDS::SubscribeForConnectingChannels() -> void
unique_lock<mutex> lk(fUpdateMutex); unique_lock<mutex> lk(fUpdateMutex);
fUpdateCondition.wait(lk, [&]{ return fUpdatesAllowed; }); fUpdateCondition.wait(lk, [&]{ return fUpdatesAllowed; });
} }
if (fConnectingChans.find(channelName) == fConnectingChans.end()) {
LOG(error) << "Received an update for a connecting channel, but either no channel with given channel name exists or it has already been configured: '" << channelName << "', ignoring...";
return;
}
string val = value; string val = value;
// check if it is to handle as one out of multiple values // check if it is to handle as one out of multiple values
auto it = fIofN.find(channelName); auto it = fIofN.find(channelName);