From 0621a9e88ecc227c365c8bad6273c4ca41916d0f Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 21 Dec 2022 13:28:44 +0800 Subject: [PATCH] make jenkins happy --- src/rpc/src/rpcMain.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c index 98cb1850d1..c53062a98a 100644 --- a/src/rpc/src/rpcMain.c +++ b/src/rpc/src/rpcMain.c @@ -1533,13 +1533,14 @@ static void rpcProcessConnError(void *param, void *id) { rpcMsg.pCont = NULL; rpcMsg.contLen = 0; - if( pContext->numOfTry >= pContext->epSet.numOfEps && rpcMsg.code == TSDB_CODE_RPC_NETWORK_UNAVAIL) { - if(pContext->msgType == TSDB_MSG_TYPE_SUBMIT || pContext->msgType == TSDB_MSG_TYPE_QUERY) { + if (pContext->numOfTry >= pContext->epSet.numOfEps && rpcMsg.code == TSDB_CODE_RPC_NETWORK_UNAVAIL) { + if (pContext->msgType == TSDB_MSG_TYPE_SUBMIT || pContext->msgType == TSDB_MSG_TYPE_QUERY) { rpcMsg.code = TSDB_CODE_RPC_VGROUP_NOT_CONNECTED; } } - tWarn("%s %p, connection error. notify client query over. numOfTry=%d msgType=%d", pRpc->label, pContext->ahandle, pContext->numOfTry, pContext->msgType); + tWarn("%s %p, connection error. notify client query over. numOfTry=%d msgType=%d", pRpc->label, pContext->ahandle, + pContext->numOfTry, pContext->msgType); rpcNotifyClient(pContext, &rpcMsg); } else { @@ -1936,7 +1937,6 @@ bool rpcSaveSendInfo(int64_t rpcRid, void **ppContext) { } if (ppContext) *ppContext = pContext; - taosReleaseRef(tsRpcRefId, rpcRid); return true; } -- GitLab