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

PMIx plugin: Fix Commands API usage

Browse Source
This commit is contained in:
Alexey Rybalchenko 2020-04-03 17:15:55 +02:00 committed by Dennis Klein
parent 036561ab38
commit 7cbd154344
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
fairmq/plugins/PMIx/PMIxPlugin.cxx
View File

@ -171,7 +171,7 @@ auto PMIxPlugin::SubscribeForCommands() -> void
LOG(debug) << "Publishing state-change: " << fLastState << "->" << fCurrentState LOG(debug) << "Publishing state-change: " << fLastState << "->" << fCurrentState
<< " to " << sender; << " to " << sender;
Cmds outCmds(make<StateChangeSubscription>(fDeviceId, Result::Ok), Cmds outCmds(make<StateChangeSubscription>(fDeviceId, fProcess.rank, Result::Ok),
make<StateChange>(fDeviceId, 0, fLastState, fCurrentState)); make<StateChange>(fDeviceId, 0, fLastState, fCurrentState));
fCommands.Send(outCmds.Serialize(Format::JSON), {sender}); fCommands.Send(outCmds.Serialize(Format::JSON), {sender});
} }
@ -181,7 +181,7 @@ auto PMIxPlugin::SubscribeForCommands() -> void
lock_guard<mutex> lock{fStateChangeSubscriberMutex}; lock_guard<mutex> lock{fStateChangeSubscriberMutex};
fStateChangeSubscribers.erase(sender.rank); fStateChangeSubscribers.erase(sender.rank);
} }
fCommands.Send(Cmds(make<StateChangeUnsubscription>(fDeviceId, Result::Ok)) fCommands.Send(Cmds(make<StateChangeUnsubscription>(fDeviceId, fProcess.rank, Result::Ok))
.Serialize(Format::JSON), .Serialize(Format::JSON),
{sender}); {sender});
} }