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 17:37:42 +08:00
parent 12b560e6db
commit cf23956f4f
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -398,6 +398,9 @@ void destroyCliConnQTable(SCliConn* conn) {
STransCtx* ctx = pIter;
transCtxCleanup(ctx);
pIter = taosHashIterate(conn->pQTable, pIter);
transReleaseExHandle(transGetRefMgt(), *qid);
transRemoveExHandle(transGetRefMgt(), *qid);
}
taosHashCleanup(conn->pQTable);
conn->pQTable = NULL;
@ -1037,7 +1040,7 @@ static void cliDestroy(uv_handle_t* handle) {
int64_t* qid = taosHashGetKey(pIter, NULL);
(void)taosHashRemove(pThrd->pIdConnTable, qid, sizeof(*qid));
pIter = taosHashIterate(conn->pQTable, pIter);
tDebug("%s conn %p destroy state %ld", CONN_GET_INST_LABEL(conn), conn, *qid);
tDebug("%s conn %p destroy state %" PRId64 "", CONN_GET_INST_LABEL(conn), conn, *qid);
}
destroyCliConnQTable(conn);