From f1eee4a8814b4a4f3f8b06d015f90cef5a3adc67 Mon Sep 17 00:00:00 2001 From: 554325746@qq.com <554325746@qq.com> Date: 星期四, 13 二月 2020 19:56:38 +0800 Subject: [PATCH] mk use gogofaster --- commsg.pb.go | 303 +++++++++++++++++++++++++------------------------ 1 files changed, 155 insertions(+), 148 deletions(-) diff --git a/commsg.pb.go b/commsg.pb.go index 71b8aee..a7d71a1 100644 --- a/commsg.pb.go +++ b/commsg.pb.go @@ -8,6 +8,7 @@ proto "github.com/gogo/protobuf/proto" io "io" math "math" + math_bits "math/bits" ) // Reference imports to suppress errors if they are not otherwise used. @@ -19,7 +20,7 @@ // is compatible with the proto package it is being compiled against. // A compilation error at this line likely means your copy of the // proto package needs to be updated. -const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package +const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package type SdkmsgWithTask struct { Ipcid string `protobuf:"bytes,1,opt,name=ipcid,proto3" json:"ipcid,omitempty"` @@ -41,7 +42,7 @@ return xxx_messageInfo_SdkmsgWithTask.Marshal(b, m, deterministic) } else { b = b[:cap(b)] - n, err := m.MarshalTo(b) + n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } @@ -102,7 +103,7 @@ return xxx_messageInfo_TaskLabel.Marshal(b, m, deterministic) } else { b = b[:cap(b)] - n, err := m.MarshalTo(b) + n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } @@ -171,7 +172,7 @@ return xxx_messageInfo_SdkMessage.Marshal(b, m, deterministic) } else { b = b[:cap(b)] - n, err := m.MarshalTo(b) + n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } @@ -245,7 +246,7 @@ return xxx_messageInfo_Recvmsg.Marshal(b, m, deterministic) } else { b = b[:cap(b)] - n, err := m.MarshalTo(b) + n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } @@ -323,7 +324,7 @@ func (m *SdkmsgWithTask) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) + n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } @@ -331,35 +332,43 @@ } func (m *SdkmsgWithTask) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *SdkmsgWithTask) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.Ipcid) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintCommsg(dAtA, i, uint64(len(m.Ipcid))) - i += copy(dAtA[i:], m.Ipcid) + if len(m.Sdkdata) > 0 { + i -= len(m.Sdkdata) + copy(dAtA[i:], m.Sdkdata) + i = encodeVarintCommsg(dAtA, i, uint64(len(m.Sdkdata))) + i-- + dAtA[i] = 0x22 } if len(m.Sdktype) > 0 { - dAtA[i] = 0x12 - i++ + i -= len(m.Sdktype) + copy(dAtA[i:], m.Sdktype) i = encodeVarintCommsg(dAtA, i, uint64(len(m.Sdktype))) - i += copy(dAtA[i:], m.Sdktype) + i-- + dAtA[i] = 0x12 } - if len(m.Sdkdata) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintCommsg(dAtA, i, uint64(len(m.Sdkdata))) - i += copy(dAtA[i:], m.Sdkdata) + if len(m.Ipcid) > 0 { + i -= len(m.Ipcid) + copy(dAtA[i:], m.Ipcid) + i = encodeVarintCommsg(dAtA, i, uint64(len(m.Ipcid))) + i-- + dAtA[i] = 0xa } - return i, nil + return len(dAtA) - i, nil } func (m *TaskLabel) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) + n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } @@ -367,46 +376,55 @@ } func (m *TaskLabel) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *TaskLabel) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.Taskid) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintCommsg(dAtA, i, uint64(len(m.Taskid))) - i += copy(dAtA[i:], m.Taskid) - } - if len(m.Taskname) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintCommsg(dAtA, i, uint64(len(m.Taskname))) - i += copy(dAtA[i:], m.Taskname) + if m.Index != 0 { + i = encodeVarintCommsg(dAtA, i, uint64(m.Index)) + i-- + dAtA[i] = 0x20 } if len(m.Sdkinfos) > 0 { - for _, msg := range m.Sdkinfos { - dAtA[i] = 0x1a - i++ - i = encodeVarintCommsg(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + for iNdEx := len(m.Sdkinfos) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.Sdkinfos[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintCommsg(dAtA, i, uint64(size)) } - i += n + i-- + dAtA[i] = 0x1a } } - if m.Index != 0 { - dAtA[i] = 0x20 - i++ - i = encodeVarintCommsg(dAtA, i, uint64(m.Index)) + if len(m.Taskname) > 0 { + i -= len(m.Taskname) + copy(dAtA[i:], m.Taskname) + i = encodeVarintCommsg(dAtA, i, uint64(len(m.Taskname))) + i-- + dAtA[i] = 0x12 } - return i, nil + if len(m.Taskid) > 0 { + i -= len(m.Taskid) + copy(dAtA[i:], m.Taskid) + i = encodeVarintCommsg(dAtA, i, uint64(len(m.Taskid))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *SdkMessage) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) + n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } @@ -414,55 +432,67 @@ } func (m *SdkMessage) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *SdkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.Cid) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintCommsg(dAtA, i, uint64(len(m.Cid))) - i += copy(dAtA[i:], m.Cid) - } - if len(m.Caddr) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintCommsg(dAtA, i, uint64(len(m.Caddr))) - i += copy(dAtA[i:], m.Caddr) - } - if m.Tasklab != nil { - dAtA[i] = 0x1a - i++ - i = encodeVarintCommsg(dAtA, i, uint64(m.Tasklab.Size())) - n1, err1 := m.Tasklab.MarshalTo(dAtA[i:]) - if err1 != nil { - return 0, err1 + if m.Push != nil { + { + size, err := m.Push.MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintCommsg(dAtA, i, uint64(size)) } - i += n1 + i-- + dAtA[i] = 0x2a } if len(m.Data) > 0 { - dAtA[i] = 0x22 - i++ + i -= len(m.Data) + copy(dAtA[i:], m.Data) i = encodeVarintCommsg(dAtA, i, uint64(len(m.Data))) - i += copy(dAtA[i:], m.Data) + i-- + dAtA[i] = 0x22 } - if m.Push != nil { - dAtA[i] = 0x2a - i++ - i = encodeVarintCommsg(dAtA, i, uint64(m.Push.Size())) - n2, err2 := m.Push.MarshalTo(dAtA[i:]) - if err2 != nil { - return 0, err2 + if m.Tasklab != nil { + { + size, err := m.Tasklab.MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintCommsg(dAtA, i, uint64(size)) } - i += n2 + i-- + dAtA[i] = 0x1a } - return i, nil + if len(m.Caddr) > 0 { + i -= len(m.Caddr) + copy(dAtA[i:], m.Caddr) + i = encodeVarintCommsg(dAtA, i, uint64(len(m.Caddr))) + i-- + dAtA[i] = 0x12 + } + if len(m.Cid) > 0 { + i -= len(m.Cid) + copy(dAtA[i:], m.Cid) + i = encodeVarintCommsg(dAtA, i, uint64(len(m.Cid))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *Recvmsg) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) + n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } @@ -470,39 +500,49 @@ } func (m *Recvmsg) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *Recvmsg) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.Id) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintCommsg(dAtA, i, uint64(len(m.Id))) - i += copy(dAtA[i:], m.Id) + if len(m.Picdata) > 0 { + i -= len(m.Picdata) + copy(dAtA[i:], m.Picdata) + i = encodeVarintCommsg(dAtA, i, uint64(len(m.Picdata))) + i-- + dAtA[i] = 0x1a } if len(m.Addr) > 0 { - dAtA[i] = 0x12 - i++ + i -= len(m.Addr) + copy(dAtA[i:], m.Addr) i = encodeVarintCommsg(dAtA, i, uint64(len(m.Addr))) - i += copy(dAtA[i:], m.Addr) + i-- + dAtA[i] = 0x12 } - if len(m.Picdata) > 0 { - dAtA[i] = 0x1a - i++ - i = encodeVarintCommsg(dAtA, i, uint64(len(m.Picdata))) - i += copy(dAtA[i:], m.Picdata) + if len(m.Id) > 0 { + i -= len(m.Id) + copy(dAtA[i:], m.Id) + i = encodeVarintCommsg(dAtA, i, uint64(len(m.Id))) + i-- + dAtA[i] = 0xa } - return i, nil + return len(dAtA) - i, nil } func encodeVarintCommsg(dAtA []byte, offset int, v uint64) int { + offset -= sovCommsg(v) + base := offset for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) - return offset + 1 + return base } func (m *SdkmsgWithTask) Size() (n int) { if m == nil { @@ -602,14 +642,7 @@ } func sovCommsg(x uint64) (n int) { - for { - n++ - x >>= 7 - if x == 0 { - break - } - } - return n + return (math_bits.Len64(x|1) + 6) / 7 } func sozCommsg(x uint64) (n int) { return sovCommsg(uint64((x << 1) ^ uint64((int64(x) >> 63)))) @@ -1312,6 +1345,7 @@ func skipCommsg(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 + depth := 0 for iNdEx < l { var wire uint64 for shift := uint(0); ; shift += 7 { @@ -1343,10 +1377,8 @@ break } } - return iNdEx, nil case 1: iNdEx += 8 - return iNdEx, nil case 2: var length int for shift := uint(0); ; shift += 7 { @@ -1367,55 +1399,30 @@ return 0, ErrInvalidLengthCommsg } iNdEx += length - if iNdEx < 0 { - return 0, ErrInvalidLengthCommsg - } - return iNdEx, nil case 3: - for { - var innerWire uint64 - var start int = iNdEx - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return 0, ErrIntOverflowCommsg - } - if iNdEx >= l { - return 0, io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - innerWire |= (uint64(b) & 0x7F) << shift - if b < 0x80 { - break - } - } - innerWireType := int(innerWire & 0x7) - if innerWireType == 4 { - break - } - next, err := skipCommsg(dAtA[start:]) - if err != nil { - return 0, err - } - iNdEx = start + next - if iNdEx < 0 { - return 0, ErrInvalidLengthCommsg - } - } - return iNdEx, nil + depth++ case 4: - return iNdEx, nil + if depth == 0 { + return 0, ErrUnexpectedEndOfGroupCommsg + } + depth-- case 5: iNdEx += 4 - return iNdEx, nil default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } + if iNdEx < 0 { + return 0, ErrInvalidLengthCommsg + } + if depth == 0 { + return iNdEx, nil + } } - panic("unreachable") + return 0, io.ErrUnexpectedEOF } var ( - ErrInvalidLengthCommsg = fmt.Errorf("proto: negative length found during unmarshaling") - ErrIntOverflowCommsg = fmt.Errorf("proto: integer overflow") + ErrInvalidLengthCommsg = fmt.Errorf("proto: negative length found during unmarshaling") + ErrIntOverflowCommsg = fmt.Errorf("proto: integer overflow") + ErrUnexpectedEndOfGroupCommsg = fmt.Errorf("proto: unexpected end of group") ) -- Gitblit v1.8.0