feat: refactor rpc quit

8cbb7bc7 · dengyihao · 411d30f3 · 8cbb7bc7
隐藏空白更改
内联并排

Showing with 2 addition and 2 deletion

source/libs/transport/src/transCli.c source/libs/transport/src/transCli.c +2 -2

未找到文件。
--- a/source/libs/transport/src/transCli.c
+++ b/source/libs/transport/src/transCli.c
@@ -1013,8 +1013,8 @@ int cliAppCb(SCliConn* pConn, STransMsg* pResp, SCliMsg* pMsg) {
               pCtx->retryCount + 1, TRANS_RETRY_COUNT_LIMIT);
      }
      if (pThrd->quit == false) {
-        if (pConn->status != ConnInPool && pResp->code != TSDB_CODE_RPC_NETWORK_UNAVAIL) {
+        if (pResp->code != TSDB_CODE_RPC_NETWORK_UNAVAIL) {
-          addConnToPool(pThrd->pool, pConn);
+          if (pConn->status != ConnInPool) addConnToPool(pThrd->pool, pConn);
        } else {
          transUnrefCliHandle(pConn);
        }