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

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

Issue 17406010: Move getters from Options to Platform (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 6 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) 2013, the Dart project authors. Please see the AUTHORS file 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 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 // VMOptions= 5 // VMOptions=
6 // VMOptions=--short_socket_read 6 // VMOptions=--short_socket_read
7 // VMOptions=--short_socket_write 7 // VMOptions=--short_socket_write
8 // VMOptions=--short_socket_read --short_socket_write 8 // VMOptions=--short_socket_read --short_socket_write
9 9
10 import "package:expect/expect.dart"; 10 import "package:expect/expect.dart";
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after
73 request.response.done.then((_) { 73 request.response.done.then((_) {
74 server.close(); 74 server.close();
75 }); 75 });
76 request.response.contentLength = 0; 76 request.response.contentLength = 0;
77 request.response.close(); 77 request.response.close();
78 }); 78 });
79 } 79 }
80 80
81 81
82 void testResponseAddStream() { 82 void testResponseAddStream() {
83 int bytes = new File(new Options().script).lengthSync(); 83 int bytes = new File(Platform.script).lengthSync();
84 84
85 testServerRequest((server, request) { 85 testServerRequest((server, request) {
86 request.response.addStream(new File(new Options().script).openRead()) 86 request.response.addStream(new File(Platform.script).openRead())
87 .then((response) { 87 .then((response) {
88 response.close(); 88 response.close();
89 response.done.then((_) => server.close()); 89 response.done.then((_) => server.close());
90 }); 90 });
91 }, bytes: bytes); 91 }, bytes: bytes);
92 92
93 testServerRequest((server, request) { 93 testServerRequest((server, request) {
94 request.response.addStream(new File(new Options().script).openRead()) 94 request.response.addStream(new File(Platform.script).openRead())
95 .then((response) { 95 .then((response) {
96 request.response.addStream(new File(new Options().script).openRead()) 96 request.response.addStream(new File(Platform.script).openRead())
97 .then((response) { 97 .then((response) {
98 response.close(); 98 response.close();
99 response.done.then((_) => server.close()); 99 response.done.then((_) => server.close());
100 }); 100 });
101 }); 101 });
102 }, bytes: bytes * 2); 102 }, bytes: bytes * 2);
103 103
104 testServerRequest((server, request) { 104 testServerRequest((server, request) {
105 var controller = new StreamController(sync: true); 105 var controller = new StreamController(sync: true);
106 request.response.addStream(controller.stream) 106 request.response.addStream(controller.stream)
(...skipping 15 matching lines...) Expand all
122 new File("__not_exitsing_file_").openRead().pipe(request.response) 122 new File("__not_exitsing_file_").openRead().pipe(request.response)
123 .catchError((e) { 123 .catchError((e) {
124 server.close(); 124 server.close();
125 }); 125 });
126 }); 126 });
127 } 127 }
128 128
129 129
130 void testResponseAddStreamClosed() { 130 void testResponseAddStreamClosed() {
131 testServerRequest((server, request) { 131 testServerRequest((server, request) {
132 request.response.addStream(new File(new Options().script).openRead()) 132 request.response.addStream(new File(Platform.script).openRead())
133 .then((response) { 133 .then((response) {
134 response.close(); 134 response.close();
135 response.done.then((_) => server.close()); 135 response.done.then((_) => server.close());
136 }); 136 });
137 }, closeClient: true); 137 }, closeClient: true);
138 138
139 testServerRequest((server, request) { 139 testServerRequest((server, request) {
140 int count = 0; 140 int count = 0;
141 write() { 141 write() {
142 request.response.addStream(new File(new Options().script).openRead()) 142 request.response.addStream(new File(Platform.script).openRead())
143 .then((response) { 143 .then((response) {
144 request.response.write("sync data"); 144 request.response.write("sync data");
145 count++; 145 count++;
146 if (count < 1000) { 146 if (count < 1000) {
147 write(); 147 write();
148 } else { 148 } else {
149 response.close(); 149 response.close();
150 response.done.then((_) => server.close()); 150 response.done.then((_) => server.close());
151 } 151 }
152 }); 152 });
153 } 153 }
154 write(); 154 write();
155 }, closeClient: true); 155 }, closeClient: true);
156 } 156 }
157 157
158 158
159 void testResponseAddClosed() { 159 void testResponseAddClosed() {
160 testServerRequest((server, request) { 160 testServerRequest((server, request) {
161 request.response.add(new File(new Options().script).readAsBytesSync()); 161 request.response.add(new File(Platform.script).readAsBytesSync());
162 request.response.close(); 162 request.response.close();
163 request.response.done.then((_) => server.close()); 163 request.response.done.then((_) => server.close());
164 }, closeClient: true); 164 }, closeClient: true);
165 165
166 testServerRequest((server, request) { 166 testServerRequest((server, request) {
167 for (int i = 0; i < 1000; i++) { 167 for (int i = 0; i < 1000; i++) {
168 request.response.add(new File(new Options().script).readAsBytesSync()); 168 request.response.add(new File(Platform.script).readAsBytesSync());
169 } 169 }
170 request.response.close(); 170 request.response.close();
171 request.response.done.then((_) => server.close()); 171 request.response.done.then((_) => server.close());
172 }, closeClient: true); 172 }, closeClient: true);
173 173
174 testServerRequest((server, request) { 174 testServerRequest((server, request) {
175 int count = 0; 175 int count = 0;
176 write() { 176 write() {
177 request.response.add(new File(new Options().script).readAsBytesSync()); 177 request.response.add(new File(Platform.script).readAsBytesSync());
178 Timer.run(() { 178 Timer.run(() {
179 count++; 179 count++;
180 if (count < 1000) { 180 if (count < 1000) {
181 write(); 181 write();
182 } else { 182 } else {
183 request.response.close(); 183 request.response.close();
184 request. response.done.then((_) => server.close()); 184 request. response.done.then((_) => server.close());
185 } 185 }
186 }); 186 });
187 } 187 }
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after
273 273
274 void main() { 274 void main() {
275 testResponseDone(); 275 testResponseDone();
276 testResponseAddStream(); 276 testResponseAddStream();
277 testResponseAddStreamClosed(); 277 testResponseAddStreamClosed();
278 testResponseAddClosed(); 278 testResponseAddClosed();
279 testBadResponseAdd(); 279 testBadResponseAdd();
280 testBadResponseClose(); 280 testBadResponseClose();
281 testIgnoreRequestData(); 281 testIgnoreRequestData();
282 } 282 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698