From 77988906f8b67d65376b0dbbf78c206193de62ef Mon Sep 17 00:00:00 2001 From: orgin Date: Thu, 30 Jun 2022 17:56:16 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E8=AE=B0=E5=BD=95rpc?= =?UTF-8?q?=E7=9A=84=E6=96=B9=E6=B3=95=E5=90=8D=E7=A7=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rpc/server.go b/rpc/server.go index 498db9d..df56baa 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -338,7 +338,7 @@ func (server *Server) selfNodeRpcHandlerAsyncGo(client *Client, callerRpcHandler pCall.rpcHandler = callerRpcHandler pCall.callback = &callback pCall.Reply = reply - + pCall.ServiceMethod = serviceMethod client.AddPending(pCall) req.requestHandle = func(Returns interface{}, Err RpcError) { v := client.RemovePending(callSeq)