summaryrefslogtreecommitdiff
path: root/js/src/Ice/Buffer.js
diff options
context:
space:
mode:
Diffstat (limited to 'js/src/Ice/Buffer.js')
-rw-r--r--js/src/Ice/Buffer.js731
1 files changed, 364 insertions, 367 deletions
diff --git a/js/src/Ice/Buffer.js b/js/src/Ice/Buffer.js
index 71c4f614bc6..a48cf6fd347 100644
--- a/js/src/Ice/Buffer.js
+++ b/js/src/Ice/Buffer.js
@@ -16,414 +16,411 @@
// Define Node.Buffer as an alias to NodeJS global Buffer type,
// that allow us to refer to Ice.Buffer as Buffer in this file.
//
-(function(global){
- var Node = { Buffer: global.Buffer };
+var Node = { Buffer: global.Buffer };
- require("Ice/Long");
- require("Ice/Class");
-
- var Ice = global.Ice || {};
- var Long = Ice.Long;
-
- var __BufferOverflowException__ = "BufferOverflowException";
- var __BufferUnderflowException__ = "BufferUnderflowException";
- var __IndexOutOfBoundsException__ = "IndexOutOfBoundsException";
+var Ice = require("../Ice/ModuleRegistry").Ice;
+Ice.__M.require(module, "Ice", ["../Ice/Long", "../Ice/Class"]);
- var Buffer = Ice.Class({
- __init__: function(buffer)
+var Long = Ice.Long;
+
+var __BufferOverflowException__ = "BufferOverflowException";
+var __BufferUnderflowException__ = "BufferUnderflowException";
+var __IndexOutOfBoundsException__ = "IndexOutOfBoundsException";
+
+var Buffer = Ice.Class({
+ __init__: function(buffer)
+ {
+ if(buffer !== undefined)
{
- if(buffer !== undefined)
- {
- this.b = buffer;
- }
- else
- {
- this.b = null;
- }
- this._position = 0;
- this._limit = 0;
- this._shrinkCounter = 0;
- },
- empty: function()
+ this.b = buffer;
+ }
+ else
{
- return this._limit === 0;
- },
- resize: function(n)
+ this.b = null;
+ }
+ this._position = 0;
+ this._limit = 0;
+ this._shrinkCounter = 0;
+ },
+ empty: function()
+ {
+ return this._limit === 0;
+ },
+ resize: function(n)
+ {
+ if(n === 0)
{
- if(n === 0)
- {
- this.clear();
- }
- else if(n > this.capacity)
- {
- this.reserve(n);
- }
- this._limit = n;
- },
- clear: function()
+ this.clear();
+ }
+ else if(n > this.capacity)
{
- this.b = null;
- this._position = 0;
- this._limit = 0;
- },
- //
- // Call expand(n) to add room for n additional bytes. Note that expand()
- // examines the current position of the buffer first; we don't want to
- // expand the buffer if the caller is writing to a location that is
- // already in the buffer.
- //
- expand: function(n)
+ this.reserve(n);
+ }
+ this._limit = n;
+ },
+ clear: function()
+ {
+ this.b = null;
+ this._position = 0;
+ this._limit = 0;
+ },
+ //
+ // Call expand(n) to add room for n additional bytes. Note that expand()
+ // examines the current position of the buffer first; we don't want to
+ // expand the buffer if the caller is writing to a location that is
+ // already in the buffer.
+ //
+ expand: function(n)
+ {
+ var sz = this.capacity === 0 ? n : this._position + n;
+ if(sz > this._limit)
{
- var sz = this.capacity === 0 ? n : this._position + n;
- if(sz > this._limit)
- {
- this.resize(sz);
- }
- },
- reset: function()
+ this.resize(sz);
+ }
+ },
+ reset: function()
+ {
+ if(this._limit > 0 && this._limit * 2 < this.capacity)
{
- if(this._limit > 0 && this._limit * 2 < this.capacity)
- {
- //
- // If the current buffer size is smaller than the
- // buffer capacity, we shrink the buffer memory to the
- // current size. This is to avoid holding on to too much
- // memory if it's not needed anymore.
- //
- if(++this._shrinkCounter > 2)
- {
- this.reserve(this._limit);
- this._shrinkCounter = 0;
- }
- }
- else
+ //
+ // If the current buffer size is smaller than the
+ // buffer capacity, we shrink the buffer memory to the
+ // current size. This is to avoid holding on to too much
+ // memory if it's not needed anymore.
+ //
+ if(++this._shrinkCounter > 2)
{
+ this.reserve(this._limit);
this._shrinkCounter = 0;
}
- this._limit = 0;
- this._position = 0;
- },
- reserve: function(n)
+ }
+ else
{
- var b, capacity;
- if(n > this.capacity)
- {
- capacity = Math.max(n, 2 * this.capacity);
- capacity = Math.max(1024, capacity);
- if(this.b === null)
- {
- this.b = new Node.Buffer(capacity);
- }
- else
- {
- b = new Node.Buffer(capacity);
- this.b.copy(b);
- this.b = b;
- }
- }
- else if(n < this.capacity)
+ this._shrinkCounter = 0;
+ }
+ this._limit = 0;
+ this._position = 0;
+ },
+ reserve: function(n)
+ {
+ var b, capacity;
+ if(n > this.capacity)
+ {
+ capacity = Math.max(n, 2 * this.capacity);
+ capacity = Math.max(1024, capacity);
+ if(this.b === null)
{
- this.b = this.b.slice(0, this.capacity);
+ this.b = new Node.Buffer(capacity);
}
else
{
- return;
+ b = new Node.Buffer(capacity);
+ this.b.copy(b);
+ this.b = b;
}
- },
- put: function(v)
+ }
+ else if(n < this.capacity)
{
- if(this._position === this._limit)
- {
- throw new Error(__BufferOverflowException__);
- }
- this.b.writeUInt8(v, this._position, true);
- this._position++;
- },
- putAt: function(i, v)
+ this.b = this.b.slice(0, this.capacity);
+ }
+ else
{
- if(i >= this._limit)
- {
- throw new Error(__IndexOutOfBoundsException__);
- }
- this.b.writeUInt8(v, i, true);
- },
- putArray: function(v)
+ return;
+ }
+ },
+ put: function(v)
+ {
+ if(this._position === this._limit)
{
- //Expects a Nodejs Buffer
- if(this._position + v.length > this._limit)
- {
- throw new Error(__BufferOverflowException__);
- }
- v.copy(this.b, this._position);
- this._position += v.length;
- },
- putShort: function(v)
+ throw new Error(__BufferOverflowException__);
+ }
+ this.b.writeUInt8(v, this._position, true);
+ this._position++;
+ },
+ putAt: function(i, v)
+ {
+ if(i >= this._limit)
{
- if(this._position + 2 > this._limit)
- {
- throw new Error(__BufferOverflowException__);
- }
- this.b.writeInt16LE(v, this._position, true);
- this._position += 2;
- },
- putShortAt: function(i, v)
+ throw new Error(__IndexOutOfBoundsException__);
+ }
+ this.b.writeUInt8(v, i, true);
+ },
+ putArray: function(v)
+ {
+ //Expects a Nodejs Buffer
+ if(this._position + v.length > this._limit)
{
- if(i + 2 > this._limit || i < 0)
- {
- throw new Error(__IndexOutOfBoundsException__);
- }
- this.b.writeInt16LE(v, i, true);
- },
- putInt: function(v)
+ throw new Error(__BufferOverflowException__);
+ }
+ v.copy(this.b, this._position);
+ this._position += v.length;
+ },
+ putShort: function(v)
+ {
+ if(this._position + 2 > this._limit)
{
- if(this._position + 4 > this._limit)
- {
- throw new Error(__BufferOverflowException__);
- }
- this.b.writeInt32LE(v, this._position, true);
- this._position += 4;
- },
- putIntAt: function(i, v)
+ throw new Error(__BufferOverflowException__);
+ }
+ this.b.writeInt16LE(v, this._position, true);
+ this._position += 2;
+ },
+ putShortAt: function(i, v)
+ {
+ if(i + 2 > this._limit || i < 0)
{
- if(i + 4 > this._limit || i < 0)
- {
- throw new Error(__IndexOutOfBoundsException__);
- }
- this.b.writeInt32LE(v, i, true);
- },
- putFloat: function(v)
+ throw new Error(__IndexOutOfBoundsException__);
+ }
+ this.b.writeInt16LE(v, i, true);
+ },
+ putInt: function(v)
+ {
+ if(this._position + 4 > this._limit)
{
- if(this._position + 4 > this._limit)
- {
- throw new Error(__BufferOverflowException__);
- }
- this.b.writeFloatLE(v, this._position, true);
- this._position += 4;
- },
- putFloatAt: function(i, v)
+ throw new Error(__BufferOverflowException__);
+ }
+ this.b.writeInt32LE(v, this._position, true);
+ this._position += 4;
+ },
+ putIntAt: function(i, v)
+ {
+ if(i + 4 > this._limit || i < 0)
{
- if(i + 4 > this._limit || i < 0)
- {
- throw new Error(__IndexOutOfBoundsException__);
- }
- this.b.writeFloatLE(v, i, true);
- },
- putDouble: function(v)
+ throw new Error(__IndexOutOfBoundsException__);
+ }
+ this.b.writeInt32LE(v, i, true);
+ },
+ putFloat: function(v)
+ {
+ if(this._position + 4 > this._limit)
{
- if(this._position + 8 > this._limit)
- {
- throw new Error(__BufferOverflowException__);
- }
- this.b.writeDoubleLE(v, this._position, true);
- this._position += 8;
- },
- putDoubleAt: function(i, v)
+ throw new Error(__BufferOverflowException__);
+ }
+ this.b.writeFloatLE(v, this._position, true);
+ this._position += 4;
+ },
+ putFloatAt: function(i, v)
+ {
+ if(i + 4 > this._limit || i < 0)
{
- if(i + 8 > this._limit || i < 0)
- {
- throw new Error(__IndexOutOfBoundsException__);
- }
- this.b.writeDoubleLE(v, i, true);
- },
- putLong: function(v)
+ throw new Error(__IndexOutOfBoundsException__);
+ }
+ this.b.writeFloatLE(v, i, true);
+ },
+ putDouble: function(v)
+ {
+ if(this._position + 8 > this._limit)
{
- if(this._position + 8 > this._limit)
- {
- throw new Error(__BufferOverflowException__);
- }
- this.b.writeUInt32LE(v.low, this._position, true);
- this._position += 4;
- this.b.writeUInt32LE(v.high, this._position, true);
- this._position += 4;
- },
- putLongAt: function(i, v)
- {
- if(i + 8 > this._limit || i < 0)
- {
- throw new Error(__IndexOutOfBoundsException__);
- }
- this.b.writeUInt32LE(v.low, i, true);
- this.b.writeUInt32LE(v.high, i + 4, true);
- },
- writeString: function(stream, v)
- {
- var sz = Node.Buffer.byteLength(v);
- stream.writeSize(sz);
- stream.expand(sz);
- this.putString(v, sz);
- },
- putString: function(v, sz)
- {
- if(this._position + sz > this._limit)
- {
- throw new Error(__BufferOverflowException__);
- }
- var bytes = this.b.write(v, this._position);
- //
- // Check all bytes were written
- //
- if(bytes < sz)
- {
- throw new Error(__IndexOutOfBoundsException__);
- }
- this._position += sz;
- },
- get: function()
+ throw new Error(__BufferOverflowException__);
+ }
+ this.b.writeDoubleLE(v, this._position, true);
+ this._position += 8;
+ },
+ putDoubleAt: function(i, v)
+ {
+ if(i + 8 > this._limit || i < 0)
{
- if(this._position >= this._limit)
- {
- throw new Error(__BufferUnderflowException__);
- }
- var v = this.b.readUInt8(this._position, true);
- this._position++;
- return v;
- },
- getAt: function(i)
+ throw new Error(__IndexOutOfBoundsException__);
+ }
+ this.b.writeDoubleLE(v, i, true);
+ },
+ putLong: function(v)
+ {
+ if(this._position + 8 > this._limit)
{
- if(i < 0 || i >= this._limit)
- {
- throw new Error(__IndexOutOfBoundsException__);
- }
- return this.b.readUInt8(i, true);
- },
- getArray: function(length)
+ throw new Error(__BufferOverflowException__);
+ }
+ this.b.writeUInt32LE(v.low, this._position, true);
+ this._position += 4;
+ this.b.writeUInt32LE(v.high, this._position, true);
+ this._position += 4;
+ },
+ putLongAt: function(i, v)
+ {
+ if(i + 8 > this._limit || i < 0)
{
- if(this._position + length > this._limit)
- {
- throw new Error(__BufferUnderflowException__);
- }
- var buffer = new Node.Buffer(length);
- this.b.slice(this._position, this._position + length).copy(buffer);
- this._position += length;
- return buffer;
- },
- getArrayAt: function(position, length)
- {
- if(position + length > this._limit)
- {
- throw new Error(__BufferUnderflowException__);
- }
- var buffer = new Node.Buffer(length);
- length = length === undefined ? (this.b.length - position) : length;
- this.b.slice(position, position + length).copy(buffer);
- return buffer;
- },
- getShort: function()
- {
- var v;
- if(this._limit - this._position < 2)
- {
- throw new Error(__BufferUnderflowException__);
- }
- v = this.b.readInt16LE(this._position, true);
- this._position += 2;
- return v;
- },
- getInt: function()
- {
- var v;
- if(this._limit - this._position < 4)
- {
- throw new Error(__BufferUnderflowException__);
- }
- v = this.b.readInt32LE(this._position, true);
- this._position += 4;
- return v;
- },
- getFloat: function()
+ throw new Error(__IndexOutOfBoundsException__);
+ }
+ this.b.writeUInt32LE(v.low, i, true);
+ this.b.writeUInt32LE(v.high, i + 4, true);
+ },
+ writeString: function(stream, v)
+ {
+ var sz = Node.Buffer.byteLength(v);
+ stream.writeSize(sz);
+ stream.expand(sz);
+ this.putString(v, sz);
+ },
+ putString: function(v, sz)
+ {
+ if(this._position + sz > this._limit)
{
- if(this._limit - this._position < 4)
- {
- throw new Error(__BufferUnderflowException__);
- }
- var v = this.b.readFloatLE(this._position, true);
- this._position += 4;
- return v;
- },
- getDouble: function()
+ throw new Error(__BufferOverflowException__);
+ }
+ var bytes = this.b.write(v, this._position);
+ //
+ // Check all bytes were written
+ //
+ if(bytes < sz)
{
- if(this._limit - this._position < 8)
- {
- throw new Error(__BufferUnderflowException__);
- }
- var v = this.b.readDoubleLE(this._position, true);
- this._position += 8;
- return v;
- },
- getLong: function()
+ throw new Error(__IndexOutOfBoundsException__);
+ }
+ this._position += sz;
+ },
+ get: function()
+ {
+ if(this._position >= this._limit)
{
- if(this._limit - this._position < 8)
- {
- throw new Error(__BufferUnderflowException__);
- }
- var v = new Long();
- v.low = this.b.readUInt32LE(this._position, true);
- this._position += 4;
- v.high = this.b.readUInt32LE(this._position, true);
- this._position += 4;
- return v;
- },
- getString: function(length)
- {
- if(this._position + length > this._limit)
- {
- throw new Error(__BufferUnderflowException__);
- }
- var s =this.b.toString("utf8", this._position, this._position + length);
- this._position += length;
- return s;
- }
- });
-
- var prototype = Buffer.prototype;
-
- Object.defineProperty(prototype, "position", {
- get: function() { return this._position; },
- set: function(position){
- if(position >= 0 && position <= this._limit)
- {
- this._position = position;
- }
+ throw new Error(__BufferUnderflowException__);
}
- });
-
- Object.defineProperty(prototype, "limit", {
- get: function() { return this._limit; },
- set: function(limit){
- if(limit <= this.capacity)
- {
- this._limit = limit;
- if(this._position > limit)
- {
- this._position = limit;
- }
- }
+ var v = this.b.readUInt8(this._position, true);
+ this._position++;
+ return v;
+ },
+ getAt: function(i)
+ {
+ if(i < 0 || i >= this._limit)
+ {
+ throw new Error(__IndexOutOfBoundsException__);
+ }
+ return this.b.readUInt8(i, true);
+ },
+ getArray: function(length)
+ {
+ if(this._position + length > this._limit)
+ {
+ throw new Error(__BufferUnderflowException__);
+ }
+ var buffer = new Node.Buffer(length);
+ this.b.slice(this._position, this._position + length).copy(buffer);
+ this._position += length;
+ return buffer;
+ },
+ getArrayAt: function(position, length)
+ {
+ if(position + length > this._limit)
+ {
+ throw new Error(__BufferUnderflowException__);
+ }
+ var buffer = new Node.Buffer(length);
+ length = length === undefined ? (this.b.length - position) : length;
+ this.b.slice(position, position + length).copy(buffer);
+ return buffer;
+ },
+ getShort: function()
+ {
+ var v;
+ if(this._limit - this._position < 2)
+ {
+ throw new Error(__BufferUnderflowException__);
+ }
+ v = this.b.readInt16LE(this._position, true);
+ this._position += 2;
+ return v;
+ },
+ getInt: function()
+ {
+ var v;
+ if(this._limit - this._position < 4)
+ {
+ throw new Error(__BufferUnderflowException__);
+ }
+ v = this.b.readInt32LE(this._position, true);
+ this._position += 4;
+ return v;
+ },
+ getFloat: function()
+ {
+ if(this._limit - this._position < 4)
+ {
+ throw new Error(__BufferUnderflowException__);
+ }
+ var v = this.b.readFloatLE(this._position, true);
+ this._position += 4;
+ return v;
+ },
+ getDouble: function()
+ {
+ if(this._limit - this._position < 8)
+ {
+ throw new Error(__BufferUnderflowException__);
+ }
+ var v = this.b.readDoubleLE(this._position, true);
+ this._position += 8;
+ return v;
+ },
+ getLong: function()
+ {
+ if(this._limit - this._position < 8)
+ {
+ throw new Error(__BufferUnderflowException__);
}
- });
+ var v = new Long();
+ v.low = this.b.readUInt32LE(this._position, true);
+ this._position += 4;
+ v.high = this.b.readUInt32LE(this._position, true);
+ this._position += 4;
+ return v;
+ },
+ getString: function(length)
+ {
+ if(this._position + length > this._limit)
+ {
+ throw new Error(__BufferUnderflowException__);
+ }
+ var s =this.b.toString("utf8", this._position, this._position + length);
+ this._position += length;
+ return s;
+ }
+});
- Object.defineProperty(prototype, "capacity", {
- get: function() { return this.b === null ? 0 : this.b.length; }
- });
+var prototype = Buffer.prototype;
- Object.defineProperty(prototype, "remaining", {
- get: function() { return this._limit - this._position; }
- });
-
- //
- // Create a native buffer from an array of bytes.
- //
- Buffer.createNative = function(data)
- {
- if(data === undefined)
+Object.defineProperty(prototype, "position", {
+ get: function() { return this._position; },
+ set: function(position){
+ if(position >= 0 && position <= this._limit)
{
- return new Node.Buffer(0);
+ this._position = position;
}
- else
+ }
+});
+
+Object.defineProperty(prototype, "limit", {
+ get: function() { return this._limit; },
+ set: function(limit){
+ if(limit <= this.capacity)
{
- return new Node.Buffer(data);
+ this._limit = limit;
+ if(this._position > limit)
+ {
+ this._position = limit;
+ }
}
- };
+ }
+});
+
+Object.defineProperty(prototype, "capacity", {
+ get: function() { return this.b === null ? 0 : this.b.length; }
+});
+
+Object.defineProperty(prototype, "remaining", {
+ get: function() { return this._limit - this._position; }
+});
+
+//
+// Create a native buffer from an array of bytes.
+//
+Buffer.createNative = function(data)
+{
+ if(data === undefined)
+ {
+ return new Node.Buffer(0);
+ }
+ else
+ {
+ return new Node.Buffer(data);
+ }
+};
- Ice.Buffer = Buffer;
- global.Ice = Ice;
-}(typeof (global) === "undefined" ? window : global));
+Ice.Buffer = Buffer;
+module.exports.Ice = Ice;
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 23:09:37 +0000