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

refactor transport

This commit is contained in:
yihaoDeng 2024-08-24 18:04:15 +08:00
parent a78a8c1230
commit a367e6a0d3
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -872,7 +872,7 @@ static int32_t cliGetConnFromPool(SCliThrd* pThrd, const char* key, SCliConn** p
} }
// code // code
static int32_t cliGetConnOrCreate(SCliThrd* pThrd, SCliReq* pReq, SCliConn** pConn) { static int32_t cliGetOrCreateConn(SCliThrd* pThrd, SCliReq* pReq, SCliConn** pConn) {
// impl later // impl later
char* fqdn = EPSET_GET_INUSE_IP(&pReq->ctx->epSet); char* fqdn = EPSET_GET_INUSE_IP(&pReq->ctx->epSet);
uint16_t port = EPSET_GET_INUSE_PORT(&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; STrans* pInst = pThrd->pInst;
SCliConn* pConn = NULL; SCliConn* pConn = NULL;
code = cliGetConnOrCreate(pThrd, pReq, &pConn); code = cliGetOrCreateConn(pThrd, pReq, &pConn);
if (code == TSDB_CODE_RPC_MAX_SESSIONS) { if (code == TSDB_CODE_RPC_MAX_SESSIONS) {
TAOS_CHECK_GOTO(code, &lino, _exception); TAOS_CHECK_GOTO(code, &lino, _exception);
} else if (code == TSDB_CODE_RPC_ASYNC_IN_PROCESS) { } 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); tTrace("%s conn %p ready", pInst->label, pConn);
_exception: _exception:
resp.code = code; resp.code = code;
(void)(pThrd->notifyExceptCb)(pThrd, pReq, &resp); (void)(pThrd->notifyExceptCb)(pThrd, pReq, &resp);
return; return;