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 --- aiocean.pb.go | 1351 ++++++++++++++++++++++++++++++--------------------------- 1 files changed, 711 insertions(+), 640 deletions(-) diff --git a/aiocean.pb.go b/aiocean.pb.go index c252110..4747146 100644 --- a/aiocean.pb.go +++ b/aiocean.pb.go @@ -21,7 +21,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 EsDataBase struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` @@ -65,7 +65,7 @@ return xxx_messageInfo_EsDataBase.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 } @@ -303,7 +303,7 @@ return xxx_messageInfo_AIOcean.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 } @@ -534,7 +534,7 @@ return xxx_messageInfo_TargetInfo.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 } @@ -614,7 +614,7 @@ return xxx_messageInfo_TargetLocation.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 } @@ -666,7 +666,7 @@ return xxx_messageInfo_Location.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 } @@ -722,7 +722,7 @@ return xxx_messageInfo_AlarmRules.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 } @@ -810,7 +810,7 @@ return xxx_messageInfo_BaseInfo.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 } @@ -971,7 +971,7 @@ func (m *EsDataBase) 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 } @@ -979,230 +979,252 @@ } func (m *EsDataBase) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *EsDataBase) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.Id) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.Id))) - i += copy(dAtA[i:], m.Id) - } - if len(m.CameraId) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraId))) - i += copy(dAtA[i:], m.CameraId) - } - if len(m.CameraName) > 0 { - dAtA[i] = 0x1a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraName))) - i += copy(dAtA[i:], m.CameraName) - } - if len(m.CameraAddr) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraAddr))) - i += copy(dAtA[i:], m.CameraAddr) - } - if len(m.AnalyServerId) > 0 { - dAtA[i] = 0x2a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerId))) - i += copy(dAtA[i:], m.AnalyServerId) - } - if len(m.AnalyServerName) > 0 { - dAtA[i] = 0x32 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerName))) - i += copy(dAtA[i:], m.AnalyServerName) - } - if len(m.AnalyServerIp) > 0 { - dAtA[i] = 0x3a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerIp))) - i += copy(dAtA[i:], m.AnalyServerIp) - } - if len(m.ClusterId) > 0 { - dAtA[i] = 0x42 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.ClusterId))) - i += copy(dAtA[i:], m.ClusterId) - } - if len(m.TaskId) > 0 { - dAtA[i] = 0x4a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TaskId))) - i += copy(dAtA[i:], m.TaskId) - } - if len(m.TaskName) > 0 { - dAtA[i] = 0x52 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TaskName))) - i += copy(dAtA[i:], m.TaskName) - } - if len(m.SdkName) > 0 { - dAtA[i] = 0x5a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.SdkName))) - i += copy(dAtA[i:], m.SdkName) - } - if len(m.PicMaxUrl) > 0 { - for _, s := range m.PicMaxUrl { - dAtA[i] = 0x62 - i++ - l = len(s) - for l >= 1<<7 { - dAtA[i] = uint8(uint64(l)&0x7f | 0x80) - l >>= 7 - i++ - } - dAtA[i] = uint8(l) - i++ - i += copy(dAtA[i:], s) - } - } - if len(m.VideoUrl) > 0 { - dAtA[i] = 0x6a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.VideoUrl))) - i += copy(dAtA[i:], m.VideoUrl) - } - if len(m.PicDate) > 0 { - dAtA[i] = 0x72 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.PicDate))) - i += copy(dAtA[i:], m.PicDate) - } - if len(m.TargetInfo) > 0 { - for _, msg := range m.TargetInfo { - dAtA[i] = 0x7a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if len(m.OtherLabels) > 0 { - dAtA[i] = 0x82 - i++ + if len(m.Content) > 0 { + i -= len(m.Content) + copy(dAtA[i:], m.Content) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.Content))) + i-- dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.OtherLabels))) - i += copy(dAtA[i:], m.OtherLabels) - } - if len(m.ShowLabels) > 0 { - dAtA[i] = 0x8a - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.ShowLabels))) - i += copy(dAtA[i:], m.ShowLabels) - } - if len(m.LikeDate) > 0 { - dAtA[i] = 0x92 - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.LikeDate))) - i += copy(dAtA[i:], m.LikeDate) - } - if len(m.BaseInfo) > 0 { - for _, msg := range m.BaseInfo { - dAtA[i] = 0x9a - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if m.IsAlarm { - dAtA[i] = 0xa0 - i++ - dAtA[i] = 0x1 - i++ - if m.IsAlarm { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ - } - if m.IsAckAlarm { - dAtA[i] = 0xa8 - i++ - dAtA[i] = 0x1 - i++ - if m.IsAckAlarm { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ - } - if len(m.AlarmRules) > 0 { - for _, msg := range m.AlarmRules { - dAtA[i] = 0xb2 - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if m.IsCollect { - dAtA[i] = 0xb8 - i++ - dAtA[i] = 0x1 - i++ - if m.IsCollect { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ + i-- + dAtA[i] = 0xca } if m.IsDelete { - dAtA[i] = 0xc0 - i++ - dAtA[i] = 0x1 - i++ + i-- if m.IsDelete { dAtA[i] = 1 } else { dAtA[i] = 0 } - i++ - } - if len(m.Content) > 0 { - dAtA[i] = 0xca - i++ + i-- dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.Content))) - i += copy(dAtA[i:], m.Content) + i-- + dAtA[i] = 0xc0 } - return i, nil + if m.IsCollect { + i-- + if m.IsCollect { + dAtA[i] = 1 + } else { + dAtA[i] = 0 + } + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0xb8 + } + if len(m.AlarmRules) > 0 { + for iNdEx := len(m.AlarmRules) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.AlarmRules[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) + } + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0xb2 + } + } + if m.IsAckAlarm { + i-- + if m.IsAckAlarm { + dAtA[i] = 1 + } else { + dAtA[i] = 0 + } + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0xa8 + } + if m.IsAlarm { + i-- + if m.IsAlarm { + dAtA[i] = 1 + } else { + dAtA[i] = 0 + } + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0xa0 + } + if len(m.BaseInfo) > 0 { + for iNdEx := len(m.BaseInfo) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.BaseInfo[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) + } + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0x9a + } + } + if len(m.LikeDate) > 0 { + i -= len(m.LikeDate) + copy(dAtA[i:], m.LikeDate) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.LikeDate))) + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0x92 + } + if len(m.ShowLabels) > 0 { + i -= len(m.ShowLabels) + copy(dAtA[i:], m.ShowLabels) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.ShowLabels))) + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0x8a + } + if len(m.OtherLabels) > 0 { + i -= len(m.OtherLabels) + copy(dAtA[i:], m.OtherLabels) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.OtherLabels))) + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0x82 + } + if len(m.TargetInfo) > 0 { + for iNdEx := len(m.TargetInfo) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.TargetInfo[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) + } + i-- + dAtA[i] = 0x7a + } + } + if len(m.PicDate) > 0 { + i -= len(m.PicDate) + copy(dAtA[i:], m.PicDate) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.PicDate))) + i-- + dAtA[i] = 0x72 + } + if len(m.VideoUrl) > 0 { + i -= len(m.VideoUrl) + copy(dAtA[i:], m.VideoUrl) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.VideoUrl))) + i-- + dAtA[i] = 0x6a + } + if len(m.PicMaxUrl) > 0 { + for iNdEx := len(m.PicMaxUrl) - 1; iNdEx >= 0; iNdEx-- { + i -= len(m.PicMaxUrl[iNdEx]) + copy(dAtA[i:], m.PicMaxUrl[iNdEx]) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.PicMaxUrl[iNdEx]))) + i-- + dAtA[i] = 0x62 + } + } + if len(m.SdkName) > 0 { + i -= len(m.SdkName) + copy(dAtA[i:], m.SdkName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.SdkName))) + i-- + dAtA[i] = 0x5a + } + if len(m.TaskName) > 0 { + i -= len(m.TaskName) + copy(dAtA[i:], m.TaskName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TaskName))) + i-- + dAtA[i] = 0x52 + } + if len(m.TaskId) > 0 { + i -= len(m.TaskId) + copy(dAtA[i:], m.TaskId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TaskId))) + i-- + dAtA[i] = 0x4a + } + if len(m.ClusterId) > 0 { + i -= len(m.ClusterId) + copy(dAtA[i:], m.ClusterId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.ClusterId))) + i-- + dAtA[i] = 0x42 + } + if len(m.AnalyServerIp) > 0 { + i -= len(m.AnalyServerIp) + copy(dAtA[i:], m.AnalyServerIp) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerIp))) + i-- + dAtA[i] = 0x3a + } + if len(m.AnalyServerName) > 0 { + i -= len(m.AnalyServerName) + copy(dAtA[i:], m.AnalyServerName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerName))) + i-- + dAtA[i] = 0x32 + } + if len(m.AnalyServerId) > 0 { + i -= len(m.AnalyServerId) + copy(dAtA[i:], m.AnalyServerId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerId))) + i-- + dAtA[i] = 0x2a + } + if len(m.CameraAddr) > 0 { + i -= len(m.CameraAddr) + copy(dAtA[i:], m.CameraAddr) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraAddr))) + i-- + dAtA[i] = 0x22 + } + if len(m.CameraName) > 0 { + i -= len(m.CameraName) + copy(dAtA[i:], m.CameraName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraName))) + i-- + dAtA[i] = 0x1a + } + if len(m.CameraId) > 0 { + i -= len(m.CameraId) + copy(dAtA[i:], m.CameraId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraId))) + i-- + dAtA[i] = 0x12 + } + if len(m.Id) > 0 { + i -= len(m.Id) + copy(dAtA[i:], m.Id) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.Id))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *AIOcean) 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 } @@ -1210,252 +1232,277 @@ } func (m *AIOcean) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *AIOcean) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.Id) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.Id))) - i += copy(dAtA[i:], m.Id) - } - if len(m.CameraId) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraId))) - i += copy(dAtA[i:], m.CameraId) - } - if len(m.CameraName) > 0 { - dAtA[i] = 0x1a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraName))) - i += copy(dAtA[i:], m.CameraName) - } - if len(m.CameraAddr) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraAddr))) - i += copy(dAtA[i:], m.CameraAddr) - } - if len(m.AnalyServerId) > 0 { - dAtA[i] = 0x2a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerId))) - i += copy(dAtA[i:], m.AnalyServerId) - } - if len(m.AnalyServerName) > 0 { - dAtA[i] = 0x32 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerName))) - i += copy(dAtA[i:], m.AnalyServerName) - } - if len(m.AnalyServerIp) > 0 { - dAtA[i] = 0x3a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerIp))) - i += copy(dAtA[i:], m.AnalyServerIp) - } - if len(m.ClusterId) > 0 { - dAtA[i] = 0x42 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.ClusterId))) - i += copy(dAtA[i:], m.ClusterId) - } - if len(m.TaskId) > 0 { - dAtA[i] = 0x4a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TaskId))) - i += copy(dAtA[i:], m.TaskId) - } - if len(m.TaskName) > 0 { - dAtA[i] = 0x52 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TaskName))) - i += copy(dAtA[i:], m.TaskName) - } - if len(m.SdkName) > 0 { - dAtA[i] = 0x5a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.SdkName))) - i += copy(dAtA[i:], m.SdkName) - } - if len(m.PicMaxUrl) > 0 { - for _, s := range m.PicMaxUrl { - dAtA[i] = 0x62 - i++ - l = len(s) - for l >= 1<<7 { - dAtA[i] = uint8(uint64(l)&0x7f | 0x80) - l >>= 7 - i++ + if len(m.LinkTagInfo) > 0 { + for iNdEx := len(m.LinkTagInfo) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.LinkTagInfo[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) } - dAtA[i] = uint8(l) - i++ - i += copy(dAtA[i:], s) - } - } - if len(m.VideoUrl) > 0 { - dAtA[i] = 0x6a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.VideoUrl))) - i += copy(dAtA[i:], m.VideoUrl) - } - if len(m.PicDate) > 0 { - dAtA[i] = 0x72 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.PicDate))) - i += copy(dAtA[i:], m.PicDate) - } - if len(m.TargetInfo) > 0 { - for _, msg := range m.TargetInfo { - dAtA[i] = 0x7a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if len(m.OtherLabels) > 0 { - dAtA[i] = 0x82 - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.OtherLabels))) - i += copy(dAtA[i:], m.OtherLabels) - } - if len(m.ShowLabels) > 0 { - dAtA[i] = 0x8a - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.ShowLabels))) - i += copy(dAtA[i:], m.ShowLabels) - } - if len(m.LikeDate) > 0 { - dAtA[i] = 0x92 - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.LikeDate))) - i += copy(dAtA[i:], m.LikeDate) - } - if len(m.BaseInfo) > 0 { - for _, msg := range m.BaseInfo { - dAtA[i] = 0x9a - i++ + i-- dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n + i-- + dAtA[i] = 0xda } } - if m.IsAlarm { - dAtA[i] = 0xa0 - i++ + if len(m.LinkTag) > 0 { + i -= len(m.LinkTag) + copy(dAtA[i:], m.LinkTag) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.LinkTag))) + i-- dAtA[i] = 0x1 - i++ - if m.IsAlarm { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ + i-- + dAtA[i] = 0xd2 } - if m.IsAckAlarm { - dAtA[i] = 0xa8 - i++ + if len(m.Content) > 0 { + i -= len(m.Content) + copy(dAtA[i:], m.Content) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.Content))) + i-- dAtA[i] = 0x1 - i++ - if m.IsAckAlarm { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ - } - if len(m.AlarmRules) > 0 { - for _, msg := range m.AlarmRules { - dAtA[i] = 0xb2 - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if m.IsCollect { - dAtA[i] = 0xb8 - i++ - dAtA[i] = 0x1 - i++ - if m.IsCollect { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ + i-- + dAtA[i] = 0xca } if m.IsDelete { - dAtA[i] = 0xc0 - i++ - dAtA[i] = 0x1 - i++ + i-- if m.IsDelete { dAtA[i] = 1 } else { dAtA[i] = 0 } - i++ - } - if len(m.Content) > 0 { - dAtA[i] = 0xca - i++ + i-- dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.Content))) - i += copy(dAtA[i:], m.Content) + i-- + dAtA[i] = 0xc0 } - if len(m.LinkTag) > 0 { - dAtA[i] = 0xd2 - i++ + if m.IsCollect { + i-- + if m.IsCollect { + dAtA[i] = 1 + } else { + dAtA[i] = 0 + } + i-- dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.LinkTag))) - i += copy(dAtA[i:], m.LinkTag) + i-- + dAtA[i] = 0xb8 } - if len(m.LinkTagInfo) > 0 { - for _, msg := range m.LinkTagInfo { - dAtA[i] = 0xda - i++ - dAtA[i] = 0x1 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + if len(m.AlarmRules) > 0 { + for iNdEx := len(m.AlarmRules) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.AlarmRules[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) } - i += n + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0xb2 } } - return i, nil + if m.IsAckAlarm { + i-- + if m.IsAckAlarm { + dAtA[i] = 1 + } else { + dAtA[i] = 0 + } + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0xa8 + } + if m.IsAlarm { + i-- + if m.IsAlarm { + dAtA[i] = 1 + } else { + dAtA[i] = 0 + } + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0xa0 + } + if len(m.BaseInfo) > 0 { + for iNdEx := len(m.BaseInfo) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.BaseInfo[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) + } + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0x9a + } + } + if len(m.LikeDate) > 0 { + i -= len(m.LikeDate) + copy(dAtA[i:], m.LikeDate) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.LikeDate))) + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0x92 + } + if len(m.ShowLabels) > 0 { + i -= len(m.ShowLabels) + copy(dAtA[i:], m.ShowLabels) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.ShowLabels))) + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0x8a + } + if len(m.OtherLabels) > 0 { + i -= len(m.OtherLabels) + copy(dAtA[i:], m.OtherLabels) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.OtherLabels))) + i-- + dAtA[i] = 0x1 + i-- + dAtA[i] = 0x82 + } + if len(m.TargetInfo) > 0 { + for iNdEx := len(m.TargetInfo) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.TargetInfo[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) + } + i-- + dAtA[i] = 0x7a + } + } + if len(m.PicDate) > 0 { + i -= len(m.PicDate) + copy(dAtA[i:], m.PicDate) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.PicDate))) + i-- + dAtA[i] = 0x72 + } + if len(m.VideoUrl) > 0 { + i -= len(m.VideoUrl) + copy(dAtA[i:], m.VideoUrl) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.VideoUrl))) + i-- + dAtA[i] = 0x6a + } + if len(m.PicMaxUrl) > 0 { + for iNdEx := len(m.PicMaxUrl) - 1; iNdEx >= 0; iNdEx-- { + i -= len(m.PicMaxUrl[iNdEx]) + copy(dAtA[i:], m.PicMaxUrl[iNdEx]) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.PicMaxUrl[iNdEx]))) + i-- + dAtA[i] = 0x62 + } + } + if len(m.SdkName) > 0 { + i -= len(m.SdkName) + copy(dAtA[i:], m.SdkName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.SdkName))) + i-- + dAtA[i] = 0x5a + } + if len(m.TaskName) > 0 { + i -= len(m.TaskName) + copy(dAtA[i:], m.TaskName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TaskName))) + i-- + dAtA[i] = 0x52 + } + if len(m.TaskId) > 0 { + i -= len(m.TaskId) + copy(dAtA[i:], m.TaskId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TaskId))) + i-- + dAtA[i] = 0x4a + } + if len(m.ClusterId) > 0 { + i -= len(m.ClusterId) + copy(dAtA[i:], m.ClusterId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.ClusterId))) + i-- + dAtA[i] = 0x42 + } + if len(m.AnalyServerIp) > 0 { + i -= len(m.AnalyServerIp) + copy(dAtA[i:], m.AnalyServerIp) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerIp))) + i-- + dAtA[i] = 0x3a + } + if len(m.AnalyServerName) > 0 { + i -= len(m.AnalyServerName) + copy(dAtA[i:], m.AnalyServerName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerName))) + i-- + dAtA[i] = 0x32 + } + if len(m.AnalyServerId) > 0 { + i -= len(m.AnalyServerId) + copy(dAtA[i:], m.AnalyServerId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.AnalyServerId))) + i-- + dAtA[i] = 0x2a + } + if len(m.CameraAddr) > 0 { + i -= len(m.CameraAddr) + copy(dAtA[i:], m.CameraAddr) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraAddr))) + i-- + dAtA[i] = 0x22 + } + if len(m.CameraName) > 0 { + i -= len(m.CameraName) + copy(dAtA[i:], m.CameraName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraName))) + i-- + dAtA[i] = 0x1a + } + if len(m.CameraId) > 0 { + i -= len(m.CameraId) + copy(dAtA[i:], m.CameraId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.CameraId))) + i-- + dAtA[i] = 0x12 + } + if len(m.Id) > 0 { + i -= len(m.Id) + copy(dAtA[i:], m.Id) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.Id))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *TargetInfo) 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 } @@ -1463,57 +1510,68 @@ } func (m *TargetInfo) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *TargetInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.TargetId) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetId))) - i += copy(dAtA[i:], m.TargetId) - } - if len(m.TargetType) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetType))) - i += copy(dAtA[i:], m.TargetType) - } - if m.TargetScore != 0 { - dAtA[i] = 0x19 - i++ - encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.TargetScore)))) - i += 8 - } - if len(m.Feature) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.Feature))) - i += copy(dAtA[i:], m.Feature) + if m.TargetLocation != nil { + { + size, err := m.TargetLocation.MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) + } + i-- + dAtA[i] = 0x32 } if len(m.PicSmUrl) > 0 { - dAtA[i] = 0x2a - i++ + i -= len(m.PicSmUrl) + copy(dAtA[i:], m.PicSmUrl) i = encodeVarintAiocean(dAtA, i, uint64(len(m.PicSmUrl))) - i += copy(dAtA[i:], m.PicSmUrl) + i-- + dAtA[i] = 0x2a } - if m.TargetLocation != nil { - dAtA[i] = 0x32 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(m.TargetLocation.Size())) - n1, err1 := m.TargetLocation.MarshalTo(dAtA[i:]) - if err1 != nil { - return 0, err1 - } - i += n1 + if len(m.Feature) > 0 { + i -= len(m.Feature) + copy(dAtA[i:], m.Feature) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.Feature))) + i-- + dAtA[i] = 0x22 } - return i, nil + if m.TargetScore != 0 { + i -= 8 + encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.TargetScore)))) + i-- + dAtA[i] = 0x19 + } + if len(m.TargetType) > 0 { + i -= len(m.TargetType) + copy(dAtA[i:], m.TargetType) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetType))) + i-- + dAtA[i] = 0x12 + } + if len(m.TargetId) > 0 { + i -= len(m.TargetId) + copy(dAtA[i:], m.TargetId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetId))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *TargetLocation) 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 } @@ -1521,37 +1579,46 @@ } func (m *TargetLocation) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *TargetLocation) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if m.TopLeft != nil { - dAtA[i] = 0xa - i++ - i = encodeVarintAiocean(dAtA, i, uint64(m.TopLeft.Size())) - n2, err2 := m.TopLeft.MarshalTo(dAtA[i:]) - if err2 != nil { - return 0, err2 - } - i += n2 - } if m.BottomRight != nil { - dAtA[i] = 0x12 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(m.BottomRight.Size())) - n3, err3 := m.BottomRight.MarshalTo(dAtA[i:]) - if err3 != nil { - return 0, err3 + { + size, err := m.BottomRight.MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) } - i += n3 + i-- + dAtA[i] = 0x12 } - return i, nil + if m.TopLeft != nil { + { + size, err := m.TopLeft.MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintAiocean(dAtA, i, uint64(size)) + } + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *Location) 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 } @@ -1559,29 +1626,34 @@ } func (m *Location) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *Location) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if m.X != 0 { - dAtA[i] = 0x9 - i++ - encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.X)))) - i += 8 - } if m.Y != 0 { - dAtA[i] = 0x11 - i++ + i -= 8 encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.Y)))) - i += 8 + i-- + dAtA[i] = 0x11 } - return i, nil + if m.X != 0 { + i -= 8 + encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.X)))) + i-- + dAtA[i] = 0x9 + } + return len(dAtA) - i, nil } func (m *AlarmRules) 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 } @@ -1589,61 +1661,70 @@ } func (m *AlarmRules) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *AlarmRules) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.GroupId) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.GroupId))) - i += copy(dAtA[i:], m.GroupId) - } - if len(m.AlarmLevel) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.AlarmLevel))) - i += copy(dAtA[i:], m.AlarmLevel) - } - if len(m.RuleText) > 0 { - dAtA[i] = 0x1a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.RuleText))) - i += copy(dAtA[i:], m.RuleText) - } - if m.DefenceState { - dAtA[i] = 0x20 - i++ - if m.DefenceState { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ + if len(m.LinkInfo) > 0 { + i -= len(m.LinkInfo) + copy(dAtA[i:], m.LinkInfo) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.LinkInfo))) + i-- + dAtA[i] = 0x32 } if m.IsLink { - dAtA[i] = 0x28 - i++ + i-- if m.IsLink { dAtA[i] = 1 } else { dAtA[i] = 0 } - i++ + i-- + dAtA[i] = 0x28 } - if len(m.LinkInfo) > 0 { - dAtA[i] = 0x32 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.LinkInfo))) - i += copy(dAtA[i:], m.LinkInfo) + if m.DefenceState { + i-- + if m.DefenceState { + dAtA[i] = 1 + } else { + dAtA[i] = 0 + } + i-- + dAtA[i] = 0x20 } - return i, nil + if len(m.RuleText) > 0 { + i -= len(m.RuleText) + copy(dAtA[i:], m.RuleText) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.RuleText))) + i-- + dAtA[i] = 0x1a + } + if len(m.AlarmLevel) > 0 { + i -= len(m.AlarmLevel) + copy(dAtA[i:], m.AlarmLevel) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.AlarmLevel))) + i-- + dAtA[i] = 0x12 + } + if len(m.GroupId) > 0 { + i -= len(m.GroupId) + copy(dAtA[i:], m.GroupId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.GroupId))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *BaseInfo) 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 } @@ -1651,81 +1732,97 @@ } func (m *BaseInfo) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *BaseInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.TableId) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TableId))) - i += copy(dAtA[i:], m.TableId) - } - if len(m.TableName) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TableName))) - i += copy(dAtA[i:], m.TableName) - } - if m.CompareScore != 0 { - dAtA[i] = 0x19 - i++ - encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.CompareScore)))) - i += 8 - } - if len(m.BwType) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.BwType))) - i += copy(dAtA[i:], m.BwType) - } - if len(m.TargetId) > 0 { - dAtA[i] = 0x2a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetId))) - i += copy(dAtA[i:], m.TargetId) - } - if len(m.TargetName) > 0 { - dAtA[i] = 0x32 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetName))) - i += copy(dAtA[i:], m.TargetName) - } - if len(m.TargetPicUrl) > 0 { - dAtA[i] = 0x3a - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetPicUrl))) - i += copy(dAtA[i:], m.TargetPicUrl) - } - if len(m.MonitorLevel) > 0 { - dAtA[i] = 0x42 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.MonitorLevel))) - i += copy(dAtA[i:], m.MonitorLevel) + if len(m.Content) > 0 { + i -= len(m.Content) + copy(dAtA[i:], m.Content) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.Content))) + i-- + dAtA[i] = 0x52 } if len(m.Labels) > 0 { - dAtA[i] = 0x4a - i++ + i -= len(m.Labels) + copy(dAtA[i:], m.Labels) i = encodeVarintAiocean(dAtA, i, uint64(len(m.Labels))) - i += copy(dAtA[i:], m.Labels) + i-- + dAtA[i] = 0x4a } - if len(m.Content) > 0 { - dAtA[i] = 0x52 - i++ - i = encodeVarintAiocean(dAtA, i, uint64(len(m.Content))) - i += copy(dAtA[i:], m.Content) + if len(m.MonitorLevel) > 0 { + i -= len(m.MonitorLevel) + copy(dAtA[i:], m.MonitorLevel) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.MonitorLevel))) + i-- + dAtA[i] = 0x42 } - return i, nil + if len(m.TargetPicUrl) > 0 { + i -= len(m.TargetPicUrl) + copy(dAtA[i:], m.TargetPicUrl) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetPicUrl))) + i-- + dAtA[i] = 0x3a + } + if len(m.TargetName) > 0 { + i -= len(m.TargetName) + copy(dAtA[i:], m.TargetName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetName))) + i-- + dAtA[i] = 0x32 + } + if len(m.TargetId) > 0 { + i -= len(m.TargetId) + copy(dAtA[i:], m.TargetId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TargetId))) + i-- + dAtA[i] = 0x2a + } + if len(m.BwType) > 0 { + i -= len(m.BwType) + copy(dAtA[i:], m.BwType) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.BwType))) + i-- + dAtA[i] = 0x22 + } + if m.CompareScore != 0 { + i -= 8 + encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.CompareScore)))) + i-- + dAtA[i] = 0x19 + } + if len(m.TableName) > 0 { + i -= len(m.TableName) + copy(dAtA[i:], m.TableName) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TableName))) + i-- + dAtA[i] = 0x12 + } + if len(m.TableId) > 0 { + i -= len(m.TableId) + copy(dAtA[i:], m.TableId) + i = encodeVarintAiocean(dAtA, i, uint64(len(m.TableId))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func encodeVarintAiocean(dAtA []byte, offset int, v uint64) int { + offset -= sovAiocean(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 *EsDataBase) Size() (n int) { if m == nil { @@ -4804,6 +4901,7 @@ func skipAiocean(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 { @@ -4835,10 +4933,8 @@ break } } - return iNdEx, nil case 1: iNdEx += 8 - return iNdEx, nil case 2: var length int for shift := uint(0); ; shift += 7 { @@ -4859,55 +4955,30 @@ return 0, ErrInvalidLengthAiocean } iNdEx += length - if iNdEx < 0 { - return 0, ErrInvalidLengthAiocean - } - return iNdEx, nil case 3: - for { - var innerWire uint64 - var start int = iNdEx - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return 0, ErrIntOverflowAiocean - } - 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 := skipAiocean(dAtA[start:]) - if err != nil { - return 0, err - } - iNdEx = start + next - if iNdEx < 0 { - return 0, ErrInvalidLengthAiocean - } - } - return iNdEx, nil + depth++ case 4: - return iNdEx, nil + if depth == 0 { + return 0, ErrUnexpectedEndOfGroupAiocean + } + depth-- case 5: iNdEx += 4 - return iNdEx, nil default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } + if iNdEx < 0 { + return 0, ErrInvalidLengthAiocean + } + if depth == 0 { + return iNdEx, nil + } } - panic("unreachable") + return 0, io.ErrUnexpectedEOF } var ( - ErrInvalidLengthAiocean = fmt.Errorf("proto: negative length found during unmarshaling") - ErrIntOverflowAiocean = fmt.Errorf("proto: integer overflow") + ErrInvalidLengthAiocean = fmt.Errorf("proto: negative length found during unmarshaling") + ErrIntOverflowAiocean = fmt.Errorf("proto: integer overflow") + ErrUnexpectedEndOfGroupAiocean = fmt.Errorf("proto: unexpected end of group") ) -- Gitblit v1.8.0