d8 Worker test of SharedArrayBuffer transferring

test/mjsunit/d8-worker-sharedarraybuffer.js

 // Copyright 2015 the V8 project authors. All rights reserved.
 // 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.
 
+// Flags: --harmony-sharedarraybuffer --harmony-atomics
+
+function f() {
+  onmessage = function(m) {
+    var sab = m;
+    var ta = new Uint32Array(sab);
+    if (sab.byteLength !== 16) {
+      throw new Error("SharedArrayBuffer transfer byteLength");
+    }
+
+    for (var i = 0; i < 4; ++i) {
+      if (ta[i] !== i) {
+        throw new Error("SharedArrayBuffer transfer value " + i);
+      }
+    }
+
+    // Atomically update ta[0]
+    Atomics.store(ta, 0, 100);
+  };
+}
+
 if (this.Worker) {
-  function f() {
-    var g = function () {
-      postMessage(42);
-    };
+  var w = new Worker(f);
 
-    var w = new Worker(g);
-
-    onmessage = function(parentMsg) {
-      w.postMessage(parentMsg);
-      var childMsg = w.getMessage();
-      postMessage(childMsg);
-    };
+  var sab = new SharedArrayBuffer(16);
+  var ta = new Uint32Array(sab);
+  for (var i = 0; i < 4; ++i) {
+    ta[i] = i;
   }
 
-  var w = new Worker(f);
-  w.postMessage(9);
-  assertEquals(42, w.getMessage());
+  // Transfer SharedArrayBuffer
+  w.postMessage(sab, [sab]);
+  assertEquals(16, sab.byteLength);  // ArrayBuffer should not be neutered.
+
+  // Spinwait for the worker to update ta[0]
+  var ta0;
+  while ((ta0 = Atomics.load(ta, 0)) == 0) {}
+
+  assertEquals(100, ta0);
+
+  w.terminate();
+
+  assertEquals(16, sab.byteLength);  // Still not neutered.
 }