修复call没找到对应service，卡死不正常返回问题

2026-02-03 22:45:13 +08:00 · 2020-06-29 22:58:27 +08:00
parent 824a83c7ed
commit 500b3908e0
1 changed files with 3 additions and 0 deletions
--- a/rpc/rpchandler.go
+++ b/rpc/rpchandler.go
@@ -362,6 +362,9 @@ func (slf *RpcHandler) callRpc(nodeId int,serviceMethod string,args interface{},

 	//跨node调用
 	pCall := pClient.Go(false,serviceMethod,args,reply)
+	if pCall.Err != nil {
+		return pCall.Err
+	}
 	pResult := pCall.Done()
 	return pResult.Err
 }