connection is cache has already been released because of the broken link

f091d8f5 · 陶建辉(Jeff) · f8a6ca0a · f091d8f5
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

src/rpc/src/rpcMain.c src/rpc/src/rpcMain.c +1 -1

未找到文件。
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -658,7 +658,7 @@ static SRpcConn *rpcSetupConnToServer(SRpcReqContext *pContext) {
  SRpcIpSet  *pIpSet = &pContext->ipSet;
  pConn = rpcGetConnFromCache(pRpc->pCache, pIpSet->ip[pIpSet->inUse], pIpSet->port, pContext->connType);
-  if ( pConn == NULL ) {
+  if ( pConn == NULL || pConn->user[0] == 0) {
    char ipstr[20] = {0};
    tinet_ntoa(ipstr, pIpSet->ip[pIpSet->inUse]);
    pConn = rpcOpenConn(pRpc, ipstr, pIpSet->port, pContext->connType);