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

ut: minor changes

This commit is contained in:
Shengliang Guan 2024-12-17 19:27:22 +08:00
parent 7488acc3b1
commit 5ea16d3ada
1 changed files with 33 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
source/os/test/osThreadTests.cpp
View File

@ -34,7 +34,6 @@ static int32_t globalVar = 0;
static void funcPtrKey(void *param) { taosMsleep(100); } static void funcPtrKey(void *param) { taosMsleep(100); }
static void *funcPtr200(void *param) { static void *funcPtr200(void *param) {
taosMsleep(200);
TdThread thread = taosThreadSelf(); TdThread thread = taosThreadSelf();
TdThreadKey key = {0}; TdThreadKey key = {0};
@ -58,6 +57,7 @@ static void *funcPtr200(void *param) {
taosThreadGetSchedParam(thread, &policy, NULL); taosThreadGetSchedParam(thread, &policy, NULL);
// taosThreadSetSchedParam(NULL, 0, &para); // taosThreadSetSchedParam(NULL, 0, &para);
taosThreadSetSchedParam(thread, 0, &para); taosThreadSetSchedParam(thread, 0, &para);
taosMsleep(200);
return NULL; return NULL;
} }
@ -107,6 +107,8 @@ TEST(osThreadTests, thread) {
EXPECT_NE(reti, 0); EXPECT_NE(reti, 0);
reti = taosThreadCreate(&tid1, NULL, funcPtr200, NULL); reti = taosThreadCreate(&tid1, NULL, funcPtr200, NULL);
EXPECT_EQ(reti, 0); EXPECT_EQ(reti, 0);
taosMsleep(300);
reti = taosThreadCancel(tid1); reti = taosThreadCancel(tid1);
EXPECT_EQ(reti, 0); EXPECT_EQ(reti, 0);
@ -289,6 +291,9 @@ TEST(osThreadTests, cond) {
reti = taosThreadCondAttrGetPshared(&condattr, NULL); reti = taosThreadCondAttrGetPshared(&condattr, NULL);
EXPECT_NE(reti, 0); EXPECT_NE(reti, 0);
reti = taosThreadCondAttrSetclock(NULL, -1);
EXPECT_NE(reti, 0);
reti = taosThreadCondAttrDestroy(NULL); reti = taosThreadCondAttrDestroy(NULL);
EXPECT_NE(reti, 0); EXPECT_NE(reti, 0);
reti = taosThreadCondAttrDestroy(&condattr); reti = taosThreadCondAttrDestroy(&condattr);
@ -399,6 +404,33 @@ TEST(osThreadTests, rwlock) {
EXPECT_NE(reti, 0); EXPECT_NE(reti, 0);
reti = taosThreadRwlockDestroy(&rwlock); reti = taosThreadRwlockDestroy(&rwlock);
EXPECT_EQ(reti, 0); EXPECT_EQ(reti, 0);
reti = taosThreadRwlockInit(NULL, 0);
EXPECT_NE(reti, 0);
reti = taosThreadRwlockInit(&rwlock, 0);
EXPECT_EQ(reti, 0);
reti = taosThreadRwlockTryWrlock(NULL);
EXPECT_NE(reti, 0);
reti = taosThreadRwlockTryWrlock(&rwlock);
EXPECT_EQ(reti, 0);
reti = taosThreadRwlockUnlock(NULL);
EXPECT_NE(reti, 0);
reti = taosThreadRwlockUnlock(&rwlock);
EXPECT_EQ(reti, 0);
reti = taosThreadRwlockWrlock(NULL);
EXPECT_NE(reti, 0);
reti = taosThreadRwlockWrlock(&rwlock);
EXPECT_EQ(reti, 0);
reti = taosThreadRwlockUnlock(&rwlock);
EXPECT_EQ(reti, 0);
reti = taosThreadRwlockDestroy(NULL);
EXPECT_NE(reti, 0);
reti = taosThreadRwlockDestroy(&rwlock);
EXPECT_EQ(reti, 0);
} }
TEST(osThreadTests, rdlockAttr) { TEST(osThreadTests, rdlockAttr) {