Lines Matching refs:pos
120 def DecodeVarint(buffer, pos): argument
124 b = local_ord(buffer[pos]) if py2 else buffer[pos]
126 pos += 1
130 return (result, pos)
143 def DecodeVarint(buffer, pos): argument
147 b = local_ord(buffer[pos]) if py2 else buffer[pos]
149 pos += 1
157 return (result, pos)
175 def ReadTag(buffer, pos): argument
188 start = pos
189 while (ord(buffer[pos]) if py2 else buffer[pos]) & 0x80:
190 pos += 1
191 pos += 1
192 return (buffer[start:pos], pos)
210 def DecodePackedField(buffer, pos, end, message, field_dict): argument
214 (endpoint, pos) = local_DecodeVarint(buffer, pos)
215 endpoint += pos
218 while pos < endpoint:
219 (element, pos) = decode_value(buffer, pos)
221 if pos > endpoint:
224 return pos
229 def DecodeRepeatedField(buffer, pos, end, message, field_dict): argument
234 (element, new_pos) = decode_value(buffer, pos)
238 pos = new_pos + tag_len
239 if buffer[new_pos:pos] != tag_bytes or new_pos >= end:
246 def DecodeField(buffer, pos, end, message, field_dict): argument
247 (field_dict[key], pos) = decode_value(buffer, pos)
248 if pos > end:
251 return pos
265 def InnerDecode(buffer, pos): argument
266 (result, new_pos) = decode_value(buffer, pos)
289 def InnerDecode(buffer, pos): argument
290 new_pos = pos + value_size
291 result = local_unpack(format, buffer[pos:new_pos])[0]
306 def InnerDecode(buffer, pos): argument
309 new_pos = pos + 4
310 float_bytes = buffer[pos:new_pos]
346 def InnerDecode(buffer, pos): argument
349 new_pos = pos + 8
350 double_bytes = buffer[pos:new_pos]
375 def DecodePackedField(buffer, pos, end, message, field_dict): argument
379 (endpoint, pos) = local_DecodeVarint(buffer, pos)
380 endpoint += pos
383 while pos < endpoint:
384 value_start_pos = pos
385 (element, pos) = _DecodeSignedVarint32(buffer, pos)
394 (tag_bytes, buffer[value_start_pos:pos]))
395 if pos > endpoint:
401 return pos
406 def DecodeRepeatedField(buffer, pos, end, message, field_dict): argument
411 (element, new_pos) = _DecodeSignedVarint32(buffer, pos)
418 (tag_bytes, buffer[pos:new_pos]))
421 pos = new_pos + tag_len
422 if buffer[new_pos:pos] != tag_bytes or new_pos >= end:
429 def DecodeField(buffer, pos, end, message, field_dict): argument
430 value_start_pos = pos
431 (enum_value, pos) = _DecodeSignedVarint32(buffer, pos)
432 if pos > end:
442 (tag_bytes, buffer[value_start_pos:pos]))
443 return pos
498 def DecodeRepeatedField(buffer, pos, end, message, field_dict): argument
503 (size, pos) = local_DecodeVarint(buffer, pos)
504 new_pos = pos + size
507 value.append(_ConvertToUnicode(buffer[pos:new_pos]))
509 pos = new_pos + tag_len
510 if buffer[new_pos:pos] != tag_bytes or new_pos == end:
515 def DecodeField(buffer, pos, end, message, field_dict): argument
516 (size, pos) = local_DecodeVarint(buffer, pos)
517 new_pos = pos + size
520 field_dict[key] = _ConvertToUnicode(buffer[pos:new_pos])
535 def DecodeRepeatedField(buffer, pos, end, message, field_dict): argument
540 (size, pos) = local_DecodeVarint(buffer, pos)
541 new_pos = pos + size
544 value.append(buffer[pos:new_pos])
546 pos = new_pos + tag_len
547 if buffer[new_pos:pos] != tag_bytes or new_pos == end:
552 def DecodeField(buffer, pos, end, message, field_dict): argument
553 (size, pos) = local_DecodeVarint(buffer, pos)
554 new_pos = pos + size
557 field_dict[key] = buffer[pos:new_pos]
574 def DecodeRepeatedField(buffer, pos, end, message, field_dict): argument
583 pos = value.add()._InternalParse(buffer, pos, end)
585 new_pos = pos+end_tag_len
586 if buffer[pos:new_pos] != end_tag_bytes or new_pos > end:
589 pos = new_pos + tag_len
590 if buffer[new_pos:pos] != tag_bytes or new_pos == end:
595 def DecodeField(buffer, pos, end, message, field_dict): argument
600 pos = value._InternalParse(buffer, pos, end)
602 new_pos = pos+end_tag_len
603 if buffer[pos:new_pos] != end_tag_bytes or new_pos > end:
619 def DecodeRepeatedField(buffer, pos, end, message, field_dict): argument
628 (size, pos) = local_DecodeVarint(buffer, pos)
629 new_pos = pos + size
633 if value.add()._InternalParse(buffer, pos, new_pos) != new_pos:
638 pos = new_pos + tag_len
639 if buffer[new_pos:pos] != tag_bytes or new_pos == end:
644 def DecodeField(buffer, pos, end, message, field_dict): argument
649 (size, pos) = local_DecodeVarint(buffer, pos)
650 new_pos = pos + size
654 if value._InternalParse(buffer, pos, new_pos) != new_pos:
688 def DecodeItem(buffer, pos, end, message, field_dict): argument
689 message_set_item_start = pos
697 (tag_bytes, pos) = local_ReadTag(buffer, pos)
699 (type_id, pos) = local_DecodeVarint(buffer, pos)
701 (size, message_start) = local_DecodeVarint(buffer, pos)
702 pos = message_end = message_start + size
706 pos = SkipField(buffer, pos, end, tag_bytes)
707 if pos == -1:
710 if pos > end:
732 buffer[message_set_item_start:pos]))
734 return pos
742 def _SkipVarint(buffer, pos, end): argument
747 while ord(buffer[pos:pos+1]) & 0x80:
748 pos += 1
749 pos += 1
750 if pos > end:
752 return pos
754 def _SkipFixed64(buffer, pos, end): argument
757 pos += 8
758 if pos > end:
760 return pos
762 def _SkipLengthDelimited(buffer, pos, end): argument
765 (size, pos) = _DecodeVarint(buffer, pos)
766 pos += size
767 if pos > end:
769 return pos
771 def _SkipGroup(buffer, pos, end): argument
775 (tag_bytes, pos) = ReadTag(buffer, pos)
776 new_pos = SkipField(buffer, pos, end, tag_bytes)
778 return pos
779 pos = new_pos
781 def _EndGroup(buffer, pos, end): argument
786 def _SkipFixed32(buffer, pos, end): argument
789 pos += 4
790 if pos > end:
792 return pos
794 def _RaiseInvalidWireType(buffer, pos, end): argument
815 def SkipField(buffer, pos, end, tag_bytes): argument
827 return WIRETYPE_TO_SKIPPER[wire_type](buffer, pos, end)