Source code
Revision control
Copy as Markdown
Other Tools
Test Info: Errors
- This test gets skipped with pattern: os == 'win' && os_version == '11.26100' && arch == 'x86_64' && msix OR os == 'win' && os_version == '11.26200' && arch == 'x86_64' && msix OR os == 'android' && os_version == '14' && arch == 'x86_64' && debug OR os == 'android' && os_version == '14' && arch == 'x86_64' && opt
- This test runs only with pattern: !socketprocess_networking
- This test failed 4 times in the preceding 30 days. quicksearch this test
- Manifest: dom/webtransport/test/xpcshell/xpcshell.toml
/* 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
// Tests that multiple server-initiated streams can be received concurrently.
"use strict";
var h3Port;
var host;
registerCleanupFunction(async () => {
Services.prefs.clearUserPref("network.dns.localDomains");
Services.prefs.clearUserPref("network.webtransport.redirect.enabled");
});
var { NetUtil } = ChromeUtils.importESModule(
"resource://gre/modules/NetUtil.sys.mjs"
);
function readFile(file) {
let fstream = Cc["@mozilla.org/network/file-input-stream;1"].createInstance(
Ci.nsIFileInputStream
);
fstream.init(file, -1, 0, 0);
let data = NetUtil.readInputStreamToString(fstream, fstream.available());
fstream.close();
return data;
}
function addCertFromFile(certdb, filename, trustString) {
let certFile = do_get_file(filename, false);
let pem = readFile(certFile)
.replace(/-----BEGIN CERTIFICATE-----/, "")
.replace(/-----END CERTIFICATE-----/, "")
.replace(/[\r\n]/g, "");
certdb.addCertFromBase64(pem, trustString);
}
add_setup(async function setup() {
Services.prefs.setCharPref("network.dns.localDomains", "foo.example.com");
Services.prefs.setBoolPref("network.webtransport.redirect.enabled", true);
h3Port = Services.env.get("MOZHTTP3_PORT");
Assert.notEqual(h3Port, null);
Assert.notEqual(h3Port, "");
host = "foo.example.com:" + h3Port;
do_get_profile();
let certdb = Cc["@mozilla.org/security/x509certdb;1"].getService(
Ci.nsIX509CertDB
);
addCertFromFile(
certdb,
"../../../../netwerk/test/unit/http2-ca.pem",
"CTu,u,u"
);
});
async function read_stream_as_string(readable_stream) {
const decoder = new (webTransportWindow().TextDecoderStream)();
const decode_stream = readable_stream.pipeThrough(decoder);
const reader = decode_stream.getReader();
let chunks = "";
while (true) {
const { value: chunk, done } = await reader.read();
if (done) {
break;
}
chunks += chunk;
}
reader.releaseLock();
return chunks;
}
add_task(async function test_multiple_incoming_unidi_streams() {
const NUM_STREAMS = 5;
let wt = newWebTransport(
);
await wt.ready;
const stream_reader = wt.incomingUnidirectionalStreams.getReader();
let received = [];
for (let i = 0; i < NUM_STREAMS; i++) {
const { value: recv_stream } = await stream_reader.read();
let str = await read_stream_as_string(recv_stream);
received.push(str);
}
stream_reader.releaseLock();
received.sort();
for (let i = 0; i < NUM_STREAMS; i++) {
Assert.equal(received[i], `stream${i}`);
}
wt.close();
});
add_task(async function test_multiple_incoming_bidi_streams() {
const NUM_STREAMS = 5;
let wt = newWebTransport(
);
await wt.ready;
const stream_reader = wt.incomingBidirectionalStreams.getReader();
let received = [];
for (let i = 0; i < NUM_STREAMS; i++) {
const { value: bidi_stream } = await stream_reader.read();
let str = await read_stream_as_string(bidi_stream.readable);
received.push(str);
}
stream_reader.releaseLock();
received.sort();
for (let i = 0; i < NUM_STREAMS; i++) {
Assert.equal(received[i], `stream${i}`);
}
wt.close();
});