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

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

Issue 12314065: Reset http-parser instead of only setting _state, when we have handled a full request-response conv… (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 10 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
« no previous file with comments | « sdk/lib/io/http_parser.dart ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
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.
4 //
5 // VMOptions=
6 // VMOptions=--short_socket_read
7 // VMOptions=--short_socket_write
8 // VMOptions=--short_socket_read --short_socket_write
9
10 import "dart:async";
11 import "dart:io";
12
13 Future getData(HttpClient client, int port, bool chunked, int length) {
14 return client.get("localhost", port, "/?chunked=$chunked&length=$length")
15 .then((request) => request.close())
16 .then((response) {
17 return response.reduce(0, (bytes, data) => bytes + data.length)
18 .then((bytes) {
19 Expect.equals(length, bytes);
20 });
21 });
22 }
23
24 Future<HttpServer> startServer() {
25 return HttpServer.bind("127.0.0.1", 0).then((server) {
26 server.listen((request) {
27 bool chunked = request.queryParameters["chunked"] == "true";
28 int length = int.parse(request.queryParameters["length"]);
29 var buffer = new List.fixedLength(length, fill: 0);
30 if (!chunked) request.response.contentLength = length;
31 request.response.add(buffer);
32 request.response.close();
33 });
34 return server;
35 });
36 }
37
38 testKeepAliveNonChunked() {
39 startServer().then((server) {
40 var client = new HttpClient();
41
42 getData(client, server.port, false, 100)
43 .then((_) => getData(client, server.port, false, 100))
44 .then((_) => getData(client, server.port, false, 100))
45 .then((_) => getData(client, server.port, false, 100))
46 .then((_) => getData(client, server.port, false, 100))
47 .then((_) {
48 server.close();
49 client.close();
50 });
51
52 });
53 }
54
55 testKeepAliveChunked() {
56 startServer().then((server) {
57 var client = new HttpClient();
58
59 getData(client, server.port, true, 100)
60 .then((_) => getData(client, server.port, true, 100))
61 .then((_) => getData(client, server.port, true, 100))
62 .then((_) => getData(client, server.port, true, 100))
63 .then((_) => getData(client, server.port, true, 100))
64 .then((_) {
65 server.close();
66 client.close();
67 });
68
69 });
70 }
71
72 testKeepAliveMixed() {
73 startServer().then((server) {
74 var client = new HttpClient();
75
76 getData(client, server.port, true, 100)
77 .then((_) => getData(client, server.port, false, 100))
78 .then((_) => getData(client, server.port, true, 100))
79 .then((_) => getData(client, server.port, false, 100))
80 .then((_) => getData(client, server.port, true, 100))
81 .then((_) => getData(client, server.port, false, 100))
82 .then((_) => getData(client, server.port, true, 100))
83 .then((_) => getData(client, server.port, false, 100))
84 .then((_) {
85 server.close();
86 client.close();
87 });
88
89 });
90 }
91
92 void main() {
93 testKeepAliveNonChunked();
94 testKeepAliveChunked();
95 testKeepAliveMixed();
96 }
OLDNEW
« no previous file with comments | « sdk/lib/io/http_parser.dart ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698