| 21020 | return nil |
| 21021 | } |
| 21022 | func (m *MapHeader) Unmarshal(dAtA []byte) error { |
| 21023 | l := len(dAtA) |
| 21024 | iNdEx := 0 |
| 21025 | for iNdEx < l { |
| 21026 | preIndex := iNdEx |
| 21027 | var wire uint64 |
| 21028 | for shift := uint(0); ; shift += 7 { |
| 21029 | if shift >= 64 { |
| 21030 | return ErrIntOverflowPb |
| 21031 | } |
| 21032 | if iNdEx >= l { |
| 21033 | return io.ErrUnexpectedEOF |
| 21034 | } |
| 21035 | b := dAtA[iNdEx] |
| 21036 | iNdEx++ |
| 21037 | wire |= uint64(b&0x7F) << shift |
| 21038 | if b < 0x80 { |
| 21039 | break |
| 21040 | } |
| 21041 | } |
| 21042 | fieldNum := int32(wire >> 3) |
| 21043 | wireType := int(wire & 0x7) |
| 21044 | if wireType == 4 { |
| 21045 | return fmt.Errorf("proto: MapHeader: wiretype end group for non-group") |
| 21046 | } |
| 21047 | if fieldNum <= 0 { |
| 21048 | return fmt.Errorf("proto: MapHeader: illegal tag %d (wire type %d)", fieldNum, wire) |
| 21049 | } |
| 21050 | switch fieldNum { |
| 21051 | case 1: |
| 21052 | if wireType != 2 { |
| 21053 | return fmt.Errorf("proto: wrong wireType = %d for field PartitionKeys", wireType) |
| 21054 | } |
| 21055 | var byteLen int |
| 21056 | for shift := uint(0); ; shift += 7 { |
| 21057 | if shift >= 64 { |
| 21058 | return ErrIntOverflowPb |
| 21059 | } |
| 21060 | if iNdEx >= l { |
| 21061 | return io.ErrUnexpectedEOF |
| 21062 | } |
| 21063 | b := dAtA[iNdEx] |
| 21064 | iNdEx++ |
| 21065 | byteLen |= int(b&0x7F) << shift |
| 21066 | if b < 0x80 { |
| 21067 | break |
| 21068 | } |
| 21069 | } |
| 21070 | if byteLen < 0 { |
| 21071 | return ErrInvalidLengthPb |
| 21072 | } |
| 21073 | postIndex := iNdEx + byteLen |
| 21074 | if postIndex < 0 { |
| 21075 | return ErrInvalidLengthPb |
| 21076 | } |
| 21077 | if postIndex > l { |
| 21078 | return io.ErrUnexpectedEOF |
| 21079 | } |