xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix invalid timeout

This commit is contained in:
yihaoDeng 2024-09-23 17:05:22 +08:00
parent b3ad84d7cf
commit 97e60cefee
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/transport/src/transCli.c
View File

@ -632,8 +632,8 @@ void cliConnTimeout(uv_timer_t* handle) {
cliResetConnTimer(conn); cliResetConnTimer(conn);
return; return;
} }
tTrace("%s conn %p conn timeout", CONN_GET_INST_LABEL(conn), conn); tTrace("%s conn %p conn timeout", CONN_GET_INST_LABEL(conn), conn);
TAOS_UNUSED(transUnrefCliHandle(conn));
} }
bool filterToRmTimoutReq(void* key, void* arg) { 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); TAOS_CHECK_GOTO(TSDB_CODE_THIRDPARTY_ERROR, &lino, _exception1);
} }
conn->registered = 1;
transRefCliHandle(conn); transRefCliHandle(conn);
ret = uv_timer_start(conn->timer, cliConnTimeout, TRANS_CONN_TIMEOUT, 0); ret = uv_timer_start(conn->timer, cliConnTimeout, TRANS_CONN_TIMEOUT, 0);
if (ret != 0) { if (ret != 0) {
tError("%s conn %p failed to start timer, reason:%s", transLabel(pInst), conn, uv_err_name(ret)); 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); TAOS_CHECK_GOTO(TSDB_CODE_THIRDPARTY_ERROR, &lino, _exception2);
} }
conn->registered = 1;
return TSDB_CODE_RPC_ASYNC_IN_PROCESS; return TSDB_CODE_RPC_ASYNC_IN_PROCESS;
_exception1: _exception1: