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

Merge branch '3.0' into enh/opt-transport

This commit is contained in:
yihaoDeng 2024-09-16 18:13:32 +08:00
parent ef0c301a6a
commit ff1ac62183
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1615,7 +1615,7 @@ int32_t cliMayGetStateByQid(SCliThrd* pThrd, SCliReq* pReq, SCliConn** pConn) {
} else { } else {
SExHandle* exh = transAcquireExHandle(transGetRefMgt(), qid); SExHandle* exh = transAcquireExHandle(transGetRefMgt(), qid);
if (exh == NULL) { if (exh == NULL) {
return TSDB_CODE_RPC_NO_STATE; return TSDB_CODE_RPC_STATE_DROPED;
} }
SReqState* pState = taosHashGet(pThrd->pIdConnTable, &qid, sizeof(qid)); SReqState* pState = taosHashGet(pThrd->pIdConnTable, &qid, sizeof(qid));
@ -1667,9 +1667,7 @@ void cliHandleBatchReq(SCliThrd* pThrd, SCliReq* pReq) {
if (code == 0) { if (code == 0) {
(void)cliHandleState_mayUpdateStateCtx(pConn, pReq); (void)cliHandleState_mayUpdateStateCtx(pConn, pReq);
} else if (code == TSDB_CODE_RPC_STATE_DROPED) { } else if (code == TSDB_CODE_RPC_STATE_DROPED) {
STraceId* trace = &pReq->msg.info.traceId; TAOS_CHECK_GOTO(code, &lino, _exception);
tWarn("%s failed to get statue, qid:%" PRId64 "", pInst->label, pReq->msg.info.qId);
destroyReq(pReq);
return; return;
} }