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

End transitions are now properly notified

Browse Source
This commit is contained in:
Dennis Klein 2019-09-04 21:23:48 +02:00
parent 67e8fe67ad
commit dab00296aa
No known key found for this signature in database
GPG Key ID: 08E62D23FA0ECBBC
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
main.cpp
View File

@ -48,11 +48,8 @@ int main(int argc, char *argv[]) {
auto [ec, states] = auto [ec, states] =
fairmqTopo.ChangeState(transition, std::chrono::milliseconds(300)); fairmqTopo.ChangeState(transition, std::chrono::milliseconds(300));
if (!ec) { if (!ec) {
// End transition does not yet wait for devices to acknowledge in v1.4.8 LOG(info) << states.size() << " devices transitioned to "
if (transition != TopologyTransition::End) { << fair::mq::sdk::AggregateState(states);
LOG(info) << states.size() << " devices transitioned to "
<< fair::mq::sdk::AggregateState(states);
}
} else { } else {
LOG(error) << ec; LOG(error) << ec;
return ec.value(); return ec.value();