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
|
// META: timeout=long
// META: global=worker
// META: script=/common/utils.js
// META: script=/common/get-host-info.sub.js
// META: script=/fetch/api/request/request-error.js
// this adopted from fetch keepalive abort test for windows from /fetch/api/abort/keepalive.html
async function fetchJson(url) {
const response = await fetch(url);
assert_true(response.ok, 'response should be ok');
return response.json();
}
promise_test(async () => {
const stateKey = token();
const controller = new AbortController();
// infinites-slow-response writes a response to the client until client closes connection
// or it receives the abortKey. In our case the we expect the connection to be closed from client,
// i.e. the fetch keep-alive request is aborted.
await fetch(`/fetch/api/resources/infinite-slow-response.py?stateKey=${stateKey}`,
{
signal: controller.signal,
keepalive: true
});
const before = await fetchJson(`/fetch/api/resources/stash-take.py?key=${stateKey}`);
assert_equals(before, 'open', 'connection should be open');
controller.abort();
// Spin until the abort completes.
while (true) {
const after = await fetchJson(`/fetch/api/resources/stash-take.py?key=${stateKey}`);
if (after) {
// stateKey='open' was removed from the dictionary by the first fetch of
// stash-take.py, so we should only ever see the value 'closed' here.
assert_equals(after, 'closed', 'connection should have closed');
break;
}
}
}, 'aborting a keepalive worker should work');
|
