From dc0318af62f2191bb53acc03243d44c715359b46 Mon Sep 17 00:00:00 2001 From: boyce Date: Fri, 18 Dec 2020 18:18:12 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96rpc=E7=9A=84Call=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc/rpchandler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rpc/rpchandler.go b/rpc/rpchandler.go index 577f49e..2e4aef2 100644 --- a/rpc/rpchandler.go +++ b/rpc/rpchandler.go @@ -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 }