From f98f39d470af71b0366ff55429e1ec9e64dc2b80 Mon Sep 17 00:00:00 2001 From: boyce Date: Thu, 12 Nov 2020 20:11:15 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=86=85=E5=AD=98=E6=B1=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc/rpc.go | 5 ++++- rpc/server.go | 6 +++++- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/rpc/rpc.go b/rpc/rpc.go index dc425b1..7378ec3 100644 --- a/rpc/rpc.go +++ b/rpc/rpc.go @@ -104,7 +104,10 @@ func (call *Call) Clear() *Call{ call.ServiceMethod = "" call.Reply = nil call.Response = nil - call.done = nil + if len(call.done)>0 { + call.done = make(chan *Call,1) + } + call.Err = nil call.connId = 0 call.callback = nil diff --git a/rpc/server.go b/rpc/server.go index c9411ae..366ab1d 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -268,7 +268,11 @@ func (server *Server) selfNodeRpcHandlerGo(processor IRpcProcessor,client *Clien ReleaseCall(pCall) return } - pCall.Err = Err + if len(Err) == 0 { + pCall.Err = nil + }else{ + pCall.Err = Err + } pCall.done <- pCall } }