fix invalid read

This commit is contained in:
yihaoDeng 2024-09-19 09:47:48 +08:00
parent 6d3b8c0594
commit 03f30f721f
1 changed files with 3 additions and 2 deletions

View File

@ -1057,11 +1057,10 @@ static void cliDestroy(uv_handle_t* handle) {
} }
taosMemoryFree(conn->buf); taosMemoryFree(conn->buf);
destroyWQ(&conn->wq); destroyWQ(&conn->wq);
(void)transDestroyBuffer(&conn->readBuf);
tTrace("%s conn %p destroy successfully", CONN_GET_INST_LABEL(conn), conn); tTrace("%s conn %p destroy successfully", CONN_GET_INST_LABEL(conn), conn);
(void)transDestroyBuffer(&conn->readBuf);
taosMemoryFree(conn); taosMemoryFree(conn);
} }
@ -1114,6 +1113,8 @@ static void cliHandleException(SCliConn* conn) {
destroyReq(pReq); destroyReq(pReq);
} }
} }
QUEUE_REMOVE(&conn->q);
if (conn->registered) { if (conn->registered) {
int8_t ref = transGetRefCount(conn); int8_t ref = transGetRefCount(conn);
if (ref == 0 && !uv_is_closing((uv_handle_t*)conn->stream)) { if (ref == 0 && !uv_is_closing((uv_handle_t*)conn->stream)) {