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

invalid read

This commit is contained in:
yihaoDeng 2024-09-29 19:21:55 +08:00
parent 74b6e98b76
commit ed01ae09c6
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/transport/src/transCli.c
View File

@ -2110,7 +2110,7 @@ _err:
} }
int32_t initCb(void* thrd, SCliReq* pReq, STransMsg* pResp) { int32_t initCb(void* thrd, SCliReq* pReq, STransMsg* pResp) {
SCliThrd* pThrd = thrd; SCliThrd* pThrd = thrd;
if (pReq->ctx == NULL) { if (pReq->ctx == NULL || pReq->ctx->epSet == NULL) {
return 0; return 0;
} }
return cliMayCvtFqdnToIp(pReq->ctx->epSet, pThrd->pCvtAddr); return cliMayCvtFqdnToIp(pReq->ctx->epSet, pThrd->pCvtAddr);
@ -2699,7 +2699,7 @@ void cliMayResetRespCode(SCliReq* pReq, STransMsg* pResp) {
} }
// check whole vnodes is offline on this vgroup // check whole vnodes is offline on this vgroup
if (pCtx->epsetRetryCnt >= pCtx->epSet->numOfEps || pCtx->retryStep > 0) { if (((pCtx->epSet != NULL) && pCtx->epsetRetryCnt >= pCtx->epSet->numOfEps) || pCtx->retryStep > 0) {
if (pResp->code == TSDB_CODE_RPC_NETWORK_UNAVAIL) { if (pResp->code == TSDB_CODE_RPC_NETWORK_UNAVAIL) {
pResp->code = TSDB_CODE_RPC_SOMENODE_NOT_CONNECTED; pResp->code = TSDB_CODE_RPC_SOMENODE_NOT_CONNECTED;
} else if (pResp->code == TSDB_CODE_RPC_BROKEN_LINK) { } else if (pResp->code == TSDB_CODE_RPC_BROKEN_LINK) {