From b41aba2a0370f3cafff581be1a89c5ea1c4f78e5 Mon Sep 17 00:00:00 2001 From: Francisco Date: Mon, 17 May 2021 19:02:35 +0100 Subject: [PATCH] fix task scheduler test --- lib/test/common/task_scheduler_test.cc | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/lib/test/common/task_scheduler_test.cc b/lib/test/common/task_scheduler_test.cc index c986c20a8..640c43d2a 100644 --- a/lib/test/common/task_scheduler_test.cc +++ b/lib/test/common/task_scheduler_test.cc @@ -43,7 +43,10 @@ int test_task_scheduler_no_pool() task_sched.notify_background_task_result([&state]() { state = task_result::external; }); }); TESTASSERT(state == task_result::null); - task_sched.run_next_task(); // runs notification + while (state != task_result::external) { + task_sched.run_pending_tasks(); // runs notification + std::this_thread::sleep_for(std::chrono::microseconds(100)); + } TESTASSERT(state == task_result::external); return SRSRAN_SUCCESS; @@ -58,8 +61,10 @@ int test_task_scheduler_with_pool() task_sched.notify_background_task_result([&state]() { state = task_result::external; }); }); TESTASSERT(state == task_result::null); - task_sched.run_next_task(); // waits and runs notification - TESTASSERT(state == task_result::external); + while (state != task_result::external) { + task_sched.run_pending_tasks(); // runs notification + std::this_thread::sleep_for(std::chrono::microseconds(100)); + } return SRSRAN_SUCCESS; }