test: add basic tests for MessageChannel

PR-URL: #116
Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
Reviewed-By: Stephen Belanger <admin@stephenbelanger.com>

test/parallel/test-message-channel-sharedarraybuffer.js

@@ -0,0 +1,28 @@
+/*global SharedArrayBuffer*/
+'use strict';
+// Flags: --harmony-sharedarraybuffer --expose-gc
+
+const common = require('../common');
+const assert = require('assert');
+const { Worker } = require('worker');
+
+{
+  const sharedArrayBuffer = new SharedArrayBuffer(12);
+  const local = Buffer.from(sharedArrayBuffer);
+
+  const w = new Worker(`
+    require('worker').on('workerMessage', ({ sharedArrayBuffer }) => {
+      const local = Buffer.from(sharedArrayBuffer);
+      local.write('world!', 6);
+      require('worker').postMessage();
+    });
+  `, { eval: true });
+  w.on('message', common.mustCall(() => {
+    assert.strictEqual(local.toString(), 'Hello world!');
+    global.gc();
+    w.terminate();
+  }));
+  w.postMessage({ sharedArrayBuffer });
+  // This would be a race condition if the memory regions were overlapping
+  local.write('Hello ');
+}

test/parallel/test-message-channel.js

@@ -0,0 +1,45 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const { Worker, MessagePort, MessageChannel } = require('worker');
+
+{
+  const channel = new MessageChannel();
+
+  const w = new Worker(`
+    const { MessagePort } = require('worker');
+    const assert = require('assert');
+    require('worker').on('workerMessage', ({ port }) => {
+      assert(port instanceof MessagePort);
+      port.postMessage('works');
+    });
+  `, { eval: true });
+  w.postMessage({ port: channel.port2 }, [ channel.port2 ]);
+  assert(channel.port1 instanceof MessagePort);
+  assert(channel.port2 instanceof MessagePort);
+  channel.port1.on('message', common.mustCall((message) => {
+    assert.strictEqual(message, 'works');
+    w.terminate();
+  }));
+}
+
+{
+  const channel = new MessageChannel();
+
+  channel.port1.on('message', common.mustCall(({ typedArray }) => {
+    assert.deepStrictEqual(typedArray, new Uint8Array([0, 1, 2, 3, 4]));
+  }));
+
+  const typedArray = new Uint8Array([0, 1, 2, 3, 4]);
+  channel.port2.postMessage({ typedArray }, [ typedArray.buffer ]);
+  assert.strictEqual(typedArray.buffer.byteLength, 0);
+  channel.port2.close();
+}
+
+{
+  const channel = new MessageChannel();
+
+  channel.port1.on('close', common.mustCall());
+  channel.port2.on('close', common.mustCall());
+  channel.port2.close();
+}