This commit is contained in:
boyce
2020-07-03 19:30:11 +08:00
2 changed files with 31 additions and 2 deletions

View File

@@ -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
}