Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(479)

Side by Side Diff: tests/standalone/io/http_shutdown_test.dart

Issue 11194025: Second round of cleanups for new optional parameter semantics. (Closed) Base URL: http://dart.googlecode.com/svn/branches/bleeding_edge/dart/
Patch Set: Created 8 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 // 4 //
5 5
6 #import("dart:isolate"); 6 #import("dart:isolate");
7 #import("dart:io"); 7 #import("dart:io");
8 8
9 void test1(int totalConnections) { 9 void test1(int totalConnections) {
10 // Server which just closes immediately. 10 // Server which just closes immediately.
11 HttpServer server = new HttpServer(); 11 HttpServer server = new HttpServer();
12 server.listen("127.0.0.1", 0, totalConnections); 12 server.listen("127.0.0.1", 0, backlog: totalConnections);
13 server.defaultRequestHandler = (HttpRequest request, HttpResponse response) { 13 server.defaultRequestHandler = (HttpRequest request, HttpResponse response) {
14 response.outputStream.close(); 14 response.outputStream.close();
15 }; 15 };
16 16
17 int count = 0; 17 int count = 0;
18 HttpClient client = new HttpClient(); 18 HttpClient client = new HttpClient();
19 for (int i = 0; i < totalConnections; i++) { 19 for (int i = 0; i < totalConnections; i++) {
20 HttpClientConnection conn = client.get("127.0.0.1", server.port, "/"); 20 HttpClientConnection conn = client.get("127.0.0.1", server.port, "/");
21 conn.onRequest = (HttpClientRequest request) { 21 conn.onRequest = (HttpClientRequest request) {
22 request.outputStream.close(); 22 request.outputStream.close();
23 }; 23 };
24 conn.onResponse = (HttpClientResponse response) { 24 conn.onResponse = (HttpClientResponse response) {
25 count++; 25 count++;
26 if (count == totalConnections) { 26 if (count == totalConnections) {
27 client.shutdown(); 27 client.shutdown();
28 server.close(); 28 server.close();
29 } 29 }
30 }; 30 };
31 } 31 }
32 } 32 }
33 33
34 34
35 void test2(int totalConnections) { 35 void test2(int totalConnections) {
36 // Server which responds without waiting for request body. 36 // Server which responds without waiting for request body.
37 HttpServer server = new HttpServer(); 37 HttpServer server = new HttpServer();
38 server.listen("127.0.0.1", 0, totalConnections); 38 server.listen("127.0.0.1", 0, backlog: totalConnections);
39 server.defaultRequestHandler = (HttpRequest request, HttpResponse response) { 39 server.defaultRequestHandler = (HttpRequest request, HttpResponse response) {
40 response.outputStream.writeString("!dlrow ,olleH"); 40 response.outputStream.writeString("!dlrow ,olleH");
41 response.outputStream.close(); 41 response.outputStream.close();
42 }; 42 };
43 43
44 int count = 0; 44 int count = 0;
45 HttpClient client = new HttpClient(); 45 HttpClient client = new HttpClient();
46 for (int i = 0; i < totalConnections; i++) { 46 for (int i = 0; i < totalConnections; i++) {
47 HttpClientConnection conn = client.get("127.0.0.1", server.port, "/"); 47 HttpClientConnection conn = client.get("127.0.0.1", server.port, "/");
48 conn.onRequest = (HttpClientRequest request) { 48 conn.onRequest = (HttpClientRequest request) {
49 request.contentLength = -1; 49 request.contentLength = -1;
50 request.outputStream.writeString("Hello, world!"); 50 request.outputStream.writeString("Hello, world!");
51 request.outputStream.close(); 51 request.outputStream.close();
52 }; 52 };
53 conn.onResponse = (HttpClientResponse response) { 53 conn.onResponse = (HttpClientResponse response) {
54 count++; 54 count++;
55 if (count == totalConnections) { 55 if (count == totalConnections) {
56 client.shutdown(); 56 client.shutdown();
57 server.close(); 57 server.close();
58 } 58 }
59 }; 59 };
60 } 60 }
61 } 61 }
62 62
63 63
64 void test3(int totalConnections) { 64 void test3(int totalConnections) {
65 // Server which responds when request body has been received. 65 // Server which responds when request body has been received.
66 HttpServer server = new HttpServer(); 66 HttpServer server = new HttpServer();
67 server.listen("127.0.0.1", 0, totalConnections); 67 server.listen("127.0.0.1", 0, backlog: totalConnections);
68 server.defaultRequestHandler = (HttpRequest request, HttpResponse response) { 68 server.defaultRequestHandler = (HttpRequest request, HttpResponse response) {
69 request.inputStream.onData = () { 69 request.inputStream.onData = () {
70 request.inputStream.read(); 70 request.inputStream.read();
71 }; 71 };
72 request.inputStream.onClosed = () { 72 request.inputStream.onClosed = () {
73 response.outputStream.writeString("!dlrow ,olleH"); 73 response.outputStream.writeString("!dlrow ,olleH");
74 response.outputStream.close(); 74 response.outputStream.close();
75 }; 75 };
76 }; 76 };
77 77
(...skipping 18 matching lines...) Expand all
96 96
97 97
98 void main() { 98 void main() {
99 test1(1); 99 test1(1);
100 test1(10); 100 test1(10);
101 test2(1); 101 test2(1);
102 test2(10); 102 test2(10);
103 test3(1); 103 test3(1);
104 test3(10); 104 test3(10);
105 } 105 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698