| <body> |
| <p>Test WorkerGlobalScope.close() method. Will print PASS multiple times, followed by DONE.</p> |
| <div id=result></div> |
| <script src="resources/worker-util.js"></script> |
| <script> |
| if (window.testRunner) { |
| testRunner.dumpAsText(); |
| testRunner.waitUntilDone(); |
| waitUntilWorkerThreadsExit(runTests); |
| } else { |
| log("NOTE: Test relies on window.testRunner to detect when worker threads have exited. Please run this test via DumpRenderTree"); |
| waitUntilWorkerThreadsExit(runTests); |
| } |
| |
| var worker; |
| |
| function startWorker() |
| { |
| if (window.testRunner) |
| log("PASS: workerThreadCount = " + internals.workerThreadCount); |
| worker = new Worker('resources/worker-close.js'); |
| } |
| |
| function runTests() |
| { |
| log("Test 1: Call close() in the worker, then enter infinite loop. From the Worker object side, call terminate(). Verify the loop is terminated.") |
| startWorker(); |
| worker.postMessage("close_post_loop"); // Close the worker but put it immediately into infinite loop. |
| worker.onmessage = function(event) { |
| if (window.testRunner) { |
| log("PASS: Worker thread created and closed, received message: " + event.data); |
| // Terminate the worker. |
| worker.terminate(); |
| waitUntilWorkerThreadsExit(testCloseWithAccumulatedMessages); |
| } |
| } |
| } |
| |
| function testCloseWithAccumulatedMessages() |
| { |
| log("PASS: Worker exited after terminate() terminated the infinite loop."); |
| log("Test 2: post 2 messages to a MessagePort into the worker. port.onmessage handler inside the worker will call close(). Verify that the second onmessage was not executed.") |
| startWorker(); |
| var channel = new MessageChannel(); |
| worker.onmessage = function(event) { |
| if (event.data == "echo_ping2") |
| log("FAIL: The MessagePort message was dispatched after a JS fragment that called 'close()' exited."); |
| else |
| log("PASS: MessagePort multiple message test, received message: " + event.data); |
| setTimeout("waitUntilWorkerThreadsExit(workerExited)", 100); // Let it run a bit to catch the echo_ping2 if it arrives. |
| } |
| worker.postMessage("take_port", [channel.port2]); |
| |
| // Queue 2 messages. |
| channel.port1.postMessage("ping1"); |
| channel.port1.postMessage("ping2"); |
| |
| // Now enable the messages to be delivered. Only first should echo back. |
| worker.postMessage("start_port"); |
| } |
| |
| function workerExited() |
| { |
| log("PASS: MessagePort messages were not delivered asfter close()."); |
| done(); |
| } |
| </script> |
| </body> |
