Cross Reference: /external/protobuf/python/google/protobuf/internal/decoder.py

Lines Matching refs:buffer
35 """Code for decoding protocol buffer primitives.
40   Decode(buffer, pos, end, message, field_dict)
42   buffer:     The string containing the encoded message.
45               less than len(buffer) if we're reading a sub-message.
49 buffer position.  A decoder for a repeated field may proactively decode all of
120   def DecodeVarint(buffer, pos):
124       b = local_ord(buffer[pos]) if py2 else buffer[pos]
143   def DecodeVarint(buffer, pos):
147       b = local_ord(buffer[pos]) if py2 else buffer[pos]
175 def ReadTag(buffer, pos):
176   """Read a tag from the buffer, and return a (tag_bytes, new_pos) tuple.
189   while (ord(buffer[pos]) if py2 else buffer[pos]) & 0x80:
192   return (buffer[start:pos], pos)
210       def DecodePackedField(buffer, pos, end, message, field_dict):
214         (endpoint, pos) = local_DecodeVarint(buffer, pos)
219           (element, pos) = decode_value(buffer, pos)
229       def DecodeRepeatedField(buffer, pos, end, message, field_dict):
234           (element, new_pos) = decode_value(buffer, pos)
239           if buffer[new_pos:pos] != tag_bytes or new_pos >= end:
246       def DecodeField(buffer, pos, end, message, field_dict):
247         (field_dict[key], pos) = decode_value(buffer, pos)
265   def InnerDecode(buffer, pos):
266     (result, new_pos) = decode_value(buffer, pos)
289   def InnerDecode(buffer, pos):
291     result = local_unpack(format, buffer[pos:new_pos])[0]
306   def InnerDecode(buffer, pos):
310     float_bytes = buffer[pos:new_pos]
346   def InnerDecode(buffer, pos):
350     double_bytes = buffer[pos:new_pos]
375     def DecodePackedField(buffer, pos, end, message, field_dict):
379       (endpoint, pos) = local_DecodeVarint(buffer, pos)
385         (element, pos) = _DecodeSignedVarint32(buffer, pos)
394               (tag_bytes, buffer[value_start_pos:pos]))
406     def DecodeRepeatedField(buffer, pos, end, message, field_dict):
411         (element, new_pos) = _DecodeSignedVarint32(buffer, pos)
418               (tag_bytes, buffer[pos:new_pos]))
422         if buffer[new_pos:pos] != tag_bytes or new_pos >= end:
429     def DecodeField(buffer, pos, end, message, field_dict):
431       (enum_value, pos) = _DecodeSignedVarint32(buffer, pos)
442           (tag_bytes, buffer[value_start_pos:pos]))
498     def DecodeRepeatedField(buffer, pos, end, message, field_dict):
503         (size, pos) = local_DecodeVarint(buffer, pos)
507         value.append(_ConvertToUnicode(buffer[pos:new_pos]))
510         if buffer[new_pos:pos] != tag_bytes or new_pos == end:
515     def DecodeField(buffer, pos, end, message, field_dict):
516       (size, pos) = local_DecodeVarint(buffer, pos)
520       field_dict[key] = _ConvertToUnicode(buffer[pos:new_pos])
535     def DecodeRepeatedField(buffer, pos, end, message, field_dict):
540         (size, pos) = local_DecodeVarint(buffer, pos)
544         value.append(buffer[pos:new_pos])
547         if buffer[new_pos:pos] != tag_bytes or new_pos == end:
552     def DecodeField(buffer, pos, end, message, field_dict):
553       (size, pos) = local_DecodeVarint(buffer, pos)
557       field_dict[key] = buffer[pos:new_pos]
574     def DecodeRepeatedField(buffer, pos, end, message, field_dict):
583         pos = value.add()._InternalParse(buffer, pos, end)
586         if buffer[pos:new_pos] != end_tag_bytes or new_pos > end:
590         if buffer[new_pos:pos] != tag_bytes or new_pos == end:
595     def DecodeField(buffer, pos, end, message, field_dict):
600       pos = value._InternalParse(buffer, pos, end)
603       if buffer[pos:new_pos] != end_tag_bytes or new_pos > end:
619     def DecodeRepeatedField(buffer, pos, end, message, field_dict):
628         (size, pos) = local_DecodeVarint(buffer, pos)
633         if value.add()._InternalParse(buffer, pos, new_pos) != new_pos:
639         if buffer[new_pos:pos] != tag_bytes or new_pos == end:
644     def DecodeField(buffer, pos, end, message, field_dict):
649       (size, pos) = local_DecodeVarint(buffer, pos)
654       if value._InternalParse(buffer, pos, new_pos) != new_pos:
688   def DecodeItem(buffer, pos, end, message, field_dict):
697       (tag_bytes, pos) = local_ReadTag(buffer, pos)
699         (type_id, pos) = local_DecodeVarint(buffer, pos)
701         (size, message_start) = local_DecodeVarint(buffer, pos)
706         pos = SkipField(buffer, pos, end, tag_bytes)
724       if value._InternalParse(buffer, message_start,message_end) != message_end:
732                                       buffer[message_set_item_start:pos]))
742 def _SkipVarint(buffer, pos, end):
744   # Previously ord(buffer[pos]) raised IndexError when pos is out of range.
747   while ord(buffer[pos:pos+1]) & 0x80:
754 def _SkipFixed64(buffer, pos, end):
762 def _SkipLengthDelimited(buffer, pos, end):
765   (size, pos) = _DecodeVarint(buffer, pos)
771 def _SkipGroup(buffer, pos, end):
775     (tag_bytes, pos) = ReadTag(buffer, pos)
776     new_pos = SkipField(buffer, pos, end, tag_bytes)
781 def _EndGroup(buffer, pos, end):
786 def _SkipFixed32(buffer, pos, end):
794 def _RaiseInvalidWireType(buffer, pos, end):
815   def SkipField(buffer, pos, end, tag_bytes):
827     return WIRETYPE_TO_SKIPPER[wire_type](buffer, pos, end)