firefox-main/netwerk/test/unit/test_happy_eyeballs_conn_failure.js (file symbol)

Source code

Revision control

Copy as Markdown

Other Tools

Test Info: Warnings

/* 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/. */
"use strict";
var { setTimeout } = ChromeUtils.importESModule(
"resource://gre/modules/Timer.sys.mjs"
);
const { HTTP3Server } = ChromeUtils.importESModule(
);
let trrServer;
let h3NoResponsePort;
let tcpNoResponseSocket;
let tcpNoResponsePort;
add_setup(async function () {
h3NoResponsePort = Services.env.get("MOZHTTP3_PORT_NO_RESPONSE");
Assert.notEqual(h3NoResponsePort, null);
Assert.notEqual(h3NoResponsePort, "");
let h3ServerPath = Services.env.get("MOZ_HTTP3_SERVER_PATH");
let h3DBPath = Services.env.get("MOZ_HTTP3_CERT_DB_PATH");
let server = new HTTP3Server();
await server.start(h3ServerPath, h3DBPath);
tcpNoResponsePort = server.no_response_port();
// A TCP server socket that listens but never accepts connections.
// TCP handshake completes (OS handles SYN/SYN-ACK) but TLS never starts.
tcpNoResponseSocket = Cc[
"@mozilla.org/network/server-socket;1"
].createInstance(Ci.nsIServerSocket);
tcpNoResponseSocket.init(tcpNoResponsePort, true, -1);
let certdb = Cc["@mozilla.org/security/x509certdb;1"].getService(
Ci.nsIX509CertDB
);
addCertFromFile(certdb, "http2-ca.pem", "CTu,u,u");
Services.prefs.setBoolPref("network.http.happy_eyeballs_enabled", true);
trrServer = new TRRServer();
await trrServer.start();
trr_test_setup();
Services.prefs.setIntPref("network.trr.mode", 3);
Services.prefs.setCharPref(
"network.trr.uri",
`https://foo.example.com:${trrServer.port()}/dns-query`
);
registerCleanupFunction(async () => {
Services.prefs.clearUserPref("network.http.happy_eyeballs_enabled");
Services.prefs.clearUserPref("network.http.speculative-parallel-limit");
Services.prefs.clearUserPref(
"network.http.http3.alt-svc-mapping-for-testing"
);
trr_clear_prefs();
if (trrServer) {
await trrServer.stop();
}
if (tcpNoResponseSocket) {
tcpNoResponseSocket.close();
}
await server.stop();
});
});
async function resetConnections() {
Services.obs.notifyObservers(null, "net:cancel-all-connections");
let nssComponent = Cc["@mozilla.org/psm;1"].getService(Ci.nsINSSComponent);
await nssComponent.asyncClearSSLExternalAndInternalSessionCache();
Services.dns.clearCache(true);
// eslint-disable-next-line mozilla/no-arbitrary-setTimeout
await new Promise(resolve => setTimeout(resolve, 1000));
}
async function do_test_h3_no_response(host) {
await resetConnections();
let chan = NetUtil.newChannel({
uri: `https://${host}:${tcpNoResponsePort}/`,
loadUsingSystemPrincipal: true,
contentPolicyType: Ci.nsIContentPolicy.TYPE_DOCUMENT,
}).QueryInterface(Ci.nsIHttpChannel);
chan.loadFlags = Ci.nsIChannel.LOAD_INITIAL_DOCUMENT_URI;
await new Promise(resolve => {
chan.asyncOpen(
new ChannelListener(
(req, _buf) => {
Assert.ok(
!Components.isSuccessCode(req.status),
`Channel should fail, status=0x${req.status.toString(16)}`
);
Assert.equal(
req.status,
Cr.NS_ERROR_NET_TIMEOUT,
"Request should fail with NS_ERROR_NET_TIMEOUT"
);
resolve();
},
null,
CL_EXPECT_FAILURE
)
);
});
}
add_task(async function test_h3_connection_no_response() {
Services.prefs.setIntPref("network.http.connection-timeout", 2);
let host = "noresponse.example.com";
Services.prefs.setCharPref(
"network.http.http3.alt-svc-mapping-for-testing",
`${host};h3=:${h3NoResponsePort}`
);
await trrServer.registerDoHAnswers(host, "A", {
answers: [
{ name: host, ttl: 55, type: "A", flush: false, data: "127.0.0.1" },
],
});
Services.prefs.setIntPref("network.http.speculative-parallel-limit", 0);
await do_test_h3_no_response(host);
Services.prefs.setIntPref("network.http.speculative-parallel-limit", 6);
await do_test_h3_no_response(host);
Services.prefs.clearUserPref("network.http.connection-timeout");
Services.prefs.clearUserPref(
"network.http.http3.alt-svc-mapping-for-testing"
);
});