Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-13 23:24:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

升级为protobuf3

Browse Source
This commit is contained in:
boyce
2020-12-10 15:50:42 +08:00
parent 96b983a7cf
commit e2a156473b
3 changed files with 122 additions and 212 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
rpc/pbprocessor.go
View File

@@ -23,17 +23,17 @@ func init(){
}
func (slf *PBRpcRequestData) MakeRequest(seq uint64,serviceMethod string,noReply bool,inParam []byte) *PBRpcRequestData{
slf.Seq = proto.Uint64(seq)
slf.ServiceMethod = proto.String(serviceMethod)
slf.NoReply = proto.Bool(noReply)
slf.Seq = seq
slf.ServiceMethod = serviceMethod
slf.NoReply = noReply
slf.InParam = inParam
return slf
}
func (slf *PBRpcResponseData) MakeRespone(seq uint64,err RpcError,reply []byte) *PBRpcResponseData{
slf.Seq = proto.Uint64(seq)
slf.Error = proto.String(err.Error())
slf.Seq = seq
slf.Error = err.Error()
slf.Reply = reply
return slf