commit
42b9afbe89
|
@ -1656,6 +1656,9 @@ static void cliHandleFreeById(SCliMsg* pMsg, SCliThrd* pThrd) {
|
||||||
// already recv, and notify upper layer
|
// already recv, and notify upper layer
|
||||||
TAOS_CHECK_GOTO(TSDB_CODE_REF_INVALID_ID, NULL, _exception);
|
TAOS_CHECK_GOTO(TSDB_CODE_REF_INVALID_ID, NULL, _exception);
|
||||||
} else {
|
} else {
|
||||||
|
destroyCmsg(pMsg);
|
||||||
|
(void)transReleaseExHandle(transGetRefMgt(), refId);
|
||||||
|
|
||||||
while (T_REF_VAL_GET(conn) >= 1) {
|
while (T_REF_VAL_GET(conn) >= 1) {
|
||||||
transUnrefCliHandle(conn);
|
transUnrefCliHandle(conn);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue