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

Merge remote-tracking branch 'origin/develop' into refactor/cluster

This commit is contained in:
slguan 2020-04-04 13:47:27 +08:00
parent 7f43265b83 5c70e1929c
commit 267e2566b6
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/rpc/src/rpcMain.c
View File

@ -840,7 +840,7 @@ static void rpcProcessBrokenLink(SRpcConn *pConn) {
rpcMsg.handle = pConn; rpcMsg.handle = pConn;
rpcMsg.msgType = pConn->inType; rpcMsg.msgType = pConn->inType;
rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL; rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL;
(*(pRpc->cfp))(&rpcMsg); // (*(pRpc->cfp))(&rpcMsg);
} }
rpcCloseConn(pConn); rpcCloseConn(pConn);
@ -1169,7 +1169,7 @@ static void rpcProcessIdleTimer(void *param, void *tmrId) {
rpcMsg.handle = pConn; rpcMsg.handle = pConn;
rpcMsg.msgType = pConn->inType; rpcMsg.msgType = pConn->inType;
rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL; rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL;
(*(pRpc->cfp))(&rpcMsg); // (*(pRpc->cfp))(&rpcMsg);
} }
rpcCloseConn(pConn); rpcCloseConn(pConn);
} else { } else {