Add support to specify the source address for socket connect

tests/standalone/io/socket_source_address_test.dart

+// 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.
+//
+// VMOptions=
+// VMOptions=--short_socket_read
+// VMOptions=--short_socket_write
+// VMOptions=--short_socket_read --short_socket_write
+
+import "dart:async";
+import "dart:io";
+
+import "package:async_helper/async_helper.dart";
+import "package:expect/expect.dart";
+
+Future throws(Function f, Function check) async {
+  try {
+    await f();
+    Expect.fail('Did not throw');
+  } catch (e) {
+    if (check != null) {
+      if (!check(e)) {
+        Expect.fail('Unexpected: $e');
+      }
+    }
+  }
+}
+
+Future testArgumentsRawSocket() async {
+  asyncStart();
+  var server = await ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0);
+  server.listen((_) { throw 'Connection unexpected'; },
+                onDone: () => asyncEnd());
+
+  asyncStart();
+  // Illegal type for sourceAddress.
+  for (var sourceAddress in ['www.google.com', 'abc']) {
+    await throws(() => RawSocket.connect('127.0.0.1',
+                                         server.port,
+                                         sourceAddress: sourceAddress),
+                 (e) => e is ArgumentError);
+  }
+  // Unsupported local address.
+  for (var sourceAddress in ['8.8.8.8', new InternetAddress('8.8.8.8')]) {
+    await throws(() => RawSocket.connect('127.0.0.1',
+                                         server.port,
+                                         sourceAddress: sourceAddress),
+                 (e) => e is SocketException);
+  }
+  // Address family mismatch.
+  for (var sourceAddress in ['::1', InternetAddress.LOOPBACK_IP_V6]) {
+    await throws(() => RawSocket.connect('127.0.0.1',
+                                         server.port,
+                                         sourceAddress: sourceAddress),
+                 (e) => e is SocketException);
+  }
+  asyncEnd();
+  server.close();
+}
+
+Future testArgumentsSocket() async {
+  asyncStart();
+  var server = await ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0);
+  server.listen((_) { throw 'Connection unexpected'; },
+                onDone: () => asyncEnd());
+
+  asyncStart();
+  // Illegal type for sourceAddress.
+  for (var sourceAddress in ['www.google.com', 'abc']) {
+    await throws(() => Socket.connect('127.0.0.1',
+                                      server.port,
+                                      sourceAddress: sourceAddress),
+                 (e) => e is ArgumentError);
+  }
+  // Unsupported local address.
+  for (var sourceAddress in ['8.8.8.8', new InternetAddress('8.8.8.8')]) {
+    await throws(() => Socket.connect('127.0.0.1',
+                                      server.port,
+                                      sourceAddress: sourceAddress),
+                 (e) => e is SocketException);
+  }
+  // Address family mismatch.
+  for (var sourceAddress in ['::1', InternetAddress.LOOPBACK_IP_V6]) {
+    await throws(() => Socket.connect('127.0.0.1',
+                                      server.port,
+                                      sourceAddress: sourceAddress),
+                 (e) => e is SocketException);
+  }
+  asyncEnd();
+  server.close();
+}

[kustermann, 2015/02/10 10:06:54]

Since there is no difference at all between these two methods, you could pass a
tearoff method as an argument, i.e.

Future testArgumentSocket(Function connectFunction) {
  ...
}

testArgumentSocket(Socket.connect)
testArgumentSocket(RawSocket.connect)

[Søren Gjesse, 2015/02/10 11:13:33]

Good point. Done.

