| OLD | NEW |
| 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 import "dart:async"; | 5 import "dart:async"; |
| 6 import "dart:io"; | 6 import "dart:io"; |
| 7 import "dart:isolate"; | 7 import "dart:isolate"; |
| 8 | 8 |
| 9 void sendData(List<int> data, int port) { | 9 void sendData(List<int> data, int port) { |
| 10 Socket.connect("127.0.0.1", port).then((socket) { | 10 Socket.connect("127.0.0.1", port).then((socket) { |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 50 Expect.isFalse(calledOnError); | 50 Expect.isFalse(calledOnError); |
| 51 Expect.equals(exception, e.error.message); | 51 Expect.equals(exception, e.error.message); |
| 52 Expect.equals(expectRequest, calledOnRequest); | 52 Expect.equals(expectRequest, calledOnRequest); |
| 53 calledOnError = true; | 53 calledOnError = true; |
| 54 port.close(); | 54 port.close(); |
| 55 c.complete(null); | 55 c.complete(null); |
| 56 }); | 56 }); |
| 57 | 57 |
| 58 List<int> d; | 58 List<int> d; |
| 59 if (data is List<int>) d = data; | 59 if (data is List<int>) d = data; |
| 60 if (data is String) d = data.charCodes; | 60 if (data is String) d = data.codeUnits; |
| 61 if (d == null) Expect.fail("Invalid data"); | 61 if (d == null) Expect.fail("Invalid data"); |
| 62 sendData(d, server.port); | 62 sendData(d, server.port); |
| 63 | 63 |
| 64 return c.future; | 64 return c.future; |
| 65 } | 65 } |
| 66 | 66 |
| 67 final data; | 67 final data; |
| 68 final String exception; | 68 final String exception; |
| 69 final bool expectRequest; | 69 final bool expectRequest; |
| 70 } | 70 } |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 109 server.listen( | 109 server.listen( |
| 110 (request) { | 110 (request) { |
| 111 String name = new Options().script; | 111 String name = new Options().script; |
| 112 new File(name).openRead().pipe(request.response); | 112 new File(name).openRead().pipe(request.response); |
| 113 }, | 113 }, |
| 114 onError: (e) { /* ignore */ }); | 114 onError: (e) { /* ignore */ }); |
| 115 | 115 |
| 116 var count = 0; | 116 var count = 0; |
| 117 makeRequest() { | 117 makeRequest() { |
| 118 Socket.connect("127.0.0.1", server.port).then((socket) { | 118 Socket.connect("127.0.0.1", server.port).then((socket) { |
| 119 var data = "GET / HTTP/1.1\r\nContent-Length: 0\r\n\r\n".charCodes; | 119 var data = "GET / HTTP/1.1\r\nContent-Length: 0\r\n\r\n".codeUnits; |
| 120 socket.add(data); | 120 socket.add(data); |
| 121 socket.close(); | 121 socket.close(); |
| 122 socket.done.then((_) { | 122 socket.done.then((_) { |
| 123 socket.destroy(); | 123 socket.destroy(); |
| 124 if (++count < 10) { | 124 if (++count < 10) { |
| 125 makeRequest(); | 125 makeRequest(); |
| 126 } else { | 126 } else { |
| 127 server.close(); | 127 server.close(); |
| 128 } | 128 } |
| 129 }); | 129 }); |
| 130 }); | 130 }); |
| 131 } | 131 } |
| 132 makeRequest(); | 132 makeRequest(); |
| 133 }); | 133 }); |
| 134 } | 134 } |
| 135 | 135 |
| 136 void main() { | 136 void main() { |
| 137 testEarlyClose1(); | 137 testEarlyClose1(); |
| 138 // testEarlyClose2(); | 138 // testEarlyClose2(); |
| 139 } | 139 } |
| OLD | NEW |