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

refactor transport code

This commit is contained in:
yihaoDeng 2024-08-08 09:23:34 +08:00
parent 66753111c9
commit 6905cc47ed
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/client/src/clientEnv.c
View File

@ -374,7 +374,7 @@ int32_t openTransporter(const char *user, const char *auth, int32_t numOfThread,
*pDnodeConn = rpcOpen(&rpcInit);
if (*pDnodeConn == NULL) {
tscError("failed to init connection to server.");
tscError("failed to init connection to server since %s", tstrerror(terrno));
code = terrno;
}

2
source/client/src/clientImpl.c
View File

@ -2468,7 +2468,7 @@ TSDB_SERVER_STATUS taos_check_server_status(const char* fqdn, int port, char* de
clientRpc = rpcOpen(&rpcInit);
if (clientRpc == NULL) {
code = terrno;
tscError("failed to init server status client");
tscError("failed to init server status client since %s", tstrerror(code));
goto _OVER;
}

8
source/dnode/mgmt/node_mgmt/src/dmTransport.c
View File

@ -392,7 +392,7 @@ int32_t dmInitClient(SDnode *pDnode) {
pTrans->clientRpc = rpcOpen(&rpcInit);
if (pTrans->clientRpc == NULL) {
dError("failed to init dnode rpc client");
dError("failed to init dnode rpc client since:%s", tstrerror(terrno));
return terrno;
}
@ -436,7 +436,7 @@ int32_t dmInitStatusClient(SDnode *pDnode) {
pTrans->statusRpc = rpcOpen(&rpcInit);
if (pTrans->statusRpc == NULL) {
dError("failed to init dnode rpc status client");
dError("failed to init dnode rpc status client since %s", tstrerror(terrno));
return terrno;
}
@ -481,7 +481,7 @@ int32_t dmInitSyncClient(SDnode *pDnode) {
pTrans->syncRpc = rpcOpen(&rpcInit);
if (pTrans->syncRpc == NULL) {
dError("failed to init dnode rpc sync client");
dError("failed to init dnode rpc sync client since %s", tstrerror(terrno));
return terrno;
}
@ -531,7 +531,7 @@ int32_t dmInitServer(SDnode *pDnode) {
(void)taosVersionStrToInt(version, &(rpcInit.compatibilityVer));
pTrans->serverRpc = rpcOpen(&rpcInit);
if (pTrans->serverRpc == NULL) {
dError("failed to init dnode rpc server");
dError("failed to init dnode rpc server since:%s", tstrerror(terrno));
return terrno;
}