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

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))
Søren Gjesse 2013/02/22 14:06:41 Maybe add a few more here.
Anders Johnsen 2013/02/22 14:07:48 Done.
44 .then((_) {
45 server.close();
46 client.close();
47 });
48
49 });
50 }
51
52 testKeepAliveChunked() {
53 startServer().then((server) {
54 var client = new HttpClient();
55
56 getData(client, server.port, true, 100)
57 .then((_) => getData(client, server.port, true, 100))
Søren Gjesse 2013/02/22 14:06:41 and here.
Anders Johnsen 2013/02/22 14:07:48 Done.
58 .then((_) {
59 server.close();
60 client.close();
61 });
62
63 });
64 }
65
66 testKeepAliveMixed() {
67 startServer().then((server) {
68 var client = new HttpClient();
69
70 getData(client, server.port, true, 100)
71 .then((_) => getData(client, server.port, false, 100))
72 .then((_) => getData(client, server.port, true, 100))
73 .then((_) => getData(client, server.port, false, 100))
74 .then((_) => getData(client, server.port, true, 100))
75 .then((_) => getData(client, server.port, false, 100))
76 .then((_) => getData(client, server.port, true, 100))
77 .then((_) => getData(client, server.port, false, 100))
78 .then((_) {
79 server.close();
80 client.close();
81 });
82
83 });
84 }
85
86 void main() {
87 testKeepAliveNonChunked();
88 testKeepAliveChunked();
89 testKeepAliveMixed();
90 }
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