From a43b866fabfd92e041a763b6767ce6f6578d4671 Mon Sep 17 00:00:00 2001 From: dmchen Date: Tue, 30 Jul 2024 02:38:12 +0000 Subject: [PATCH] fix/TD-30989 --- source/dnode/mnode/impl/src/mndMain.c | 10 +++++----- source/dnode/mnode/impl/src/mndProfile.c | 4 ++-- source/dnode/mnode/impl/src/mndStb.c | 2 +- source/libs/sync/src/syncMain.c | 2 +- 4 files changed, 9 insertions(+), 9 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndMain.c b/source/dnode/mnode/impl/src/mndMain.c index 4f195227a2..7e072b8fe5 100644 --- a/source/dnode/mnode/impl/src/mndMain.c +++ b/source/dnode/mnode/impl/src/mndMain.c @@ -716,9 +716,9 @@ SMnode *mndOpen(const char *path, const SMnodeOpt *pOption) { void mndPreClose(SMnode *pMnode) { if (pMnode != NULL) { // TODO check return value - syncLeaderTransfer(pMnode->syncMgmt.sync); + (void)syncLeaderTransfer(pMnode->syncMgmt.sync); syncPreStop(pMnode->syncMgmt.sync); - sdbWriteFile(pMnode->pSdb, 0); + (void)sdbWriteFile(pMnode->pSdb, 0); } } @@ -1106,12 +1106,12 @@ int64_t mndGetRoleTimeMs(SMnode *pMnode) { void mndSetRestored(SMnode *pMnode, bool restored) { if (restored) { - taosThreadRwlockWrlock(&pMnode->lock); + (void)taosThreadRwlockWrlock(&pMnode->lock); pMnode->restored = true; (void)taosThreadRwlockUnlock(&pMnode->lock); mInfo("mnode set restored:%d", restored); } else { - taosThreadRwlockWrlock(&pMnode->lock); + (void)taosThreadRwlockWrlock(&pMnode->lock); pMnode->restored = false; (void)taosThreadRwlockUnlock(&pMnode->lock); mInfo("mnode set restored:%d", restored); @@ -1125,7 +1125,7 @@ void mndSetRestored(SMnode *pMnode, bool restored) { bool mndGetRestored(SMnode *pMnode) { return pMnode->restored; } void mndSetStop(SMnode *pMnode) { - taosThreadRwlockWrlock(&pMnode->lock); + (void)taosThreadRwlockWrlock(&pMnode->lock); pMnode->stopped = true; (void)taosThreadRwlockUnlock(&pMnode->lock); mInfo("mnode set stopped"); diff --git a/source/dnode/mnode/impl/src/mndProfile.c b/source/dnode/mnode/impl/src/mndProfile.c index ad3ed2e62f..d8bfb6c2a7 100644 --- a/source/dnode/mnode/impl/src/mndProfile.c +++ b/source/dnode/mnode/impl/src/mndProfile.c @@ -575,7 +575,7 @@ static int32_t mndProcessQueryHeartBeat(SMnode *pMnode, SRpcMsg *pMsg, SClientHb if (needCheck) { SKv kv1 = {.key = HEARTBEAT_KEY_DYN_VIEW, .valueLen = sizeof(*pDynViewVer), .value = pRspVer}; - taosArrayPush(hbRsp.info, &kv1); + TAOS_CHECK_RETURN(taosArrayPush(hbRsp.info, &kv1)); mTrace("need to check view ver, lastest bootTs:%" PRId64 ", ver:%" PRIu64, pRspVer->svrBootTs, pRspVer->dynViewVer); } @@ -703,7 +703,7 @@ static int32_t mndProcessHeartBeatReq(SRpcMsg *pReq) { } else if (pHbReq->connKey.connType == CONN_TYPE__TMQ) { SClientHbRsp *pRsp = mndMqHbBuildRsp(pMnode, pHbReq); if (pRsp != NULL) { - taosArrayPush(batchRsp.rsps, pRsp); + (void)taosArrayPush(batchRsp.rsps, pRsp); taosMemoryFree(pRsp); } } diff --git a/source/dnode/mnode/impl/src/mndStb.c b/source/dnode/mnode/impl/src/mndStb.c index 3204c70db5..a76dfa1b51 100644 --- a/source/dnode/mnode/impl/src/mndStb.c +++ b/source/dnode/mnode/impl/src/mndStb.c @@ -2629,7 +2629,7 @@ static int32_t mndProcessAlterStbReq(SRpcMsg *pReq) { SName name = {0}; // TODO check return value - tNameFromString(&name, alterReq.name, T_NAME_ACCT | T_NAME_DB | T_NAME_TABLE); + (void)tNameFromString(&name, alterReq.name, T_NAME_ACCT | T_NAME_DB | T_NAME_TABLE); auditRecord(pReq, pMnode->clusterId, "alterStb", name.dbname, name.tname, alterReq.sql, alterReq.sqlLen); diff --git a/source/libs/sync/src/syncMain.c b/source/libs/sync/src/syncMain.c index 67eb09418c..171b73eba7 100644 --- a/source/libs/sync/src/syncMain.c +++ b/source/libs/sync/src/syncMain.c @@ -181,7 +181,7 @@ int32_t syncReconfig(int64_t rid, SSyncCfg* pNewCfg) { TAOS_RETURN(code); } - syncNodeUpdateNewConfigIndex(pSyncNode, pNewCfg); + TAOS_CHECK_RETURN(syncNodeUpdateNewConfigIndex(pSyncNode, pNewCfg)); syncNodeDoConfigChange(pSyncNode, pNewCfg, pNewCfg->lastIndex); if (pSyncNode->state == TAOS_SYNC_STATE_LEADER || pSyncNode->state == TAOS_SYNC_STATE_ASSIGNED_LEADER) {