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

add ut

This commit is contained in:
54liuyao 2024-12-19 19:24:41 +08:00
parent 5b10753ac0
commit b89532c83c
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/libs/stream/test/streamCheckPointTest.cpp
View File

@ -198,6 +198,11 @@ TEST(ChkptTriggerRecvMonitorHelperTest, chkptTriggerRecvMonitorHelper) {
pTask->chkInfo.pActiveInfo->dispatchTrigger = true; pTask->chkInfo.pActiveInfo->dispatchTrigger = true;
SArray* array1 = NULL; SArray* array1 = NULL;
code = chkptTriggerRecvMonitorHelper(pTask, NULL, &array1); code = chkptTriggerRecvMonitorHelper(pTask, NULL, &array1);
EXPECT_EQ(code, TSDB_CODE_SUCCESS); EXPECT_EQ(code, TSDB_CODE_SUCCESS);
pTask->pMeta->fatalInfo.code = TSDB_CODE_SUCCESS;
streamSetFatalError(pTask->pMeta, code, __func__, __LINE__);
pTask->pMeta->fatalInfo.code = TSDB_CODE_FAILED;
streamSetFatalError(pTask->pMeta, code, __func__, __LINE__);
} }