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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
|
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at <http://mozilla.org/MPL/2.0/>. */
// Test basic worker functionality: the main thread and worker can be
// separately controlled from the same debugger.
"use strict";
add_task(async function () {
await pushPref("devtools.debugger.threads-visible", true);
const dbg = await initDebugger("doc-windowless-workers.html");
const mainThread = dbg.toolbox.threadFront.actor;
await waitForThreadCount(dbg, 2);
const workers = dbg.selectors.getThreads();
ok(workers.length == 2, "Got two workers");
const thread1 = workers[0].actor;
const thread2 = workers[1].actor;
const mainThreadSource = findSource(dbg, "doc-windowless-workers.html");
await waitForSource(dbg, "simple-worker.js");
info("Pause in the main thread");
assertNotPaused(dbg);
await dbg.actions.breakOnNext(getThreadContext(dbg));
await waitForPaused(dbg, "doc-windowless-workers.html");
assertPausedAtSourceAndLine(dbg, mainThreadSource.id, 10);
threadIsSelected(dbg, 1);
info("Pause in the first worker");
await dbg.actions.selectThread(getContext(dbg), thread1);
assertNotPaused(dbg);
await dbg.actions.breakOnNext(getThreadContext(dbg));
await waitForPaused(dbg, "simple-worker.js");
threadIsSelected(dbg, 2);
const workerSource2 = dbg.selectors.getSelectedSource();
assertPausedAtSourceAndLine(dbg, workerSource2.id, 3);
info("Add a watch expression and view the value");
await addExpression(dbg, "count");
is(getWatchExpressionLabel(dbg, 1), "count");
const v = getWatchExpressionValue(dbg, 1);
ok(v == `${+v}`, "Value of count should be a number");
info("StepOver in the first worker");
await stepOver(dbg);
assertPausedAtSourceAndLine(dbg, workerSource2.id, 4);
info("Ensure that the watch expression has updated");
await waitUntil(() => {
const v2 = getWatchExpressionValue(dbg, 1);
return +v2 == +v + 1;
});
info("Resume in the first worker");
await resume(dbg);
assertNotPaused(dbg);
info("StepOver in the main thread");
dbg.actions.selectThread(getContext(dbg), mainThread);
await stepOver(dbg);
assertPausedAtSourceAndLine(dbg, mainThreadSource.id, 11);
info("Resume in the mainThread");
await resume(dbg);
assertNotPaused(dbg);
info("Pause in both workers");
await addBreakpoint(dbg, "simple-worker.js", 10);
invokeInTab("sayHello");
info("Wait for both workers to pause");
// When a thread pauses the current thread changes,
// and we don't want to get confused.
await waitForPausedThread(dbg, thread1);
await waitForPausedThread(dbg, thread2);
threadIsPaused(dbg, 2);
threadIsPaused(dbg, 3);
info("View the first paused thread");
dbg.actions.selectThread(getContext(dbg), thread1);
await waitForPaused(dbg);
assertPausedAtSourceAndLine(dbg, workerSource2.id, 10);
info("View the second paused thread");
await dbg.actions.selectThread(getContext(dbg), thread2);
threadIsSelected(dbg, 3);
await waitForPaused(dbg);
const workerSource3 = dbg.selectors.getSelectedSource();
is(
workerSource2,
workerSource3,
"The selected source is the same as we have one source per URL"
);
assertPausedAtSourceAndLine(dbg, workerSource3.id, 10);
info("StepOver in second worker and not the first");
await stepOver(dbg);
assertPausedAtSourceAndLine(dbg, workerSource3.id, 11);
await dbg.actions.selectThread(getContext(dbg), thread1);
assertPausedAtSourceAndLine(dbg, workerSource2.id, 10);
info("Resume both worker execution");
await resume(dbg);
await dbg.actions.selectThread(getContext(dbg), thread2);
await resume(dbg);
let sourceActors = dbg.selectors.getSourceActorsForSource(workerSource3.id);
is(
sourceActors.length,
2,
"There is one source actor per thread for the worker source"
);
info(
"Terminate the first worker and wait for having only the second worker in threads list"
);
await SpecialPowers.spawn(gBrowser.selectedBrowser, [], () => {
content.wrappedJSObject.worker1.terminate();
});
await waitForThreadCount(dbg, 1);
sourceActors = dbg.selectors.getSourceActorsForSource(workerSource3.id);
is(
sourceActors.length,
1,
"After the first worker is destroyed, we only have one source actor for the worker source"
);
ok(
sourceExists(dbg, "simple-worker.js"),
"But we still have the worker source object"
);
info("Terminate the second worker and wait for no more additional threads");
await SpecialPowers.spawn(gBrowser.selectedBrowser, [], () => {
content.wrappedJSObject.worker2.terminate();
});
await waitForThreadCount(dbg, 0);
sourceActors = dbg.selectors.getSourceActorsForSource(workerSource3.id);
is(
sourceActors.length,
0,
"After all workers are destroyed, we no longer have any source actor"
);
ok(
!sourceExists(dbg, "simple-worker.js"),
"And we no longer have the worker source"
);
});
function assertClass(dbg, selector, className, ...args) {
ok(
findElement(dbg, selector, ...args).classList.contains(className),
`${className} class exists`
);
}
function threadIsPaused(dbg, index) {
return ok(findElement(dbg, "threadsPaneItemPause", index));
}
function threadIsSelected(dbg, index) {
return assertClass(dbg, "threadsPaneItem", "selected", index);
}
|
