blob: ba1653599ef324556331015f23703ed4f1f2aad3 [file] [log] [blame]
// Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
// @dart = 2.9
// OtherResources=http_client_stays_alive_test.dart
import 'dart:io';
import "package:async_helper/async_helper.dart";
// NOTE: This test tries to ensure that an HttpClient will close it's
// underlying idle connections after [HttpClient.idleTimeout].
//
// The main script spawns a server and a subprocess which does a connection back
// to it.
// The subprocess is expected to shut down its idle sockets after
// [HttpClient.idleTimeout] and the main script will assert that this happens
// within +/- 2 <= seconds.
const SECONDS = 4;
const SLACK = 60;
void runServerProcess() {
asyncStart();
HttpServer.bind('127.0.0.1', 0).then((server) {
var url = 'http://127.0.0.1:${server.port}/';
server.idleTimeout = const Duration(hours: 1);
var subscription = server.listen((HttpRequest request) {
request.response
..write('hello world')
..close();
});
var sw = new Stopwatch()..start();
var script = Platform.script
.resolve('http_client_stays_alive_test.dart')
.toFilePath();
var arguments = <String>[]
..addAll(Platform.executableArguments)
..add(script)
..add(url);
Process.run(Platform.executable, arguments).then((res) {
subscription.cancel();
if (res.exitCode != 0) {
throw "Child exited with ${res.exitCode} instead of 0. "
"(stdout: ${res.stdout}, stderr: ${res.stderr})";
}
var seconds = sw.elapsed.inSeconds;
// NOTE: There is a slight chance this will cause flakiness, but there is
// no other good way of testing correctness of timing-dependent code
// form the outside.
if (seconds < SECONDS || (SECONDS + SLACK) < seconds) {
throw "Child did exit within $seconds seconds, but expected it to take "
"roughly between $SECONDS and ${SECONDS + SLACK} seconds.";
}
asyncEnd();
});
});
}
void runClientProcess(String url) {
var uri = Uri.parse(url);
// NOTE: We make an HTTP client request and then *forget to close* the HTTP
// client instance. The idle timer should fire after SECONDS.
var client = new HttpClient();
client.idleTimeout = const Duration(seconds: SECONDS);
client
.getUrl(uri)
.then((req) => req.close())
.then((response) => response.drain())
.then((_) => print('drained client request'));
}
void main(List<String> args) {
if (args.length == 1) {
runClientProcess(args.first);
} else {
runServerProcess();
}
}