| Index: dart/tests/standalone/io/http_client_timeout_test.dart
|
| diff --git a/dart/tests/standalone/io/http_client_timeout_test.dart b/dart/tests/standalone/io/http_client_timeout_test.dart
|
| deleted file mode 100644
|
| index 0703abb4bc4fa9e747dad808729a5ac2743cd4c5..0000000000000000000000000000000000000000
|
| --- a/dart/tests/standalone/io/http_client_timeout_test.dart
|
| +++ /dev/null
|
| @@ -1,85 +0,0 @@
|
| -// 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.
|
| -
|
| -import 'dart:async';
|
| -import 'dart:io';
|
| -
|
| -
|
| -void testOneRequest(int connections) {
|
| - HttpServer.bind('127.0.0.1', 0).then((server) {
|
| - server.listen((request) => request.response.close());
|
| - var client = new HttpClient();
|
| - var futures = [];
|
| - for (int i = 0; i < connections; i++) {
|
| - futures.add(
|
| - client.get('127.0.0.1', server.port, '/')
|
| - .then((request) => request.close())
|
| - .then((response) => response.fold(null, (x, y) {})));
|
| - }
|
| - Future.wait(futures).then((_) {
|
| - new Timer.periodic(const Duration(milliseconds: 100), (timer) {
|
| - if (server.connectionsInfo().total == 0) {
|
| - timer.cancel();
|
| - server.close();
|
| - }
|
| - });
|
| - });
|
| - });
|
| -}
|
| -
|
| -
|
| -void testIdleTimeout(int timeout) {
|
| - HttpServer.bind('127.0.0.1', 0).then((server1) {
|
| - HttpServer.bind('127.0.0.1', 0).then((server2) {
|
| - server1.listen((request) => request.pipe(request.response));
|
| - server2.listen((request) => request.pipe(request.response));
|
| -
|
| - var client = new HttpClient();
|
| - client.idleTimeout = new Duration(milliseconds: timeout);
|
| -
|
| - // Create a 'slow' connection..
|
| - Future connect(int port) {
|
| - return client.post('127.0.0.1', port, '/')
|
| - .then((request) {
|
| - request.write("data");
|
| - new Timer(const Duration(milliseconds: 250), () {
|
| - request.close();
|
| - });
|
| - return request.done;
|
| - })
|
| - .then((response) {
|
| - return response.fold(null, (x, y) {});
|
| - });
|
| - }
|
| -
|
| - // Create a single, slow request, to server1.
|
| - connect(server1.port);
|
| -
|
| - // Create a repeating connection to server2.
|
| - run() {
|
| - connect(server2.port).then((_) {
|
| - if (server1.connectionsInfo().total == 0) {
|
| - server1.close();
|
| - server2.close();
|
| - return;
|
| - }
|
| - Timer.run(run);
|
| - });
|
| - }
|
| - run();
|
| - });
|
| - });
|
| -}
|
| -
|
| -
|
| -main() {
|
| - testOneRequest(1);
|
| - testOneRequest(5);
|
| - testOneRequest(20);
|
| - testIdleTimeout(0);
|
| - testIdleTimeout(100);
|
| - testIdleTimeout(500);
|
| - testIdleTimeout(1000);
|
| - testIdleTimeout(2000);
|
| -}
|
|
|