Index: dart/tests/standalone/io/socket_bind_test.dart |
diff --git a/dart/tests/standalone/io/socket_bind_test.dart b/dart/tests/standalone/io/socket_bind_test.dart |
deleted file mode 100644 |
index 18fbaacbb2f4495f6608b39664fb178374a0d0cd..0000000000000000000000000000000000000000 |
--- a/dart/tests/standalone/io/socket_bind_test.dart |
+++ /dev/null |
@@ -1,165 +0,0 @@ |
-// Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
-// for details. All rights reserved. Use of this source code is governed by a |
-// BSD-style license that can be found in the LICENSE file. |
- |
-import 'dart:async'; |
-import 'dart:io'; |
-import 'dart:convert'; |
- |
-import 'package:async_helper/async_helper.dart'; |
-import 'package:expect/expect.dart'; |
- |
-testBindShared(bool v6Only) { |
- asyncStart(); |
- ServerSocket.bind( |
- 'localhost', 0, v6Only: v6Only, shared: true).then((socket) { |
- Expect.isTrue(socket.port > 0); |
- |
- asyncStart(); |
- return ServerSocket.bind( |
- 'localhost', socket.port, v6Only: v6Only, shared: true).then((socket2) { |
- Expect.equals(socket.address.address, socket2.address.address); |
- Expect.equals(socket.port, socket2.port); |
- socket.close().whenComplete(asyncEnd); |
- socket2.close().whenComplete(asyncEnd); |
- }); |
- }); |
-} |
- |
-negTestBindSharedMismatch(bool v6Only) { |
- asyncStart(); |
- ServerSocket.bind('localhost', 0, v6Only: v6Only).then((ServerSocket socket) { |
- Expect.isTrue(socket.port > 0); |
- |
- asyncStart(); |
- return ServerSocket.bind( |
- 'localhost', socket.port, v6Only: v6Only).catchError((error) { |
- Expect.isTrue(error is SocketException); |
- Expect.isTrue('$error'.contains('shared flag')); |
- socket.close().whenComplete(asyncEnd); |
- asyncEnd(); |
- }); |
- }); |
-} |
- |
-negTestBindV6OnlyMismatch(bool v6Only) { |
- asyncStart(); |
- ServerSocket.bind( |
- 'localhost', 0, v6Only: v6Only, shared: true).then((ServerSocket socket) { |
- Expect.isTrue(socket.port > 0); |
- |
- asyncStart(); |
- return ServerSocket.bind( |
- 'localhost', socket.port, v6Only: !v6Only, shared: true) |
- .catchError((error) { |
- Expect.isTrue(error is SocketException); |
- Expect.isTrue('$error'.contains('v6Only flag')); |
- socket.close().whenComplete(asyncEnd); |
- asyncEnd(); |
- }); |
- }); |
-} |
- |
-Future testBindDifferentAddresses(InternetAddress addr1, |
- InternetAddress addr2, |
- bool addr1V6Only, |
- bool addr2V6Only) { |
- asyncStart(); |
- return ServerSocket.bind( |
- addr1, 0, v6Only: addr1V6Only, shared: false).then((socket) { |
- Expect.isTrue(socket.port > 0); |
- |
- asyncStart(); |
- return ServerSocket.bind( |
- addr2, socket.port, v6Only: addr2V6Only, shared: false).then((socket2) { |
- Expect.equals(socket.port, socket2.port); |
- |
- return Future.wait([ |
- socket.close().whenComplete(asyncEnd), |
- socket2.close().whenComplete(asyncEnd), |
- ]); |
- }); |
- }); |
-} |
- |
-testSocketReferenceInteroperability() { |
- asyncStart(); |
- ServerSocket.bind('localhost', 0).then((ServerSocket socket) { |
- Expect.isTrue(socket.port > 0); |
- |
- asyncStart(); |
- socket.reference.create().then((socket2) { |
- bool gotResponseFrom1; |
- bool gotResponseFrom2; |
- |
- Expect.isTrue(socket.port > 0); |
- Expect.equals(socket.port, socket2.port); |
- |
- asyncStart(); |
- asyncStart(); |
- socket.listen((client) { |
- client.drain().whenComplete(asyncEnd); |
- client.write('1: hello world'); |
- client.close(); |
- socket.close().whenComplete(asyncEnd); |
- }, onDone: asyncEnd); |
- |
- asyncStart(); |
- asyncStart(); |
- socket2.listen((client) { |
- client.drain().whenComplete(asyncEnd); |
- client.write('2: hello world'); |
- client.close(); |
- socket2.close().whenComplete(asyncEnd); |
- }, onDone: asyncEnd); |
- |
- var futures = []; |
- for (int i = 0; i < 2; i++) { |
- asyncStart(); |
- futures.add( |
- Socket.connect(socket.address, socket.port).then((Socket socket) { |
- socket.close().whenComplete(asyncEnd); |
- asyncStart(); |
- return socket |
- .transform(ASCII.decoder).join('').then((String result) { |
- if (result == '1: hello world') gotResponseFrom1 = true; |
- else if (result == '2: hello world') gotResponseFrom2 = true; |
- else throw 'Unexpected result from server: $result'; |
- asyncEnd(); |
- }); |
- })); |
- } |
- asyncStart(); |
- Future.wait(futures).then((_) { |
- Expect.isTrue(gotResponseFrom1); |
- Expect.isTrue(gotResponseFrom2); |
- asyncEnd(); |
- }); |
- }); |
- }); |
-} |
- |
-void main() { |
- testBindShared(false); |
- testBindShared(true); |
- |
- negTestBindSharedMismatch(false); |
- negTestBindSharedMismatch(true); |
- |
- negTestBindV6OnlyMismatch(true); |
- negTestBindV6OnlyMismatch(false); |
- |
- asyncStart(); |
- testBindDifferentAddresses(InternetAddress.ANY_IP_V6, |
- InternetAddress.ANY_IP_V4, |
- true, |
- false).then((_) { |
- testBindDifferentAddresses(InternetAddress.ANY_IP_V4, |
- InternetAddress.ANY_IP_V6, |
- false, |
- true); |
- asyncEnd(); |
- }); |
- |
- testSocketReferenceInteroperability(); |
-} |