From 6e9bc0cbd9c6d4bd88a572ca877b2ad8286f20bd Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 16 Mar 2022 09:08:42 +0800 Subject: [PATCH] handle except --- source/libs/transport/src/transCli.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 931f58097e..3696e86d22 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -525,6 +525,7 @@ static void cliHandleRelease(SCliMsg* pMsg, SCliThrdObj* pThrd) { transDestroyBuffer(&conn->readBuf); if (conn->persist && T_REF_VAL_GET(conn) >= 2) { + conn->persist = false; transUnrefCliHandle(conn); addConnToPool(pThrd->pool, conn); } else { @@ -746,8 +747,7 @@ void transReleaseCliHandle(void* handle) { } STransMsg tmsg = {.handle = handle}; - - SCliMsg* cmsg = calloc(1, sizeof(SCliMsg)); + SCliMsg* cmsg = calloc(1, sizeof(SCliMsg)); cmsg->type = Release; cmsg->msg = tmsg;