+
+Future testConnectRawSocket() async {
+  asyncStart();
+  var server = await ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0);
+  var port = server.port;
+  server.listen((s) {
+    s.destroy();

[kustermann, 2015/02/10 10:06:54]

Maybe have a counter here, to make sure it actually got called?
Also further down.

[Søren Gjesse, 2015/02/10 11:13:33]

Added more asyncStart() and asyncEnd() to do the counting.

+  }, onDone: () => asyncEnd());
+
+  asyncStart();
+  for (var sourceAddress in [InternetAddress.LOOPBACK_IP_V4,
+                             InternetAddress.ANY_IP_V4,
+                             '127.0.0.1',
+                             '0.0.0.0']) {
+    RawSocket raw;
+    raw = await RawSocket.connect(InternetAddress.LOOPBACK_IP_V4,
+                                  port,
+                                  sourceAddress: sourceAddress);
+    raw.close();
+  }
+  server.close();
+  asyncEnd();
+}
+
+Future testConnectSocket() async {
+  asyncStart();
+  var server = await ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0);
+  var port = server.port;
+  server.listen((s) {
+    s.destroy();
+  }, onDone: () => asyncEnd());
+
+  asyncStart();
+  for (var sourceAddress in [InternetAddress.LOOPBACK_IP_V4,
+                             InternetAddress.ANY_IP_V4,
+                             '127.0.0.1',
+                             '0.0.0.0']) {
+    Socket s;
+    s = await Socket.connect(InternetAddress.LOOPBACK_IP_V4,
+                             port,
+                             sourceAddress: sourceAddress);
+    s.destroy();
+  }
+  server.close();
+  asyncEnd();
+}
+
+Future testConnectRawSocketIPv6() async {
+  asyncStart();
+  var server = await ServerSocket.bind(InternetAddress.ANY_IP_V6, 0);
+  var port = server.port;
+  server.listen((s) {
+    s.destroy();
+  }, onDone: () => asyncEnd());
+
+  asyncStart();
+  for (var sourceAddress in [InternetAddress.LOOPBACK_IP_V4,
+                             InternetAddress.ANY_IP_V4,
+                             '127.0.0.1',
+                             '0.0.0.0']) {
+    RawSocket raw;
+    raw = await RawSocket.connect(InternetAddress.LOOPBACK_IP_V4,
+                                  port,
+                                  sourceAddress: sourceAddress);
+    raw.close();
+  }

[kustermann, 2015/02/10 10:06:54]

This is loop is an exact duplicate of the one in testConnectRawSocket() - it
makes it relaly hard to see what is actually tested / what is the difference to
the other tests.

If possible, I'd collapse these tests into less, more concise code.

[Søren Gjesse, 2015/02/10 11:13:33]

Created a parameterized test to cover the last 4 tests.

+  for (var sourceAddress in [InternetAddress.LOOPBACK_IP_V6,
+                             InternetAddress.ANY_IP_V6,
+                             '::1',
+                             '::']) {
+    RawSocket raw;
+    raw = await RawSocket.connect(InternetAddress.LOOPBACK_IP_V6,
+                                  port,
+                                  sourceAddress: sourceAddress);
+    raw.close();
+  }
+  server.close();
+  asyncEnd();
+}
+
+Future testConnectSocketIPv6() async {
+  asyncStart();
+  var server = await ServerSocket.bind(InternetAddress.ANY_IP_V6, 0);
+  var port = server.port;
+  server.listen((s) {
+    s.destroy();
+  }, onDone: () => asyncEnd());
+
+  asyncStart();
+  for (var sourceAddress in [InternetAddress.LOOPBACK_IP_V4,
+                             InternetAddress.ANY_IP_V4,
+                             '127.0.0.1',
+                             '0.0.0.0']) {
+    Socket s;
+    s = await Socket.connect(InternetAddress.LOOPBACK_IP_V4,
+                             port,
+                             sourceAddress: sourceAddress);
+    s.destroy();
+  }
+  for (var sourceAddress in [InternetAddress.LOOPBACK_IP_V6,
+                             InternetAddress.ANY_IP_V6,
+                             '::1',
+                             '::']) {
+    Socket s;
+    s = await Socket.connect(InternetAddress.LOOPBACK_IP_V6,
+                             port,
+                             sourceAddress: sourceAddress);
+    s.destroy();
+  }
+  server.close();
+  asyncEnd();
+}
+
+main() {
+  testArgumentsRawSocket();
+  testArgumentsSocket();
+  testConnectRawSocket();
+  testConnectSocket();
+  testConnectRawSocketIPv6();
+  testConnectSocketIPv6();
+}