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

Add sdk:GroupByTaskId(TopologyState)

Browse Source
This commit is contained in:
Alexey Rybalchenko 2019-09-05 16:13:18 +02:00 committed by Dennis Klein
parent 92112c812f
commit 4b78c472b1
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
fairmq/sdk/Topology.h
View File

@ -102,6 +102,16 @@ inline TopologyStateByCollection GroupByCollectionId(const TopologyState& topolo
return state;
}
inline TopologyStateByTask GroupByTaskId(const TopologyState& topologyState)
{
TopologyStateByTask state;
for (const auto& ds : topologyState) {
state[ds.taskId] = ds;
}
return state;
}
/**
* @class BasicTopology Topology.h <fairmq/sdk/Topology.h>
* @tparam Executor Associated I/O executor