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: One more test

Browse Source
This commit is contained in:
Dennis Klein 2020-01-27 19:29:40 +01:00 committed by Dennis Klein
parent be524d838a
commit 19ab8bba3b
1 changed files with 28 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
test/sdk/_topology.cxx
View File

@ -368,4 +368,32 @@ TEST_F(Topology, GetProperties)
ASSERT_EQ(topo.ChangeState(TopologyTransition::ResetDevice).first, std::error_code()); ASSERT_EQ(topo.ChangeState(TopologyTransition::ResetDevice).first, std::error_code());
} }
TEST_F(Topology, SetAndGetProperties)
{
using namespace fair::mq;
using fair::mq::sdk::TopologyTransition;
sdk::Topology topo(mDDSTopo, mDDSSession);
ASSERT_EQ(topo.ChangeState(TopologyTransition::InitDevice).first, std::error_code());
sdk::DeviceProperties const props{{"key1", "val1"}, {"key2", "val2"}};
auto const result1 = topo.SetProperties(props);
LOG(info) << result1.first;
ASSERT_EQ(result1.first, std::error_code());
ASSERT_EQ(result1.second.size(), 0);
auto const result2 = topo.GetProperties("^key.*");
LOG(info) << result2.first;
ASSERT_EQ(result2.first, std::error_code());
ASSERT_EQ(result2.second.failed.size(), 0);
ASSERT_EQ(result2.second.devices.size(), 6);
for (auto const& d : result2.second.devices) {
ASSERT_EQ(d.second.props, props);
}
ASSERT_EQ(topo.ChangeState(TopologyTransition::CompleteInit).first, std::error_code());
ASSERT_EQ(topo.ChangeState(TopologyTransition::ResetDevice).first, std::error_code());
}
} // namespace } // namespace