Add m-esr52 at 52.6.0

1 files changed, 157 insertions, 0 deletions

diff --git a/xpcom/tests/unit/test_streams.js b/xpcom/tests/unit/test_streams.js
new file mode 100644
index 000000000..e668cb8d5
--- /dev/null
+++ b/xpcom/tests/unit/test_streams.js
@@ -0,0 +1,157 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+var Ci = Components.interfaces;
+var Cr = Components.results;
+var CC = Components.Constructor;
+
+var Pipe = CC("@mozilla.org/pipe;1",
+              "nsIPipe",
+              "init");
+var BinaryOutput = CC("@mozilla.org/binaryoutputstream;1",
+                      "nsIBinaryOutputStream",
+                      "setOutputStream");
+var BinaryInput = CC("@mozilla.org/binaryinputstream;1",
+                     "nsIBinaryInputStream",
+                     "setInputStream");
+
+/**
+ * Binary stream tests.
+ */
+function test_binary_streams() {
+  var p, is, os;
+
+  p = new Pipe(false, false, 1024, 1, null);
+  is = new BinaryInput(p.inputStream);
+  os = new BinaryOutput(p.outputStream);
+
+  const LargeNum = Math.pow(2, 18) + Math.pow(2, 12) + 1;
+  const HugeNum = Math.pow(2, 62);
+  const HelloStr = "Hello World";
+  const HelloArray = Array.map(HelloStr, function(c) {return c.charCodeAt(0)});
+  var countObj = {};
+  var msg = {};
+  var buffer = new ArrayBuffer(HelloArray.length);
+
+  // Test reading immediately after writing.
+  os.writeBoolean(true);
+  do_check_eq(is.readBoolean(), true);
+  os.write8(4);
+  do_check_eq(is.read8(), 4);
+  os.write16(4);
+  do_check_eq(is.read16(), 4);
+  os.write16(1024);
+  do_check_eq(is.read16(), 1024);
+  os.write32(7);
+  do_check_eq(is.read32(), 7);
+  os.write32(LargeNum);
+  do_check_eq(is.read32(), LargeNum);
+  os.write64(LargeNum);
+  do_check_eq(is.read64(), LargeNum);
+  os.write64(1024);
+  do_check_eq(is.read64(), 1024);
+  os.write64(HugeNum);
+  do_check_eq(is.read64(), HugeNum);
+  os.writeFloat(2.5);
+  do_check_eq(is.readFloat(), 2.5);
+//  os.writeDouble(Math.SQRT2);
+//  do_check_eq(is.readDouble(), Math.SQRT2);
+  os.writeStringZ("Mozilla");
+  do_check_eq(is.readCString(), "Mozilla");
+  os.writeWStringZ("Gecko");
+  do_check_eq(is.readString(), "Gecko");
+  os.writeBytes(HelloStr, HelloStr.length);
+  do_check_eq(is.available(), HelloStr.length);
+  msg = is.readBytes(HelloStr.length);
+  do_check_eq(msg, HelloStr);
+  msg = null;
+  countObj.value = -1;
+  os.writeByteArray(HelloArray, HelloArray.length);
+  do_check_eq(is.available(), HelloStr.length);
+  msg = is.readByteArray(HelloStr.length)
+  do_check_eq(typeof msg, typeof HelloArray);
+  do_check_eq(msg.toSource(), HelloArray.toSource());
+  do_check_eq(is.available(), 0);
+  os.writeByteArray(HelloArray, HelloArray.length);
+  do_check_eq(is.readArrayBuffer(buffer.byteLength, buffer), HelloArray.length);
+  do_check_eq([...(new Uint8Array(buffer))].toSource(), HelloArray.toSource());
+  do_check_eq(is.available(), 0);
+
+  // Test writing in one big chunk.
+  os.writeBoolean(true);
+  os.write8(4);
+  os.write16(4);
+  os.write16(1024);
+  os.write32(7);
+  os.write32(LargeNum);
+  os.write64(LargeNum);
+  os.write64(1024);
+  os.write64(HugeNum);
+  os.writeFloat(2.5);
+//  os.writeDouble(Math.SQRT2);
+  os.writeStringZ("Mozilla");
+  os.writeWStringZ("Gecko");
+  os.writeBytes(HelloStr, HelloStr.length);
+  os.writeByteArray(HelloArray, HelloArray.length);
+  // Available should not be zero after a long write like this.
+  do_check_neq(is.available(), 0);
+
+  // Test reading in one big chunk.
+  do_check_eq(is.readBoolean(), true);
+  do_check_eq(is.read8(), 4);
+  do_check_eq(is.read16(), 4);
+  do_check_eq(is.read16(), 1024);
+  do_check_eq(is.read32(), 7);
+  do_check_eq(is.read32(), LargeNum);
+  do_check_eq(is.read64(), LargeNum);
+  do_check_eq(is.read64(), 1024);
+  do_check_eq(is.read64(), HugeNum);
+  do_check_eq(is.readFloat(), 2.5);
+//  do_check_eq(is.readDouble(), Math.SQRT2);
+  do_check_eq(is.readCString(), "Mozilla");
+  do_check_eq(is.readString(), "Gecko");
+  // Remember, we wrote HelloStr twice - once as a string, and then as an array.
+  do_check_eq(is.available(), HelloStr.length * 2);
+  msg = is.readBytes(HelloStr.length);
+  do_check_eq(msg, HelloStr);
+  msg = null;
+  countObj.value = -1;
+  do_check_eq(is.available(), HelloStr.length);
+  msg = is.readByteArray(HelloStr.length)
+  do_check_eq(typeof msg, typeof HelloArray);
+  do_check_eq(msg.toSource(), HelloArray.toSource());
+  do_check_eq(is.available(), 0);
+  
+  // Test for invalid actions.
+  os.close();
+  is.close();
+
+  try {
+    os.writeBoolean(false);
+    do_throw("Not reached!");
+  } catch (e if (e instanceof Ci.nsIException &&
+                 e.result == Cr.NS_BASE_STREAM_CLOSED)) {
+    // do nothing
+  }
+
+  try {
+    is.available();
+    do_throw("Not reached!");
+  } catch (e if (e instanceof Ci.nsIException &&
+                 e.result == Cr.NS_BASE_STREAM_CLOSED)) {
+    // do nothing
+  }
+
+  try {
+    is.readBoolean();
+    do_throw("Not reached!");
+  } catch (e if (e instanceof Ci.nsIException &&
+                 e.result == Cr.NS_ERROR_FAILURE)) {
+    // do nothing
+  }
+}
+
+function run_test() {
+  test_binary_streams();
+}