From 6225f7fa2ff8fffdee9e0f3bbb7d036ffee92c1f Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao@163.com> Date: Thu, 19 Sep 2024 13:47:20 +0800 Subject: [PATCH] fix(stream):use terrno --- source/libs/stream/src/streamUpdate.c | 4 ++-- source/libs/stream/src/tstreamFileState.c | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/source/libs/stream/src/streamUpdate.c b/source/libs/stream/src/streamUpdate.c index 2acb0f88af..d5adbcee77 100644 --- a/source/libs/stream/src/streamUpdate.c +++ b/source/libs/stream/src/streamUpdate.c @@ -631,10 +631,10 @@ int32_t updateInfoDeserialize(void* buf, int32_t bufLen, SUpdateInfo* pInfo) { if (tDecodeI8(&decoder, &pInfo->pkColType) < 0) return -1; pInfo->pKeyBuff = taosMemoryCalloc(1, sizeof(TSKEY) + sizeof(int64_t) + pInfo->pkColLen); - QUERY_CHECK_NULL(pInfo->pKeyBuff, code, lino, _error, errno); + QUERY_CHECK_NULL(pInfo->pKeyBuff, code, lino, _error, terrno); pInfo->pValueBuff = taosMemoryCalloc(1, sizeof(TSKEY) + pInfo->pkColLen); - QUERY_CHECK_NULL(pInfo->pValueBuff, code, lino, _error, errno); + QUERY_CHECK_NULL(pInfo->pValueBuff, code, lino, _error, terrno); if (pInfo->pkColLen != 0) { pInfo->comparePkRowFn = compareKeyTsAndPk; diff --git a/source/libs/stream/src/tstreamFileState.c b/source/libs/stream/src/tstreamFileState.c index e1c7294185..5626aa29da 100644 --- a/source/libs/stream/src/tstreamFileState.c +++ b/source/libs/stream/src/tstreamFileState.c @@ -494,7 +494,7 @@ SRowBuffPos* getNewRowPos(SStreamFileState* pFileState) { if (pFileState->curRowCount < pFileState->maxRowCount) { pBuff = taosMemoryCalloc(1, pFileState->rowSize); - QUERY_CHECK_NULL(pBuff, code, lino, _error, errno); + QUERY_CHECK_NULL(pBuff, code, lino, _error, terrno); pPos->pRowBuff = pBuff; pFileState->curRowCount++; goto _end; @@ -725,7 +725,7 @@ void flushSnapshot(SStreamFileState* pFileState, SStreamSnapshot* pSnapshot, boo } void* pSKey = pFileState->stateBuffCreateStateKeyFn(pPos, ((SStreamState*)pFileState->pFileStore)->number); - QUERY_CHECK_NULL(pSKey, code, lino, _end, errno); + QUERY_CHECK_NULL(pSKey, code, lino, _end, terrno); code = streamStatePutBatchOptimize(pFileState->pFileStore, idx, batch, pSKey, pPos->pRowBuff, pFileState->rowSize, 0, buf);