From a367e6a0d3b4e8b09a5c655e7050c7e2f9c56177 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sat, 24 Aug 2024 18:04:15 +0800 Subject: [PATCH] refactor transport --- source/libs/transport/src/transCli.c | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 12022f495f..9a0f5fa450 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -872,7 +872,7 @@ static int32_t cliGetConnFromPool(SCliThrd* pThrd, const char* key, SCliConn** p } // code -static int32_t cliGetConnOrCreate(SCliThrd* pThrd, SCliReq* pReq, SCliConn** pConn) { +static int32_t cliGetOrCreateConn(SCliThrd* pThrd, SCliReq* pReq, SCliConn** pConn) { // impl later char* fqdn = EPSET_GET_INUSE_IP(&pReq->ctx->epSet); uint16_t port = EPSET_GET_INUSE_PORT(&pReq->ctx->epSet); @@ -2190,7 +2190,7 @@ void cliHandleReq__noShareConn(SCliThrd* pThrd, SCliReq* pReq) { STrans* pInst = pThrd->pInst; SCliConn* pConn = NULL; - code = cliGetConnOrCreate(pThrd, pReq, &pConn); + code = cliGetOrCreateConn(pThrd, pReq, &pConn); if (code == TSDB_CODE_RPC_MAX_SESSIONS) { TAOS_CHECK_GOTO(code, &lino, _exception); } else if (code == TSDB_CODE_RPC_ASYNC_IN_PROCESS) { @@ -2201,7 +2201,6 @@ void cliHandleReq__noShareConn(SCliThrd* pThrd, SCliReq* pReq) { tTrace("%s conn %p ready", pInst->label, pConn); _exception: - resp.code = code; (void)(pThrd->notifyExceptCb)(pThrd, pReq, &resp); return;