From 51b90819cae6abc29b9449bd6b35b471a30558f4 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sun, 28 Jul 2024 16:07:06 +0800 Subject: [PATCH] fix(test): fix syntax error. --- source/dnode/mnode/impl/test/stream/stream.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/dnode/mnode/impl/test/stream/stream.cpp b/source/dnode/mnode/impl/test/stream/stream.cpp index 0a1e9a0059..407163ae91 100644 --- a/source/dnode/mnode/impl/test/stream/stream.cpp +++ b/source/dnode/mnode/impl/test/stream/stream.cpp @@ -213,7 +213,7 @@ TEST_F(StreamTest, kill_checkpoint_trans) { const char* pDbName = "test_db_name"; 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); killAllCheckpointTrans(pMnode, &info); @@ -236,7 +236,7 @@ TEST_F(StreamTest, kill_checkpoint_trans) { pTask->id.streamId = defStreamId; pTask->id.taskId = 1; pTask->exec.qmsg = (char*)taosMemoryCalloc(1,1); - int32_t code = taosThreadMutexInit(&pTask->lock, NULL); + code = taosThreadMutexInit(&pTask->lock, NULL); ASSERT(code == 0); void* px = taosArrayPush(pLevel, &pTask); @@ -245,7 +245,7 @@ TEST_F(StreamTest, kill_checkpoint_trans) { px = taosArrayPush(pStream->tasks, &pLevel); ASSERT(px != NULL); - int32_t code = mndCreateStreamResetStatusTrans(pMnode, pStream); + code = mndCreateStreamResetStatusTrans(pMnode, pStream); ASSERT(code == 0); tFreeStreamObj(pStream);