| OLD | NEW |
| (Empty) |
| 1 // Copyright 2015 the V8 project authors. All rights reserved. | |
| 2 // Redistribution and use in source and binary forms, with or without | |
| 3 // modification, are permitted provided that the following conditions are | |
| 4 // met: | |
| 5 // | |
| 6 // * Redistributions of source code must retain the above copyright | |
| 7 // notice, this list of conditions and the following disclaimer. | |
| 8 // * Redistributions in binary form must reproduce the above | |
| 9 // copyright notice, this list of conditions and the following | |
| 10 // disclaimer in the documentation and/or other materials provided | |
| 11 // with the distribution. | |
| 12 // * Neither the name of Google Inc. nor the names of its | |
| 13 // contributors may be used to endorse or promote products derived | |
| 14 // from this software without specific prior written permission. | |
| 15 // | |
| 16 // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | |
| 17 // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | |
| 18 // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | |
| 19 // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | |
| 20 // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | |
| 21 // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | |
| 22 // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | |
| 23 // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | |
| 24 // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |
| 25 // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | |
| 26 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
| 27 | |
| 28 // Test the Worker API of d8. This test only makes sense with d8. A Worker | |
| 29 // spawns a new OS thread and isolate, and runs it concurrently with the | |
| 30 // current running thread. | |
| 31 | |
| 32 function f() { | |
| 33 postMessage("Starting worker"); | |
| 34 // Set a global variable; should not be visible outside of the worker's | |
| 35 // context. | |
| 36 foo = 100; | |
| 37 | |
| 38 var c = 0; | |
| 39 onmessage = function(m) { | |
| 40 switch (c++) { | |
| 41 case 0: | |
| 42 if (m !== undefined) throw new Error("undefined"); | |
| 43 break; | |
| 44 case 1: | |
| 45 if (m !== null) throw new Error("null"); | |
| 46 break; | |
| 47 case 2: | |
| 48 if (m !== true) throw new Error("true"); | |
| 49 break; | |
| 50 case 3: | |
| 51 if (m !== false) throw new Error("false"); | |
| 52 break; | |
| 53 case 4: | |
| 54 if (m !== 100) throw new Error("Number"); | |
| 55 break; | |
| 56 case 5: | |
| 57 if (m !== "hi") throw new Error("String"); | |
| 58 break; | |
| 59 case 6: | |
| 60 if (JSON.stringify(m) !== '[4,true,"bye"]') throw new Error("Array"); | |
| 61 break; | |
| 62 case 7: | |
| 63 if (JSON.stringify(m) !== '{"a":1,"b":2.5,"c":"three"}') | |
| 64 throw new Error("Object"); | |
| 65 break; | |
| 66 case 8: | |
| 67 var ab = m; | |
| 68 var t = new Uint32Array(ab); | |
| 69 if (ab.byteLength !== 16) | |
| 70 throw new Error("ArrayBuffer clone byteLength"); | |
| 71 for (var i = 0; i < 4; ++i) | |
| 72 if (t[i] !== i) | |
| 73 throw new Error("ArrayBuffer clone value " + i); | |
| 74 break; | |
| 75 case 9: | |
| 76 var ab = m; | |
| 77 var t = new Uint32Array(ab); | |
| 78 if (ab.byteLength !== 32) | |
| 79 throw new Error("ArrayBuffer transfer byteLength"); | |
| 80 for (var i = 0; i < 8; ++i) | |
| 81 if (t[i] !== i) | |
| 82 throw new Error("ArrayBuffer transfer value " + i); | |
| 83 break; | |
| 84 } | |
| 85 | |
| 86 if (c == 10) { | |
| 87 postMessage("DONE"); | |
| 88 } | |
| 89 } | |
| 90 } | |
| 91 | |
| 92 | |
| 93 if (this.Worker) { | |
| 94 function createArrayBuffer(byteLength) { | |
| 95 var ab = new ArrayBuffer(byteLength); | |
| 96 var t = new Uint32Array(ab); | |
| 97 for (var i = 0; i < byteLength / 4; ++i) | |
| 98 t[i] = i; | |
| 99 return ab; | |
| 100 } | |
| 101 | |
| 102 var w = new Worker(f); | |
| 103 | |
| 104 assertEquals("Starting worker", w.getMessage()); | |
| 105 | |
| 106 // Currently can only create one worker at a time. | |
| 107 assertThrows(function() { new Worker(f); }); | |
| 108 | |
| 109 w.postMessage(undefined); | |
| 110 w.postMessage(null); | |
| 111 w.postMessage(true); | |
| 112 w.postMessage(false); | |
| 113 w.postMessage(100); | |
| 114 w.postMessage("hi"); | |
| 115 w.postMessage([4, true, "bye"]); | |
| 116 w.postMessage({a: 1, b: 2.5, c: "three"}); | |
| 117 | |
| 118 // Clone ArrayBuffer | |
| 119 var ab1 = createArrayBuffer(16); | |
| 120 w.postMessage(ab1); | |
| 121 assertEquals(16, ab1.byteLength); // ArrayBuffer should not be neutered. | |
| 122 | |
| 123 // Transfer ArrayBuffer | |
| 124 var ab2 = createArrayBuffer(32); | |
| 125 w.postMessage(ab2, [ab2]); | |
| 126 assertEquals(0, ab2.byteLength); // ArrayBuffer should be neutered. | |
| 127 | |
| 128 assertEquals("undefined", typeof foo); | |
| 129 | |
| 130 // Read a message from the worker. | |
| 131 assertEquals("DONE", w.getMessage()); | |
| 132 | |
| 133 w.terminate(); | |
| 134 } | |
| OLD | NEW |