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

fix(test): fix syntax error.

This commit is contained in:
Haojun Liao 2024-07-28 16:07:06 +08:00
parent 7fbb76b441
commit 51b90819ca
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/dnode/mnode/impl/test/stream/stream.cpp
View File

@ -213,7 +213,7 @@ TEST_F(StreamTest, kill_checkpoint_trans) {
const char* pDbName = "test_db_name"; const char* pDbName = "test_db_name";
int32_t len = strlen(pDbName); int32_t len = strlen(pDbName);
int32_t code = taosHashPut(info.pDBMap, pDbName, len, NULL, 0); code = taosHashPut(info.pDBMap, pDbName, len, NULL, 0);
ASSERT(code == 0); ASSERT(code == 0);
killAllCheckpointTrans(pMnode, &info); killAllCheckpointTrans(pMnode, &info);
@ -236,7 +236,7 @@ TEST_F(StreamTest, kill_checkpoint_trans) {
pTask->id.streamId = defStreamId; pTask->id.streamId = defStreamId;
pTask->id.taskId = 1; pTask->id.taskId = 1;
pTask->exec.qmsg = (char*)taosMemoryCalloc(1,1); pTask->exec.qmsg = (char*)taosMemoryCalloc(1,1);
int32_t code = taosThreadMutexInit(&pTask->lock, NULL); code = taosThreadMutexInit(&pTask->lock, NULL);
ASSERT(code == 0); ASSERT(code == 0);
void* px = taosArrayPush(pLevel, &pTask); void* px = taosArrayPush(pLevel, &pTask);
@ -245,7 +245,7 @@ TEST_F(StreamTest, kill_checkpoint_trans) {
px = taosArrayPush(pStream->tasks, &pLevel); px = taosArrayPush(pStream->tasks, &pLevel);
ASSERT(px != NULL); ASSERT(px != NULL);
int32_t code = mndCreateStreamResetStatusTrans(pMnode, pStream); code = mndCreateStreamResetStatusTrans(pMnode, pStream);
ASSERT(code == 0); ASSERT(code == 0);
tFreeStreamObj(pStream); tFreeStreamObj(pStream);