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()) }