diff options
author | Matteo Martincigh <matteo.martincigh@arm.com> | 2019-10-04 14:40:04 +0100 |
---|---|---|
committer | Matteo Martincigh <matteo.martincigh@arm.com> | 2019-10-07 10:08:27 +0000 |
commit | 88813936232bc47fc7768800c6895191585570e8 (patch) | |
tree | dfe9a615abd585ad9489afacc017ae40270486cc /src/profiling/test/ProfilingTests.cpp | |
parent | a84edee4702c112a6e004b1987acc11144e2d6dd (diff) | |
download | armnn-88813936232bc47fc7768800c6895191585570e8.tar.gz |
IVGCVSW-3937 Refactor the command thread
* Integrated the Join method into Stop
* Updated the unit tests accordingly
* General code refactoring
Signed-off-by: Matteo Martincigh <matteo.martincigh@arm.com>
Change-Id: If8537e77b3d3ff2b780f58a07df01191a91d83d2
Diffstat (limited to 'src/profiling/test/ProfilingTests.cpp')
-rw-r--r-- | src/profiling/test/ProfilingTests.cpp | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/profiling/test/ProfilingTests.cpp b/src/profiling/test/ProfilingTests.cpp index d14791c43d..9dd7cd3d64 100644 --- a/src/profiling/test/ProfilingTests.cpp +++ b/src/profiling/test/ProfilingTests.cpp @@ -174,7 +174,6 @@ BOOST_AUTO_TEST_CASE(CheckCommandThread) commandThread0.Start(); commandThread0.Stop(); - commandThread0.Join(); BOOST_CHECK(profilingStateMachine.GetCurrentState() == ProfilingState::Active); @@ -188,11 +187,15 @@ BOOST_AUTO_TEST_CASE(CheckCommandThread) testProfilingConnectionTimeOutError); commandThread1.Start(); - commandThread1.Join(); + + std::this_thread::sleep_for(std::chrono::milliseconds(100)); + + BOOST_CHECK(!commandThread1.IsRunning()); + commandThread1.Stop(); BOOST_CHECK(profilingStateMachine.GetCurrentState() == ProfilingState::WaitingForAck); //now commandThread1 should persist after a timeout - commandThread1.StopAfterTimeout(false); + commandThread1.SetStopAfterTimeout(false); commandThread1.Start(); for (int i = 0; i < 100; i++) @@ -208,11 +211,9 @@ BOOST_AUTO_TEST_CASE(CheckCommandThread) } commandThread1.Stop(); - commandThread1.Join(); BOOST_CHECK(profilingStateMachine.GetCurrentState() == ProfilingState::Active); - CommandThread commandThread2(1, false, commandHandlerRegistry, @@ -226,13 +227,13 @@ BOOST_AUTO_TEST_CASE(CheckCommandThread) if (!commandThread2.IsRunning()) { //commandThread2 should stop once it encounters a non timing error - commandThread2.Join(); return; } std::this_thread::sleep_for(std::chrono::milliseconds(5)); } BOOST_ERROR("commandThread2 has failed to stop"); + commandThread2.Stop(); } BOOST_AUTO_TEST_CASE(CheckEncodeVersion) |