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

fix unittest test_uniq_task_queue

Browse Source
This commit is contained in:
LeonChaoHi
2024-05-27 15:11:47 +00:00
committed by ob-robot
parent 2355bec27b
commit d8bbcdb419
1 changed files with 6 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
unittest/observer/test_uniq_task_queue.cpp
View File

@ -239,23 +239,14 @@ TEST_F(TestUniqTaskQueue, test_get_queue_fail)
// bugfix: workitem/49006474 // bugfix: workitem/49006474
TEST_F(TestUniqTaskQueue, test_queue_starvation) TEST_F(TestUniqTaskQueue, test_queue_starvation)
{ {
obrpc::MockObCommonRpcProxy rpc;
GDS.set_rpc_proxy(&rpc);
ObMalloc allocator;
ObDSSessionActions sa;
ASSERT_EQ(OB_SUCCESS, sa.init(1024, allocator));
GCONF.debug_sync_timeout.set_value("1000s");
ASSERT_TRUE(GCONF.is_debug_sync_enabled());
const bool L = false; // local
ASSERT_EQ(OB_SUCCESS, GDS.add_debug_sync("BEFORE_UNIQ_TASK_RUN wait_for signal", L, sa));
MockTaskQueue queue; MockTaskQueue queue;
MockTaskProcesser processor(queue); MockTaskProcesser processor(queue);
ASSERT_EQ(OB_SUCCESS, queue.init(&processor, 1 /*thread_num*/, 1024 /*queue_size*/)); ASSERT_EQ(OB_SUCCESS, queue.init(&processor, 1 /*thread_num*/, 1024 /*queue_size*/));
// to reproduce the bug scenario's groups and tasks, stop the queue first and add tasks
queue.stop();
queue.wait();
MockTask task(0 /*group_id*/, 0 /*task_id*/); MockTask task(0 /*group_id*/, 0 /*task_id*/);
ASSERT_EQ(OB_SUCCESS, queue.add(task)); ASSERT_EQ(OB_SUCCESS, queue.add(task));
@ -276,7 +267,8 @@ TEST_F(TestUniqTaskQueue, test_queue_starvation)
* |-----------| * |-----------|
*/ */
ASSERT_EQ(OB_SUCCESS, GDS.add_debug_sync("now signal signal", L, sa)); // continue to start queue
ASSERT_EQ(OB_SUCCESS, queue.start());
/* /*
* before task(1, 0) runs, tasks in queue are as follows: * before task(1, 0) runs, tasks in queue are as follows: