xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: arb unit test

This commit is contained in:
Shungang Li 2024-03-15 11:11:07 +08:00
parent 3a656c3595
commit fc7575279c
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
source/dnode/mnode/impl/test/arbgroup/arbgroup.cpp
View File

@ -114,6 +114,8 @@ TEST_F(ArbgroupTest, 02_process_heart_beat_rsp) {
group.assignedLeader.dnodeId = dnodeId; group.assignedLeader.dnodeId = dnodeId;
strncpy(group.assignedLeader.token, group.members[0].state.token, TSDB_ARB_TOKEN_SIZE); strncpy(group.assignedLeader.token, group.members[0].state.token, TSDB_ARB_TOKEN_SIZE);
taosThreadMutexInit(&group.mutex, NULL);
// -------------------------------------------------------------------------------- // --------------------------------------------------------------------------------
{ // expired hb => skip { // expired hb => skip
SVArbHbRspMember rspMember = {0}; SVArbHbRspMember rspMember = {0};
@ -164,6 +166,8 @@ TEST_F(ArbgroupTest, 02_process_heart_beat_rsp) {
EXPECT_EQ(newGroup.assignedLeader.dnodeId, 0); EXPECT_EQ(newGroup.assignedLeader.dnodeId, 0);
EXPECT_EQ(std::string(newGroup.assignedLeader.token).size(), 0); EXPECT_EQ(std::string(newGroup.assignedLeader.token).size(), 0);
} }
taosThreadMutexDestroy(&group.mutex);
} }
TEST_F(ArbgroupTest, 03_process_check_sync_rsp) { TEST_F(ArbgroupTest, 03_process_check_sync_rsp) {
@ -184,6 +188,8 @@ TEST_F(ArbgroupTest, 03_process_check_sync_rsp) {
group.isSync = 0; group.isSync = 0;
taosThreadMutexInit(&group.mutex, NULL);
// -------------------------------------------------------------------------------- // --------------------------------------------------------------------------------
{ // token mismatch => skip { // token mismatch => skip
char member0Token[TSDB_ARB_TOKEN_SIZE] = {0}; char member0Token[TSDB_ARB_TOKEN_SIZE] = {0};
@ -211,6 +217,8 @@ TEST_F(ArbgroupTest, 03_process_check_sync_rsp) {
EXPECT_TRUE(updateIsSync); EXPECT_TRUE(updateIsSync);
EXPECT_TRUE(newGroup.isSync); EXPECT_TRUE(newGroup.isSync);
} }
taosThreadMutexDestroy(&group.mutex);
} }
TEST_F(ArbgroupTest, 04_process_set_assigned_leader){ TEST_F(ArbgroupTest, 04_process_set_assigned_leader){
@ -233,6 +241,8 @@ TEST_F(ArbgroupTest, 04_process_set_assigned_leader){
group.assignedLeader.dnodeId = dnodeId; group.assignedLeader.dnodeId = dnodeId;
strncpy(group.assignedLeader.token, group.members[0].state.token, TSDB_ARB_TOKEN_SIZE); strncpy(group.assignedLeader.token, group.members[0].state.token, TSDB_ARB_TOKEN_SIZE);
taosThreadMutexInit(&group.mutex, NULL);
// -------------------------------------------------------------------------------- // --------------------------------------------------------------------------------
{ // token mismatch => skip { // token mismatch => skip
char memberToken[TSDB_ARB_TOKEN_SIZE] = {0}; char memberToken[TSDB_ARB_TOKEN_SIZE] = {0};
@ -269,6 +279,8 @@ TEST_F(ArbgroupTest, 04_process_set_assigned_leader){
EXPECT_TRUE(updateAssigned); EXPECT_TRUE(updateAssigned);
EXPECT_FALSE(newGroup.isSync); EXPECT_FALSE(newGroup.isSync);
} }
taosThreadMutexDestroy(&group.mutex);
} }
#pragma GCC diagnostic pop #pragma GCC diagnostic pop