From 97e60cefeed4809d119dc18b0f6ca704aad470b6 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Mon, 23 Sep 2024 17:05:22 +0800 Subject: [PATCH] fix invalid timeout --- 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 ea0096f7b2..25badedd2d 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -632,8 +632,8 @@ void cliConnTimeout(uv_timer_t* handle) { cliResetConnTimer(conn); return; } - tTrace("%s conn %p conn timeout", CONN_GET_INST_LABEL(conn), conn); + TAOS_UNUSED(transUnrefCliHandle(conn)); } bool filterToRmTimoutReq(void* key, void* arg) { @@ -1363,13 +1363,13 @@ static int32_t cliDoConn(SCliThrd* pThrd, SCliConn* conn) { TAOS_CHECK_GOTO(TSDB_CODE_THIRDPARTY_ERROR, &lino, _exception1); } + conn->registered = 1; transRefCliHandle(conn); ret = uv_timer_start(conn->timer, cliConnTimeout, TRANS_CONN_TIMEOUT, 0); if (ret != 0) { tError("%s conn %p failed to start timer, reason:%s", transLabel(pInst), conn, uv_err_name(ret)); TAOS_CHECK_GOTO(TSDB_CODE_THIRDPARTY_ERROR, &lino, _exception2); } - conn->registered = 1; return TSDB_CODE_RPC_ASYNC_IN_PROCESS; _exception1: