优化rpc的Call接口

This commit is contained in:
boyce
2020-12-18 18:18:12 +08:00
parent 8da32be256
commit dc0318af62

View File

@@ -450,13 +450,13 @@ func (handler *RpcHandler) callRpc(nodeId int,serviceMethod string,args interfac
//跨node调用
pCall := pClient.Go(false,serviceMethod,args,reply)
pClient.RemovePending(pCall.Seq)
if pCall.Err != nil {
err = pCall.Err
ReleaseCall(pCall)
return err
}
err = pCall.Done().Err
pClient.RemovePending(pCall.Seq)
ReleaseCall(pCall)
return err
}