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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
<!DOCTYPE html>
<html>
<!--
Copyright 2011 The Closure Library Authors. All Rights Reserved.
Use of this source code is governed by the Apache License, Version 2.0.
See the COPYING file for details.
-->
<!--
-->
<head>
<title>
Closure Unit Tests - goog.messaging.PortNetwork
</title>
<script src="../base.js"></script>
<script>
goog.require('goog.events.EventTarget');
goog.require('goog.messaging.PortChannel');
goog.require('goog.messaging.PortOperator');
goog.require('goog.testing.AsyncTestCase');
goog.require('goog.testing.MockControl');
goog.require('goog.testing.async.MockControl');
goog.require('goog.testing.messaging.MockMessageEvent');
goog.require('goog.testing.jsunit');
</script>
</head>
<body>
<iframe style="display: none;" name="inner" id="inner"
src="testdata/portnetwork_inner.html"></iframe>
<script>
var asyncTestCase = goog.testing.AsyncTestCase.createAndInstall();
// Use a relatively long timeout because workers can take a while to start up.
asyncTestCase.stepTimeout = 5 * 1000;
var timer;
function setUp() {
timer = new goog.Timer(50);
}
function tearDown() {
goog.dispose(timer);
}
function testRouteMessageThroughWorkers() {
if (!('MessageChannel' in goog.global)) {
return;
}
var master = new goog.messaging.PortOperator('main');
master.addPort('worker1', new goog.messaging.PortChannel(
new Worker('testdata/portnetwork_worker1.js')));
master.addPort('worker2', new goog.messaging.PortChannel(
new Worker('testdata/portnetwork_worker2.js')));
master.addPort(
'frame', goog.messaging.PortChannel.forEmbeddedWindow(
window.frames['inner'], '*', timer));
master.dial('worker1').registerService('result', function(msg) {
assertArrayEquals(['main', 'worker2', 'frame', 'worker1'], msg);
master.dispose();
asyncTestCase.continueTesting();
}, true);
master.dial('worker2').send('sendToFrame', ['main']);
asyncTestCase.waitForAsync('routing messages');
}
</script>
</body>
</html>
|
