123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222 |
- // sizeof(T).
- var SIZE_INT32 = 4
- var SIZE_UINT32 = 4
- var SIZE_INT64 = 8
- var SIZE_UINT64 = 8
- var SIZE_FLOAT = 4
- var SIZE_DOUBLE = 8
-
- // The allocation granularity of the payload.
- var PAYLOAD_UNIT = 64
-
- // Largest JS number.
- var CAPACITY_READ_ONLY = 9007199254740992
-
- // Aligns 'i' by rounding it up to the next multiple of 'alignment'.
- var alignInt = function (i, alignment) {
- return i + (alignment - (i % alignment)) % alignment
- }
-
- // PickleIterator reads data from a Pickle. The Pickle object must remain valid
- // while the PickleIterator object is in use.
- var PickleIterator = (function () {
- function PickleIterator (pickle) {
- this.payload = pickle.header
- this.payloadOffset = pickle.headerSize
- this.readIndex = 0
- this.endIndex = pickle.getPayloadSize()
- }
-
- PickleIterator.prototype.readBool = function () {
- return this.readInt() !== 0
- }
-
- PickleIterator.prototype.readInt = function () {
- return this.readBytes(SIZE_INT32, Buffer.prototype.readInt32LE)
- }
-
- PickleIterator.prototype.readUInt32 = function () {
- return this.readBytes(SIZE_UINT32, Buffer.prototype.readUInt32LE)
- }
-
- PickleIterator.prototype.readInt64 = function () {
- return this.readBytes(SIZE_INT64, Buffer.prototype.readInt64LE)
- }
-
- PickleIterator.prototype.readUInt64 = function () {
- return this.readBytes(SIZE_UINT64, Buffer.prototype.readUInt64LE)
- }
-
- PickleIterator.prototype.readFloat = function () {
- return this.readBytes(SIZE_FLOAT, Buffer.prototype.readFloatLE)
- }
-
- PickleIterator.prototype.readDouble = function () {
- return this.readBytes(SIZE_DOUBLE, Buffer.prototype.readDoubleLE)
- }
-
- PickleIterator.prototype.readString = function () {
- return this.readBytes(this.readInt()).toString()
- }
-
- PickleIterator.prototype.readBytes = function (length, method) {
- var readPayloadOffset = this.getReadPayloadOffsetAndAdvance(length)
- if (method != null) {
- return method.call(this.payload, readPayloadOffset, length)
- } else {
- return this.payload.slice(readPayloadOffset, readPayloadOffset + length)
- }
- }
-
- PickleIterator.prototype.getReadPayloadOffsetAndAdvance = function (length) {
- if (length > this.endIndex - this.readIndex) {
- this.readIndex = this.endIndex
- throw new Error('Failed to read data with length of ' + length)
- }
- var readPayloadOffset = this.payloadOffset + this.readIndex
- this.advance(length)
- return readPayloadOffset
- }
-
- PickleIterator.prototype.advance = function (size) {
- var alignedSize = alignInt(size, SIZE_UINT32)
- if (this.endIndex - this.readIndex < alignedSize) {
- this.readIndex = this.endIndex
- } else {
- this.readIndex += alignedSize
- }
- }
-
- return PickleIterator
- })()
-
- // This class provides facilities for basic binary value packing and unpacking.
- //
- // The Pickle class supports appending primitive values (ints, strings, etc.)
- // to a pickle instance. The Pickle instance grows its internal memory buffer
- // dynamically to hold the sequence of primitive values. The internal memory
- // buffer is exposed as the "data" of the Pickle. This "data" can be passed
- // to a Pickle object to initialize it for reading.
- //
- // When reading from a Pickle object, it is important for the consumer to know
- // what value types to read and in what order to read them as the Pickle does
- // not keep track of the type of data written to it.
- //
- // The Pickle's data has a header which contains the size of the Pickle's
- // payload. It can optionally support additional space in the header. That
- // space is controlled by the header_size parameter passed to the Pickle
- // constructor.
- var Pickle = (function () {
- function Pickle (buffer) {
- if (buffer) {
- this.initFromBuffer(buffer)
- } else {
- this.initEmpty()
- }
- }
-
- Pickle.prototype.initEmpty = function () {
- this.header = new Buffer(0)
- this.headerSize = SIZE_UINT32
- this.capacityAfterHeader = 0
- this.writeOffset = 0
- this.resize(PAYLOAD_UNIT)
- this.setPayloadSize(0)
- }
-
- Pickle.prototype.initFromBuffer = function (buffer) {
- this.header = buffer
- this.headerSize = buffer.length - this.getPayloadSize()
- this.capacityAfterHeader = CAPACITY_READ_ONLY
- this.writeOffset = 0
- if (this.headerSize > buffer.length) {
- this.headerSize = 0
- }
- if (this.headerSize !== alignInt(this.headerSize, SIZE_UINT32)) {
- this.headerSize = 0
- }
- if (this.headerSize === 0) {
- this.header = new Buffer(0)
- }
- }
-
- Pickle.prototype.createIterator = function () {
- return new PickleIterator(this)
- }
-
- Pickle.prototype.toBuffer = function () {
- return this.header.slice(0, this.headerSize + this.getPayloadSize())
- }
-
- Pickle.prototype.writeBool = function (value) {
- return this.writeInt(value ? 1 : 0)
- }
-
- Pickle.prototype.writeInt = function (value) {
- return this.writeBytes(value, SIZE_INT32, Buffer.prototype.writeInt32LE)
- }
-
- Pickle.prototype.writeUInt32 = function (value) {
- return this.writeBytes(value, SIZE_UINT32, Buffer.prototype.writeUInt32LE)
- }
-
- Pickle.prototype.writeInt64 = function (value) {
- return this.writeBytes(value, SIZE_INT64, Buffer.prototype.writeInt64LE)
- }
-
- Pickle.prototype.writeUInt64 = function (value) {
- return this.writeBytes(value, SIZE_UINT64, Buffer.prototype.writeUInt64LE)
- }
-
- Pickle.prototype.writeFloat = function (value) {
- return this.writeBytes(value, SIZE_FLOAT, Buffer.prototype.writeFloatLE)
- }
-
- Pickle.prototype.writeDouble = function (value) {
- return this.writeBytes(value, SIZE_DOUBLE, Buffer.prototype.writeDoubleLE)
- }
-
- Pickle.prototype.writeString = function (value) {
- var length = Buffer.byteLength(value, 'utf8')
- if (!this.writeInt(length)) {
- return false
- }
- return this.writeBytes(value, length)
- }
-
- Pickle.prototype.setPayloadSize = function (payloadSize) {
- return this.header.writeUInt32LE(payloadSize, 0)
- }
-
- Pickle.prototype.getPayloadSize = function () {
- return this.header.readUInt32LE(0)
- }
-
- Pickle.prototype.writeBytes = function (data, length, method) {
- var dataLength = alignInt(length, SIZE_UINT32)
- var newSize = this.writeOffset + dataLength
- if (newSize > this.capacityAfterHeader) {
- this.resize(Math.max(this.capacityAfterHeader * 2, newSize))
- }
- if (method != null) {
- method.call(this.header, data, this.headerSize + this.writeOffset)
- } else {
- this.header.write(data, this.headerSize + this.writeOffset, length)
- }
- var endOffset = this.headerSize + this.writeOffset + length
- this.header.fill(0, endOffset, endOffset + dataLength - length)
- this.setPayloadSize(newSize)
- this.writeOffset = newSize
- return true
- }
-
- Pickle.prototype.resize = function (newCapacity) {
- newCapacity = alignInt(newCapacity, PAYLOAD_UNIT)
- this.header = Buffer.concat([this.header, new Buffer(newCapacity)])
- this.capacityAfterHeader = newCapacity
- }
-
- return Pickle
- })()
-
- module.exports = Pickle
|