d8-worker-sharedarraybuffer.js 3.49 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27
// 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.

28
// Flags: --harmony-sharedarraybuffer
29

30
if (this.Worker) {
31
  (function TestClone() {
32 33
    var workerScript =
      `onmessage = function(m) {
34 35 36
        var sab = m;
        var ta = new Uint32Array(sab);
        if (sab.byteLength !== 16) {
37
          throw new Error('SharedArrayBuffer clone byteLength');
38 39 40
        }
        for (var i = 0; i < 4; ++i) {
          if (ta[i] !== i) {
41
            throw new Error('SharedArrayBuffer clone value ' + i);
42 43
          }
        }
44 45 46 47
        // Atomically update ta[0]
        Atomics.store(ta, 0, 100);
      };`;

48
    var w = new Worker(workerScript, {type: 'string'});
49 50 51 52 53 54 55

    var sab = new SharedArrayBuffer(16);
    var ta = new Uint32Array(sab);
    for (var i = 0; i < 4; ++i) {
      ta[i] = i;
    }

56
    // Clone SharedArrayBuffer
57
    w.postMessage(sab);
58
    assertEquals(16, sab.byteLength);  // ArrayBuffer should not be detached.
59 60 61 62 63 64 65 66 67

    // Spinwait for the worker to update ta[0]
    var ta0;
    while ((ta0 = Atomics.load(ta, 0)) == 0) {}

    assertEquals(100, ta0);

    w.terminate();

68
    assertEquals(16, sab.byteLength);  // Still not detached.
69
  })();
70

71
  (function TestCloneMulti() {
72 73 74 75 76 77 78 79
    var workerScript =
      `onmessage = function(msg) {
       var sab = msg.sab;
       var id = msg.id;
       var ta = new Uint32Array(sab);
       Atomics.store(ta, id, 1);
       postMessage(id);
      };`;
80

81 82
    var sab = new SharedArrayBuffer(16);
    var ta = new Uint32Array(sab);
83

84 85 86
    var id;
    var workers = [];
    for (id = 0; id < 4; ++id) {
87
      workers[id] = new Worker(workerScript, {type: 'string'});
88
      workers[id].postMessage({sab: sab, id: id});
89
    }
90

91 92 93 94 95 96 97 98 99 100 101 102 103
    // Spinwait for each worker to update ta[id]
    var count = 0;
    while (count < 4) {
      for (id = 0; id < 4; ++id) {
        if (Atomics.compareExchange(ta, id, 1, -1) == 1) {
          // Worker is finished.
          assertEquals(id, workers[id].getMessage());
          workers[id].terminate();
          count++;
        }
      }
    }
  })();
104 105

}