OLD | NEW |
(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 import "dart:async"; |
| 6 import "dart:io"; |
| 7 |
| 8 |
| 9 void testReuseSocket(int numConnections, int numServers) { |
| 10 ServerSocket.bind('localhost', 0, reusePort: true).then((server) { |
| 11 var servers = []; |
| 12 for (int i = 1; i < numServers; i++) { |
| 13 servers.add(ServerSocket.bind('localhost', server.port, reusePort: true)); |
| 14 } |
| 15 Future.wait(servers).then((servers) { |
| 16 servers = [server]..addAll(servers); |
| 17 for (var server in servers) { |
| 18 server.listen((socket) { |
| 19 socket.pipe(socket); |
| 20 }); |
| 21 } |
| 22 var connections = []; |
| 23 for (int i = 0; i < numConnections; i++) { |
| 24 connections.add( |
| 25 Socket.connect('localhost', server.port) |
| 26 .then((socket) => socket.close()) |
| 27 .then((socket) => socket.listen(null).asFuture())); |
| 28 } |
| 29 Future.wait(connections).then((_) { |
| 30 for (var server in servers) { |
| 31 server.close(); |
| 32 } |
| 33 }); |
| 34 }); |
| 35 }).catchError((e) { |
| 36 print("reusePort is not supported: $e"); |
| 37 }); |
| 38 } |
| 39 |
| 40 void main() { |
| 41 testReuseSocket(1, 1); |
| 42 testReuseSocket(10, 1); |
| 43 testReuseSocket(10, 10); |
| 44 testReuseSocket(100, 10); |
| 45 } |
OLD | NEW |