| Index: third_party/protobuf/js/binary/reader.js
|
| diff --git a/third_party/protobuf/js/binary/reader.js b/third_party/protobuf/js/binary/reader.js
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..abcd1660dd636b65ef0911d41e36dd144875d689
|
| --- /dev/null
|
| +++ b/third_party/protobuf/js/binary/reader.js
|
| @@ -0,0 +1,1127 @@
|
| +// Protocol Buffers - Google's data interchange format
|
| +// Copyright 2008 Google Inc. All rights reserved.
|
| +// https://developers.google.com/protocol-buffers/
|
| +//
|
| +// Redistribution and use in source and binary forms, with or without
|
| +// modification, are permitted provided that the following conditions are
|
| +// met:
|
| +//
|
| +// * Redistributions of source code must retain the above copyright
|
| +// notice, this list of conditions and the following disclaimer.
|
| +// * Redistributions in binary form must reproduce the above
|
| +// copyright notice, this list of conditions and the following disclaimer
|
| +// in the documentation and/or other materials provided with the
|
| +// distribution.
|
| +// * Neither the name of Google Inc. nor the names of its
|
| +// contributors may be used to endorse or promote products derived from
|
| +// this software without specific prior written permission.
|
| +//
|
| +// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
| +// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
| +// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
| +// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
| +// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
| +// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
| +// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
| +// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
| +// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
| +// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
| +// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
| +
|
| +/**
|
| + * @fileoverview This file contains utilities for converting binary,
|
| + * wire-format protocol buffers into Javascript data structures.
|
| + *
|
| + * jspb's BinaryReader class wraps the BinaryDecoder class to add methods
|
| + * that understand the protocol buffer syntax and can do the type checking and
|
| + * bookkeeping necessary to parse trees of nested messages.
|
| + *
|
| + * Major caveat - Users of this library _must_ keep their Javascript proto
|
| + * parsing code in sync with the original .proto file - presumably you'll be
|
| + * using the typed jspb code generator, but if you bypass that you'll need
|
| + * to keep things in sync by hand.
|
| + *
|
| + * @author aappleby@google.com (Austin Appleby)
|
| + */
|
| +
|
| +goog.provide('jspb.BinaryReader');
|
| +
|
| +goog.require('goog.asserts');
|
| +goog.require('jspb.BinaryConstants');
|
| +goog.require('jspb.BinaryDecoder');
|
| +
|
| +
|
| +
|
| +/**
|
| + * BinaryReader implements the decoders for all the wire types specified in
|
| + * https://developers.google.com/protocol-buffers/docs/encoding.
|
| + *
|
| + * @param {jspb.ByteSource=} opt_bytes The bytes we're reading from.
|
| + * @param {number=} opt_start The optional offset to start reading at.
|
| + * @param {number=} opt_length The optional length of the block to read -
|
| + * we'll throw an assertion if we go off the end of the block.
|
| + * @constructor
|
| + * @struct
|
| + */
|
| +jspb.BinaryReader = function(opt_bytes, opt_start, opt_length) {
|
| + /**
|
| + * Wire-format decoder.
|
| + * @private {!jspb.BinaryDecoder}
|
| + */
|
| + this.decoder_ = jspb.BinaryDecoder.alloc(opt_bytes, opt_start, opt_length);
|
| +
|
| + /**
|
| + * Cursor immediately before the field tag.
|
| + * @private {number}
|
| + */
|
| + this.fieldCursor_ = this.decoder_.getCursor();
|
| +
|
| + /**
|
| + * Field number of the next field in the buffer, filled in by nextField().
|
| + * @private {number}
|
| + */
|
| + this.nextField_ = jspb.BinaryConstants.INVALID_FIELD_NUMBER;
|
| +
|
| + /**
|
| + * Wire type of the next proto field in the buffer, filled in by
|
| + * nextField().
|
| + * @private {jspb.BinaryConstants.WireType}
|
| + */
|
| + this.nextWireType_ = jspb.BinaryConstants.WireType.INVALID;
|
| +
|
| + /**
|
| + * Set to true if this reader encountered an error due to corrupt data.
|
| + * @private {boolean}
|
| + */
|
| + this.error_ = false;
|
| +
|
| + /**
|
| + * User-defined reader callbacks.
|
| + * @private {Object.<string, function(!jspb.BinaryReader):*>}
|
| + */
|
| + this.readCallbacks_ = null;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Global pool of BinaryReader instances.
|
| + * @private {!Array.<!jspb.BinaryReader>}
|
| + */
|
| +jspb.BinaryReader.instanceCache_ = [];
|
| +
|
| +
|
| +/**
|
| + * Pops an instance off the instance cache, or creates one if the cache is
|
| + * empty.
|
| + * @param {jspb.ByteSource=} opt_bytes The bytes we're reading from.
|
| + * @param {number=} opt_start The optional offset to start reading at.
|
| + * @param {number=} opt_length The optional length of the block to read -
|
| + * we'll throw an assertion if we go off the end of the block.
|
| + * @return {!jspb.BinaryReader}
|
| + */
|
| +jspb.BinaryReader.alloc =
|
| + function(opt_bytes, opt_start, opt_length) {
|
| + if (jspb.BinaryReader.instanceCache_.length) {
|
| + var newReader = jspb.BinaryReader.instanceCache_.pop();
|
| + if (opt_bytes) {
|
| + newReader.decoder_.setBlock(opt_bytes, opt_start, opt_length);
|
| + }
|
| + return newReader;
|
| + } else {
|
| + return new jspb.BinaryReader(opt_bytes, opt_start, opt_length);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Alias for the above method.
|
| + * @param {jspb.ByteSource=} opt_bytes The bytes we're reading from.
|
| + * @param {number=} opt_start The optional offset to start reading at.
|
| + * @param {number=} opt_length The optional length of the block to read -
|
| + * we'll throw an assertion if we go off the end of the block.
|
| + * @return {!jspb.BinaryReader}
|
| + */
|
| +jspb.BinaryReader.prototype.alloc = jspb.BinaryReader.alloc;
|
| +
|
| +
|
| +/**
|
| + * Puts this instance back in the instance cache.
|
| + */
|
| +jspb.BinaryReader.prototype.free = function() {
|
| + this.decoder_.clear();
|
| + this.nextField_ = jspb.BinaryConstants.INVALID_FIELD_NUMBER;
|
| + this.nextWireType_ = jspb.BinaryConstants.WireType.INVALID;
|
| + this.error_ = false;
|
| + this.readCallbacks_ = null;
|
| +
|
| + if (jspb.BinaryReader.instanceCache_.length < 100) {
|
| + jspb.BinaryReader.instanceCache_.push(this);
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Returns the cursor immediately before the current field's tag.
|
| + * @return {number} The internal read cursor.
|
| + */
|
| +jspb.BinaryReader.prototype.getFieldCursor = function() {
|
| + return this.fieldCursor_;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Returns the internal read cursor.
|
| + * @return {number} The internal read cursor.
|
| + */
|
| +jspb.BinaryReader.prototype.getCursor = function() {
|
| + return this.decoder_.getCursor();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Returns the raw buffer.
|
| + * @return {Uint8Array} The raw buffer.
|
| + */
|
| +jspb.BinaryReader.prototype.getBuffer = function() {
|
| + return this.decoder_.getBuffer();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @return {number} The field number of the next field in the buffer, or
|
| + * INVALID_FIELD_NUMBER if there is no next field.
|
| + */
|
| +jspb.BinaryReader.prototype.getFieldNumber = function() {
|
| + return this.nextField_;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @return {jspb.BinaryConstants.WireType} The wire type of the next field
|
| + * in the stream, or WireType.INVALID if there is no next field.
|
| + */
|
| +jspb.BinaryReader.prototype.getWireType = function() {
|
| + return this.nextWireType_;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * @return {boolean} Whether the current wire type is an end-group tag. Used as
|
| + * an exit condition in decoder loops in generated code.
|
| + */
|
| +jspb.BinaryReader.prototype.isEndGroup = function() {
|
| + return this.nextWireType_ == jspb.BinaryConstants.WireType.END_GROUP;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Returns true if this reader hit an error due to corrupt data.
|
| + * @return {boolean}
|
| + */
|
| +jspb.BinaryReader.prototype.getError = function() {
|
| + return this.error_ || this.decoder_.getError();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Points this reader at a new block of bytes.
|
| + * @param {!Uint8Array} bytes The block of bytes we're reading from.
|
| + * @param {number} start The offset to start reading at.
|
| + * @param {number} length The length of the block to read.
|
| + */
|
| +jspb.BinaryReader.prototype.setBlock = function(bytes, start, length) {
|
| + this.decoder_.setBlock(bytes, start, length);
|
| + this.nextField_ = jspb.BinaryConstants.INVALID_FIELD_NUMBER;
|
| + this.nextWireType_ = jspb.BinaryConstants.WireType.INVALID;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Rewinds the stream cursor to the beginning of the buffer and resets all
|
| + * internal state.
|
| + */
|
| +jspb.BinaryReader.prototype.reset = function() {
|
| + this.decoder_.reset();
|
| + this.nextField_ = jspb.BinaryConstants.INVALID_FIELD_NUMBER;
|
| + this.nextWireType_ = jspb.BinaryConstants.WireType.INVALID;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Advances the stream cursor by the given number of bytes.
|
| + * @param {number} count The number of bytes to advance by.
|
| + */
|
| +jspb.BinaryReader.prototype.advance = function(count) {
|
| + this.decoder_.advance(count);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads the next field header in the stream if there is one, returns true if
|
| + * we saw a valid field header or false if we've read the whole stream.
|
| + * Throws an error if we encountered a deprecated START_GROUP/END_GROUP field.
|
| + * @return {boolean} True if the stream contains more fields.
|
| + */
|
| +jspb.BinaryReader.prototype.nextField = function() {
|
| + // If we're at the end of the block, there are no more fields.
|
| + if (this.decoder_.atEnd()) {
|
| + return false;
|
| + }
|
| +
|
| + // If we hit an error decoding the previous field, stop now before we
|
| + // try to decode anything else
|
| + if (this.getError()) {
|
| + goog.asserts.fail('Decoder hit an error');
|
| + return false;
|
| + }
|
| +
|
| + // Otherwise just read the header of the next field.
|
| + this.fieldCursor_ = this.decoder_.getCursor();
|
| + var header = this.decoder_.readUnsignedVarint32();
|
| +
|
| + var nextField = header >>> 3;
|
| + var nextWireType = /** @type {jspb.BinaryConstants.WireType} */
|
| + (header & 0x7);
|
| +
|
| + // If the wire type isn't one of the valid ones, something's broken.
|
| + if (nextWireType != jspb.BinaryConstants.WireType.VARINT &&
|
| + nextWireType != jspb.BinaryConstants.WireType.FIXED32 &&
|
| + nextWireType != jspb.BinaryConstants.WireType.FIXED64 &&
|
| + nextWireType != jspb.BinaryConstants.WireType.DELIMITED &&
|
| + nextWireType != jspb.BinaryConstants.WireType.START_GROUP &&
|
| + nextWireType != jspb.BinaryConstants.WireType.END_GROUP) {
|
| + goog.asserts.fail('Invalid wire type');
|
| + this.error_ = true;
|
| + return false;
|
| + }
|
| +
|
| + this.nextField_ = nextField;
|
| + this.nextWireType_ = nextWireType;
|
| +
|
| + return true;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Winds the reader back to just before this field's header.
|
| + */
|
| +jspb.BinaryReader.prototype.unskipHeader = function() {
|
| + this.decoder_.unskipVarint((this.nextField_ << 3) | this.nextWireType_);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Skips all contiguous fields whose header matches the one we just read.
|
| + */
|
| +jspb.BinaryReader.prototype.skipMatchingFields = function() {
|
| + var field = this.nextField_;
|
| + this.unskipHeader();
|
| +
|
| + while (this.nextField() && (this.getFieldNumber() == field)) {
|
| + this.skipField();
|
| + }
|
| +
|
| + if (!this.decoder_.atEnd()) {
|
| + this.unskipHeader();
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Skips over the next varint field in the binary stream.
|
| + */
|
| +jspb.BinaryReader.prototype.skipVarintField = function() {
|
| + if (this.nextWireType_ != jspb.BinaryConstants.WireType.VARINT) {
|
| + goog.asserts.fail('Invalid wire type for skipVarintField');
|
| + this.skipField();
|
| + return;
|
| + }
|
| +
|
| + this.decoder_.skipVarint();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Skips over the next delimited field in the binary stream.
|
| + */
|
| +jspb.BinaryReader.prototype.skipDelimitedField = function() {
|
| + if (this.nextWireType_ != jspb.BinaryConstants.WireType.DELIMITED) {
|
| + goog.asserts.fail('Invalid wire type for skipDelimitedField');
|
| + this.skipField();
|
| + return;
|
| + }
|
| +
|
| + var length = this.decoder_.readUnsignedVarint32();
|
| + this.decoder_.advance(length);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Skips over the next fixed32 field in the binary stream.
|
| + */
|
| +jspb.BinaryReader.prototype.skipFixed32Field = function() {
|
| + if (this.nextWireType_ != jspb.BinaryConstants.WireType.FIXED32) {
|
| + goog.asserts.fail('Invalid wire type for skipFixed32Field');
|
| + this.skipField();
|
| + return;
|
| + }
|
| +
|
| + this.decoder_.advance(4);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Skips over the next fixed64 field in the binary stream.
|
| + */
|
| +jspb.BinaryReader.prototype.skipFixed64Field = function() {
|
| + if (this.nextWireType_ != jspb.BinaryConstants.WireType.FIXED64) {
|
| + goog.asserts.fail('Invalid wire type for skipFixed64Field');
|
| + this.skipField();
|
| + return;
|
| + }
|
| +
|
| + this.decoder_.advance(8);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Skips over the next group field in the binary stream.
|
| + */
|
| +jspb.BinaryReader.prototype.skipGroup = function() {
|
| + // Keep a stack of start-group tags that must be matched by end-group tags.
|
| + var nestedGroups = [this.nextField_];
|
| + do {
|
| + if (!this.nextField()) {
|
| + goog.asserts.fail('Unmatched start-group tag: stream EOF');
|
| + this.error_ = true;
|
| + return;
|
| + }
|
| + if (this.nextWireType_ ==
|
| + jspb.BinaryConstants.WireType.START_GROUP) {
|
| + // Nested group start.
|
| + nestedGroups.push(this.nextField_);
|
| + } else if (this.nextWireType_ ==
|
| + jspb.BinaryConstants.WireType.END_GROUP) {
|
| + // Group end: check that it matches top-of-stack.
|
| + if (this.nextField_ != nestedGroups.pop()) {
|
| + goog.asserts.fail('Unmatched end-group tag');
|
| + this.error_ = true;
|
| + return;
|
| + }
|
| + }
|
| + } while (nestedGroups.length > 0);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Skips over the next field in the binary stream - this is useful if we're
|
| + * decoding a message that contain unknown fields.
|
| + */
|
| +jspb.BinaryReader.prototype.skipField = function() {
|
| + switch (this.nextWireType_) {
|
| + case jspb.BinaryConstants.WireType.VARINT:
|
| + this.skipVarintField();
|
| + break;
|
| + case jspb.BinaryConstants.WireType.FIXED64:
|
| + this.skipFixed64Field();
|
| + break;
|
| + case jspb.BinaryConstants.WireType.DELIMITED:
|
| + this.skipDelimitedField();
|
| + break;
|
| + case jspb.BinaryConstants.WireType.FIXED32:
|
| + this.skipFixed32Field();
|
| + break;
|
| + case jspb.BinaryConstants.WireType.START_GROUP:
|
| + this.skipGroup();
|
| + break;
|
| + default:
|
| + goog.asserts.fail('Invalid wire encoding for field.');
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Registers a user-defined read callback.
|
| + * @param {string} callbackName
|
| + * @param {function(!jspb.BinaryReader):*} callback
|
| + */
|
| +jspb.BinaryReader.prototype.registerReadCallback =
|
| + function(callbackName, callback) {
|
| + if (goog.isNull(this.readCallbacks_)) {
|
| + this.readCallbacks_ = {};
|
| + }
|
| + goog.asserts.assert(!this.readCallbacks_[callbackName]);
|
| + this.readCallbacks_[callbackName] = callback;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Runs a registered read callback.
|
| + * @param {string} callbackName The name the callback is registered under.
|
| + * @return {*} The value returned by the callback.
|
| + */
|
| +jspb.BinaryReader.prototype.runReadCallback = function(callbackName) {
|
| + goog.asserts.assert(!goog.isNull(this.readCallbacks_));
|
| + var callback = this.readCallbacks_[callbackName];
|
| + goog.asserts.assert(callback);
|
| + return callback(this);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a field of any valid non-message type from the binary stream.
|
| + * @param {jspb.BinaryConstants.FieldType} fieldType
|
| + * @return {jspb.AnyFieldType}
|
| + */
|
| +jspb.BinaryReader.prototype.readAny = function(fieldType) {
|
| + this.nextWireType_ = jspb.BinaryConstants.FieldTypeToWireType(fieldType);
|
| + var fieldTypes = jspb.BinaryConstants.FieldType;
|
| + switch (fieldType) {
|
| + case fieldTypes.DOUBLE:
|
| + return this.readDouble();
|
| + case fieldTypes.FLOAT:
|
| + return this.readFloat();
|
| + case fieldTypes.INT64:
|
| + return this.readInt64();
|
| + case fieldTypes.UINT64:
|
| + return this.readUint64();
|
| + case fieldTypes.INT32:
|
| + return this.readInt32();
|
| + case fieldTypes.FIXED64:
|
| + return this.readFixed64();
|
| + case fieldTypes.FIXED32:
|
| + return this.readFixed32();
|
| + case fieldTypes.BOOL:
|
| + return this.readBool();
|
| + case fieldTypes.STRING:
|
| + return this.readString();
|
| + case fieldTypes.GROUP:
|
| + goog.asserts.fail('Group field type not supported in readAny()');
|
| + case fieldTypes.MESSAGE:
|
| + goog.asserts.fail('Message field type not supported in readAny()');
|
| + case fieldTypes.BYTES:
|
| + return this.readBytes();
|
| + case fieldTypes.UINT32:
|
| + return this.readUint32();
|
| + case fieldTypes.ENUM:
|
| + return this.readEnum();
|
| + case fieldTypes.SFIXED32:
|
| + return this.readSfixed32();
|
| + case fieldTypes.SFIXED64:
|
| + return this.readSfixed64();
|
| + case fieldTypes.SINT32:
|
| + return this.readSint32();
|
| + case fieldTypes.SINT64:
|
| + return this.readSint64();
|
| + case fieldTypes.FHASH64:
|
| + return this.readFixedHash64();
|
| + case fieldTypes.VHASH64:
|
| + return this.readVarintHash64();
|
| + default:
|
| + goog.asserts.fail('Invalid field type in readAny()');
|
| + }
|
| + return 0;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Deserialize a proto into the provided message object using the provided
|
| + * reader function. This function is templated as we currently have one client
|
| + * who is using manual deserialization instead of the code-generated versions.
|
| + * @template T
|
| + * @param {T} message
|
| + * @param {function(T, !jspb.BinaryReader)} reader
|
| + */
|
| +jspb.BinaryReader.prototype.readMessage = function(message, reader) {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED);
|
| +
|
| + // Save the current endpoint of the decoder and move it to the end of the
|
| + // embedded message.
|
| + var oldEnd = this.decoder_.getEnd();
|
| + var length = this.decoder_.readUnsignedVarint32();
|
| + var newEnd = this.decoder_.getCursor() + length;
|
| + this.decoder_.setEnd(newEnd);
|
| +
|
| + // Deserialize the embedded message.
|
| + reader(message, this);
|
| +
|
| + // Advance the decoder past the embedded message and restore the endpoint.
|
| + this.decoder_.setCursor(newEnd);
|
| + this.decoder_.setEnd(oldEnd);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Deserialize a proto into the provided message object using the provided
|
| + * reader function, assuming that the message is serialized as a group
|
| + * with the given tag.
|
| + * @template T
|
| + * @param {number} field
|
| + * @param {T} message
|
| + * @param {function(T, !jspb.BinaryReader)} reader
|
| + */
|
| +jspb.BinaryReader.prototype.readGroup =
|
| + function(field, message, reader) {
|
| + // Ensure that the wire type is correct.
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.START_GROUP);
|
| + // Ensure that the field number is correct.
|
| + goog.asserts.assert(this.nextField_ == field);
|
| +
|
| + // Deserialize the message. The deserialization will stop at an END_GROUP tag.
|
| + reader(message, this);
|
| +
|
| + if (!this.error_ &&
|
| + this.nextWireType_ != jspb.BinaryConstants.WireType.END_GROUP) {
|
| + goog.asserts.fail('Group submessage did not end with an END_GROUP tag');
|
| + this.error_ = true;
|
| + }
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Return a decoder that wraps the current delimited field.
|
| + * @return {!jspb.BinaryDecoder}
|
| + */
|
| +jspb.BinaryReader.prototype.getFieldDecoder = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED);
|
| +
|
| + var length = this.decoder_.readUnsignedVarint32();
|
| + var start = this.decoder_.getCursor();
|
| + var end = start + length;
|
| +
|
| + var innerDecoder = jspb.BinaryDecoder.alloc(this.decoder_.getBuffer(),
|
| + start, length);
|
| + this.decoder_.setCursor(end);
|
| + return innerDecoder;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a signed 32-bit integer field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {number} The value of the signed 32-bit integer field.
|
| + */
|
| +jspb.BinaryReader.prototype.readInt32 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readSignedVarint32();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a signed 32-bit integer field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * Returns the value as a string.
|
| + *
|
| + * @return {string} The value of the signed 32-bit integer field as a decimal
|
| + * string.
|
| + */
|
| +jspb.BinaryReader.prototype.readInt32String = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readSignedVarint32String();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a signed 64-bit integer field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {number} The value of the signed 64-bit integer field.
|
| + */
|
| +jspb.BinaryReader.prototype.readInt64 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readSignedVarint64();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a signed 64-bit integer field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * Returns the value as a string.
|
| + *
|
| + * @return {string} The value of the signed 64-bit integer field as a decimal
|
| + * string.
|
| + */
|
| +jspb.BinaryReader.prototype.readInt64String = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readSignedVarint64String();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads an unsigned 32-bit integer field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {number} The value of the unsigned 32-bit integer field.
|
| + */
|
| +jspb.BinaryReader.prototype.readUint32 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readUnsignedVarint32();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads an unsigned 32-bit integer field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * Returns the value as a string.
|
| + *
|
| + * @return {string} The value of the unsigned 32-bit integer field as a decimal
|
| + * string.
|
| + */
|
| +jspb.BinaryReader.prototype.readUint32String = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readUnsignedVarint32String();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads an unsigned 64-bit integer field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {number} The value of the unsigned 64-bit integer field.
|
| + */
|
| +jspb.BinaryReader.prototype.readUint64 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readUnsignedVarint64();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads an unsigned 64-bit integer field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * Returns the value as a string.
|
| + *
|
| + * @return {string} The value of the unsigned 64-bit integer field as a decimal
|
| + * string.
|
| + */
|
| +jspb.BinaryReader.prototype.readUint64String = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readUnsignedVarint64String();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a signed zigzag-encoded 32-bit integer field from the binary stream,
|
| + * or throws an error if the next field in the stream is not of the correct
|
| + * wire type.
|
| + *
|
| + * @return {number} The value of the signed 32-bit integer field.
|
| + */
|
| +jspb.BinaryReader.prototype.readSint32 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readZigzagVarint32();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a signed zigzag-encoded 64-bit integer field from the binary stream,
|
| + * or throws an error if the next field in the stream is not of the correct
|
| + * wire type.
|
| + *
|
| + * @return {number} The value of the signed 64-bit integer field.
|
| + */
|
| +jspb.BinaryReader.prototype.readSint64 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readZigzagVarint64();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads an unsigned 32-bit fixed-length integer fiield from the binary stream,
|
| + * or throws an error if the next field in the stream is not of the correct
|
| + * wire type.
|
| + *
|
| + * @return {number} The value of the double field.
|
| + */
|
| +jspb.BinaryReader.prototype.readFixed32 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED32);
|
| + return this.decoder_.readUint32();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads an unsigned 64-bit fixed-length integer fiield from the binary stream,
|
| + * or throws an error if the next field in the stream is not of the correct
|
| + * wire type.
|
| + *
|
| + * @return {number} The value of the float field.
|
| + */
|
| +jspb.BinaryReader.prototype.readFixed64 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64);
|
| + return this.decoder_.readUint64();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a signed 32-bit fixed-length integer fiield from the binary stream, or
|
| + * throws an error if the next field in the stream is not of the correct wire
|
| + * type.
|
| + *
|
| + * @return {number} The value of the double field.
|
| + */
|
| +jspb.BinaryReader.prototype.readSfixed32 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED32);
|
| + return this.decoder_.readInt32();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a signed 64-bit fixed-length integer fiield from the binary stream, or
|
| + * throws an error if the next field in the stream is not of the correct wire
|
| + * type.
|
| + *
|
| + * @return {number} The value of the float field.
|
| + */
|
| +jspb.BinaryReader.prototype.readSfixed64 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64);
|
| + return this.decoder_.readInt64();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a 32-bit floating-point field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {number} The value of the float field.
|
| + */
|
| +jspb.BinaryReader.prototype.readFloat = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED32);
|
| + return this.decoder_.readFloat();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a 64-bit floating-point field from the binary stream, or throws an
|
| + * error if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {number} The value of the double field.
|
| + */
|
| +jspb.BinaryReader.prototype.readDouble = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64);
|
| + return this.decoder_.readDouble();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a boolean field from the binary stream, or throws an error if the next
|
| + * field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {boolean} The value of the boolean field.
|
| + */
|
| +jspb.BinaryReader.prototype.readBool = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return !!this.decoder_.readUnsignedVarint32();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads an enum field from the binary stream, or throws an error if the next
|
| + * field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {number} The value of the enum field.
|
| + */
|
| +jspb.BinaryReader.prototype.readEnum = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readSignedVarint64();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a string field from the binary stream, or throws an error if the next
|
| + * field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {string} The value of the string field.
|
| + */
|
| +jspb.BinaryReader.prototype.readString = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED);
|
| + var length = this.decoder_.readUnsignedVarint32();
|
| + return this.decoder_.readString(length);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a length-prefixed block of bytes from the binary stream, or returns
|
| + * null if the next field in the stream has an invalid length value.
|
| + *
|
| + * @return {Uint8Array} The block of bytes.
|
| + */
|
| +jspb.BinaryReader.prototype.readBytes = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED);
|
| + var length = this.decoder_.readUnsignedVarint32();
|
| + return this.decoder_.readBytes(length);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a 64-bit varint or fixed64 field from the stream and returns it as a
|
| + * 8-character Unicode string for use as a hash table key, or throws an error
|
| + * if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {string} The hash value.
|
| + */
|
| +jspb.BinaryReader.prototype.readVarintHash64 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT);
|
| + return this.decoder_.readVarintHash64();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a 64-bit varint or fixed64 field from the stream and returns it as a
|
| + * 8-character Unicode string for use as a hash table key, or throws an error
|
| + * if the next field in the stream is not of the correct wire type.
|
| + *
|
| + * @return {string} The hash value.
|
| + */
|
| +jspb.BinaryReader.prototype.readFixedHash64 = function() {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64);
|
| + return this.decoder_.readFixedHash64();
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed scalar field using the supplied raw reader function.
|
| + * @param {function()} decodeMethod
|
| + * @return {!Array}
|
| + * @private
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedField_ = function(decodeMethod) {
|
| + goog.asserts.assert(
|
| + this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED);
|
| + var length = this.decoder_.readUnsignedVarint32();
|
| + var end = this.decoder_.getCursor() + length;
|
| + var result = [];
|
| + while (this.decoder_.getCursor() < end) {
|
| + // TODO(aappleby): .call is slow
|
| + result.push(decodeMethod.call(this.decoder_));
|
| + }
|
| + return result;
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed int32 field, which consists of a length header and a list of
|
| + * signed varints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedInt32 = function() {
|
| + return this.readPackedField_(this.decoder_.readSignedVarint32);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed int32 field, which consists of a length header and a list of
|
| + * signed varints. Returns a list of strings.
|
| + * @return {!Array.<string>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedInt32String = function() {
|
| + return this.readPackedField_(this.decoder_.readSignedVarint32String);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed int64 field, which consists of a length header and a list of
|
| + * signed varints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedInt64 = function() {
|
| + return this.readPackedField_(this.decoder_.readSignedVarint64);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed int64 field, which consists of a length header and a list of
|
| + * signed varints. Returns a list of strings.
|
| + * @return {!Array.<string>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedInt64String = function() {
|
| + return this.readPackedField_(this.decoder_.readSignedVarint64String);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed uint32 field, which consists of a length header and a list of
|
| + * unsigned varints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedUint32 = function() {
|
| + return this.readPackedField_(this.decoder_.readUnsignedVarint32);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed uint32 field, which consists of a length header and a list of
|
| + * unsigned varints. Returns a list of strings.
|
| + * @return {!Array.<string>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedUint32String = function() {
|
| + return this.readPackedField_(this.decoder_.readUnsignedVarint32String);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed uint64 field, which consists of a length header and a list of
|
| + * unsigned varints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedUint64 = function() {
|
| + return this.readPackedField_(this.decoder_.readUnsignedVarint64);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed uint64 field, which consists of a length header and a list of
|
| + * unsigned varints. Returns a list of strings.
|
| + * @return {!Array.<string>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedUint64String = function() {
|
| + return this.readPackedField_(this.decoder_.readUnsignedVarint64String);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed sint32 field, which consists of a length header and a list of
|
| + * zigzag varints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedSint32 = function() {
|
| + return this.readPackedField_(this.decoder_.readZigzagVarint32);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed sint64 field, which consists of a length header and a list of
|
| + * zigzag varints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedSint64 = function() {
|
| + return this.readPackedField_(this.decoder_.readZigzagVarint64);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed fixed32 field, which consists of a length header and a list
|
| + * of unsigned 32-bit ints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedFixed32 = function() {
|
| + return this.readPackedField_(this.decoder_.readUint32);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed fixed64 field, which consists of a length header and a list
|
| + * of unsigned 64-bit ints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedFixed64 = function() {
|
| + return this.readPackedField_(this.decoder_.readUint64);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed sfixed32 field, which consists of a length header and a list
|
| + * of 32-bit ints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedSfixed32 = function() {
|
| + return this.readPackedField_(this.decoder_.readInt32);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed sfixed64 field, which consists of a length header and a list
|
| + * of 64-bit ints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedSfixed64 = function() {
|
| + return this.readPackedField_(this.decoder_.readInt64);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed float field, which consists of a length header and a list of
|
| + * floats.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedFloat = function() {
|
| + return this.readPackedField_(this.decoder_.readFloat);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed double field, which consists of a length header and a list of
|
| + * doubles.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedDouble = function() {
|
| + return this.readPackedField_(this.decoder_.readDouble);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed bool field, which consists of a length header and a list of
|
| + * unsigned varints.
|
| + * @return {!Array.<boolean>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedBool = function() {
|
| + return this.readPackedField_(this.decoder_.readBool);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed enum field, which consists of a length header and a list of
|
| + * unsigned varints.
|
| + * @return {!Array.<number>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedEnum = function() {
|
| + return this.readPackedField_(this.decoder_.readEnum);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed varint hash64 field, which consists of a length header and a
|
| + * list of varint hash64s.
|
| + * @return {!Array.<string>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedVarintHash64 = function() {
|
| + return this.readPackedField_(this.decoder_.readVarintHash64);
|
| +};
|
| +
|
| +
|
| +/**
|
| + * Reads a packed fixed hash64 field, which consists of a length header and a
|
| + * list of fixed hash64s.
|
| + * @return {!Array.<string>}
|
| + */
|
| +jspb.BinaryReader.prototype.readPackedFixedHash64 = function() {
|
| + return this.readPackedField_(this.decoder_.readFixedHash64);
|
| +};
|
|
|