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

SDK: Add DDSTopology::GetTasksMatchingPath

Browse Source
This commit is contained in:
Alexey Rybalchenko 2020-01-23 16:40:36 +01:00 committed by Dennis Klein
parent f42945b3a3
commit 25658370fa
2 changed files with 23 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
fairmq/sdk/DDSTopology.cxx
View File

@ -69,10 +69,25 @@ auto DDSTopology::GetTasks() const -> std::vector<DDSTask>
std::vector<DDSTask> list; std::vector<DDSTask> list;
list.reserve(GetNumRequiredAgents()); list.reserve(GetNumRequiredAgents());
auto itPair = fImpl->fTopo.getRuntimeTaskIterator( auto itPair = fImpl->fTopo.getRuntimeTaskIterator(nullptr); // passing nullptr will get all tasks
[](const dds::topology_api::STopoRuntimeTask::FilterIterator_t::value_type&) -> bool { auto tasks = boost::make_iterator_range(itPair.first, itPair.second);
return true;
}); for (const auto& task : tasks) {
LOG(debug) << "Found task with id: " << task.first << ", "
<< "Path: " << task.second.m_taskPath << ", "
<< "Collection id: " << task.second.m_taskCollectionId << ", "
<< "Name: " << task.second.m_task->getName() << "_" << task.second.m_taskIndex;
list.emplace_back(task.first, task.second.m_taskCollectionId);
}
return list;
}
auto DDSTopology::GetTasksMatchingPath(const std::string& path) const -> std::vector<DDSTask>
{
std::vector<DDSTask> list;
auto itPair = fImpl->fTopo.getRuntimeTaskIteratorMatchingPath(path);
auto tasks = boost::make_iterator_range(itPair.first, itPair.second); auto tasks = boost::make_iterator_range(itPair.first, itPair.second);
for (const auto& task : tasks) { for (const auto& task : tasks) {
@ -90,10 +105,7 @@ auto DDSTopology::GetCollections() const -> std::vector<DDSCollection>
{ {
std::vector<DDSCollection> list; std::vector<DDSCollection> list;
auto itPair = fImpl->fTopo.getRuntimeCollectionIterator( auto itPair = fImpl->fTopo.getRuntimeCollectionIterator(nullptr); // passing nullptr will get all collections
[](const dds::topology_api::STopoRuntimeCollection::FilterIterator_t::value_type&) -> bool {
return true;
});
auto collections = boost::make_iterator_range(itPair.first, itPair.second); auto collections = boost::make_iterator_range(itPair.first, itPair.second);
for (const auto& c : collections) { for (const auto& c : collections) {

3
fairmq/sdk/DDSTopology.h
View File

@ -56,6 +56,9 @@ class DDSTopology
/// @brief Get list of tasks in this topology /// @brief Get list of tasks in this topology
auto GetTasks() const -> std::vector<DDSTask>; auto GetTasks() const -> std::vector<DDSTask>;
/// @brief Get list of tasks matching the provided topology path
auto GetTasksMatchingPath(const std::string&) const -> std::vector<DDSTask>;
/// @brief Get list of tasks in this topology /// @brief Get list of tasks in this topology
auto GetCollections() const -> std::vector<DDSCollection>; auto GetCollections() const -> std::vector<DDSCollection>;