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

update fqdn cache

This commit is contained in:
yihaoDeng 2024-11-06 15:55:42 +08:00
parent aa8bc83791
commit 0a9d1d8ff7
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -620,7 +620,7 @@ int32_t cliHandleState_mayCreateAhandle(SCliConn* conn, STransMsgHead* pHead, ST
int32_t code = 0; int32_t code = 0;
int64_t qId = taosHton64(pHead->qid); int64_t qId = taosHton64(pHead->qid);
if (qId == 0) { if (qId == 0) {
return 0; return TSDB_CODE_RPC_NO_STATE;
} }
STransCtx* pCtx = taosHashGet(conn->pQTable, &qId, sizeof(qId)); STransCtx* pCtx = taosHashGet(conn->pQTable, &qId, sizeof(qId));
@ -1608,7 +1608,6 @@ static int32_t cliDoConn(SCliThrd* pThrd, SCliConn* conn) {
ret = uv_tcp_connect(&conn->connReq, (uv_tcp_t*)(conn->stream), (const struct sockaddr*)&addr, cliConnCb); ret = uv_tcp_connect(&conn->connReq, (uv_tcp_t*)(conn->stream), (const struct sockaddr*)&addr, cliConnCb);
if (ret != 0) { if (ret != 0) {
tError("failed connect to %s since %s", conn->dstAddr, uv_err_name(ret)); tError("failed connect to %s since %s", conn->dstAddr, uv_err_name(ret));
if (ret == )
cliMayUpdateFqdnCache(pThrd->fqdn2ipCache, conn->dstAddr); cliMayUpdateFqdnCache(pThrd->fqdn2ipCache, conn->dstAddr);
TAOS_CHECK_GOTO(TSDB_CODE_THIRDPARTY_ERROR, &lino, _exception1); TAOS_CHECK_GOTO(TSDB_CODE_THIRDPARTY_ERROR, &lino, _exception1);
} }