blob: a143f4c4950184780d7fe44305be5263302c4162 (
plain)
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
|
"use strict";
const { HttpServer } = ChromeUtils.importESModule(
"resource://testing-common/httpd.sys.mjs"
);
var httpProtocolHandler = Cc[
"@mozilla.org/network/protocol;1?name=http"
].getService(Ci.nsIHttpProtocolHandler);
ChromeUtils.defineLazyGetter(this, "URL", function () {
return "http://localhost:" + httpserver.identity.primaryPort;
});
var httpserver = new HttpServer();
var testpath = "/simple";
var httpbody = "0123456789";
var live_channels = [];
add_task(async function test() {
httpserver.registerPathHandler(testpath, serverHandler);
httpserver.start(-1);
registerCleanupFunction(async () => {
if (httpserver) {
await httpserver.stop();
}
});
await httpProtocolHandler.EnsureHSTSDataReady();
// Opened channel that has no remaining references on shutdown
let local_channel = setupChannel(testpath);
local_channel.asyncOpen(new SimpleChannelListener());
// Opened channel that has no remaining references after being opened
setupChannel(testpath).asyncOpen(new SimpleChannelListener());
// Unopened channel that has remaining references on shutdown
live_channels.push(setupChannel(testpath));
// Opened channel that has remaining references on shutdown
live_channels.push(setupChannel(testpath));
await new Promise(resolve => {
live_channels[1].asyncOpen(
new SimpleChannelListener((req, data) => {
Assert.equal(data, httpbody);
resolve();
})
);
});
await httpserver.stop();
httpserver = null;
});
function setupChannel(path) {
var chan = NetUtil.newChannel({
uri: URL + path,
loadUsingSystemPrincipal: true,
});
chan.QueryInterface(Ci.nsIHttpChannel);
chan.requestMethod = "GET";
return chan;
}
function serverHandler(metadata, response) {
response.setHeader("Content-Type", "text/plain", false);
response.bodyOutputStream.write(httpbody, httpbody.length);
}
|
