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