diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c index 3e83293a2faf9177baff30d1b70a9f0ad40d674a..8dbbb97a1af438049adb40c12b2b6bec466dcb6e 100755 --- a/src/rpc/src/rpcMain.c +++ b/src/rpc/src/rpcMain.c @@ -840,7 +840,7 @@ static void rpcProcessBrokenLink(SRpcConn *pConn) { rpcMsg.handle = pConn; rpcMsg.msgType = pConn->inType; rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL; - (*(pRpc->cfp))(&rpcMsg); + // (*(pRpc->cfp))(&rpcMsg); } rpcCloseConn(pConn); @@ -1169,7 +1169,7 @@ static void rpcProcessIdleTimer(void *param, void *tmrId) { rpcMsg.handle = pConn; rpcMsg.msgType = pConn->inType; rpcMsg.code = TSDB_CODE_NETWORK_UNAVAIL; - (*(pRpc->cfp))(&rpcMsg); + // (*(pRpc->cfp))(&rpcMsg); } rpcCloseConn(pConn); } else {