hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix unstable ut: test_tg_mgr

Browse Source
This commit is contained in:
obdev 2023-10-12 13:09:42 +00:00 committed by ob-robot
parent 852eef5a78
commit 505cfa1e53
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/oblib/src/lib/thread/thread_mgr.h vendored
View File

@ -276,8 +276,8 @@ public:
void logical_stop()
{
if (nullptr != th_) {
th_->runnable_->set_stop(true);
th_->logical_stop();
th_->runnable_->set_stop(true);
}
}
void logical_wait()

10
deps/oblib/unittest/lib/thread/test_tg_mgr.cpp vendored
View File

@ -26,7 +26,7 @@ public:
{
running_ = true;
++task_run_count_;
::usleep(50000);
::usleep(500000);
running_ = false;
}
@ -41,9 +41,9 @@ TEST(TG, timer)
// start
ASSERT_EQ(OB_SUCCESS, TG_START(tg_id));
ASSERT_EQ(OB_SUCCESS, TG_SCHEDULE(tg_id, task, 0, true));
::usleep(40000);
::usleep(250000);
ASSERT_TRUE(task.running_);
::usleep(60000);
::usleep(750000);
ASSERT_EQ(1, task.task_run_count_);
ASSERT_EQ(OB_SUCCESS, TG_STOP_R(tg_id));
TG_WAIT_ONLY(tg_id);
@ -55,9 +55,9 @@ TEST(TG, timer)
// restart
ASSERT_EQ(OB_SUCCESS, TG_START(tg_id));
ASSERT_EQ(OB_SUCCESS, TG_SCHEDULE(tg_id, task, 0, true));
::usleep(40000);
::usleep(250000);
ASSERT_TRUE(task.running_);
::usleep(60000);
::usleep(750000);
ASSERT_EQ(2, task.task_run_count_);
ASSERT_EQ(OB_SUCCESS, TG_STOP_R(tg_id));
ASSERT_EQ(OB_SUCCESS, TG_WAIT_R(tg_id));