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

Tests.SDK: Add another test

Browse Source
This commit is contained in:
Dennis Klein 2019-07-28 16:28:46 +02:00 committed by Dennis Klein
parent 9cbccface7
commit 07fe02a0a0
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
test/sdk/_topology.cxx
View File

@ -105,7 +105,7 @@ TEST_F(Topology, ChangeStateTimeout)
blocker.Wait(); blocker.Wait();
} }
TEST_F(Topology, ChangeStateFullDeviceLifetime) TEST_F(Topology, ChangeStateFullDeviceLifecycle)
{ {
using fair::mq::sdk::Topology; using fair::mq::sdk::Topology;
using fair::mq::sdk::TopologyTransition; using fair::mq::sdk::TopologyTransition;
@ -125,4 +125,27 @@ TEST_F(Topology, ChangeStateFullDeviceLifetime)
} }
} }
TEST_F(Topology, ChangeStateFullDeviceLifecycle2)
{
using fair::mq::sdk::Topology;
using fair::mq::sdk::TopologyTransition;
Topology topo(mDDSTopo, mDDSSession);
for (int i(0); i < 10; ++i) {
for (auto transition : {TopologyTransition::InitDevice,
TopologyTransition::CompleteInit,
TopologyTransition::Bind,
TopologyTransition::Connect,
TopologyTransition::InitTask,
TopologyTransition::Run}) {
ASSERT_EQ(topo.ChangeState(transition).rc, fair::mq::AsyncOpResultCode::Ok);
}
std::this_thread::sleep_for(std::chrono::milliseconds(100));
for (auto transition : {TopologyTransition::Stop,
TopologyTransition::ResetTask,
TopologyTransition::ResetDevice}) {
ASSERT_EQ(topo.ChangeState(transition).rc, fair::mq::AsyncOpResultCode::Ok);
}
}
}
} // namespace } // namespace