From a69010c31d465c28737ab6d38b69f8fa398a20f6 Mon Sep 17 00:00:00 2001 From: lifeiyi <736926938@qq.com> Date: Wed, 8 Jul 2020 17:11:27 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DRPC=E4=BD=BF=E7=94=A8protobuf?= =?UTF-8?q?=E4=B8=8D=E8=83=BD=E6=AD=A3=E5=B8=B8=E8=BF=94=E5=9B=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc/pbprocessor.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/rpc/pbprocessor.go b/rpc/pbprocessor.go index 561a784..9e5b77c 100644 --- a/rpc/pbprocessor.go +++ b/rpc/pbprocessor.go @@ -17,7 +17,9 @@ func (slf *PBRpcRequestData) MakeRequest(seq uint64,serviceMethod string,noReply func (slf *PBRpcResponseData) MakeRespone(seq uint64,err *RpcError,reply []byte) *PBRpcResponseData{ slf.Seq = proto.Uint64(seq) - slf.Error = proto.String(err.Error()) + if err != nil { + slf.Error = proto.String(err.Error()) + } slf.Reply = reply return slf @@ -45,6 +47,9 @@ func (slf *PBRpcRequestData) IsReply() bool{ } func (slf *PBRpcResponseData) GetErr() *RpcError { + if slf.GetError() == "" { + return nil + } return Errorf(slf.GetError()) }