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

Unified Diff: tests/standalone/io/socket_cross_process_test.dart

Issue 23414004: Add dart:io tests for creating a client and server in separate processes. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 4 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 side-by-side diff with in-line comments
Download patch
Index: tests/standalone/io/socket_cross_process_test.dart
diff --git a/tests/standalone/io/socket_cross_process_test.dart b/tests/standalone/io/socket_cross_process_test.dart
new file mode 100644
index 0000000000000000000000000000000000000000..23be5b77c7b6c26e576b3ded9368e61fb9277412
--- /dev/null
+++ b/tests/standalone/io/socket_cross_process_test.dart
@@ -0,0 +1,59 @@
+// 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 "package:expect/expect.dart";
+import 'dart:async';
+import 'dart:io';
+
+const int NUM_SERVERS = 10;
+
+void main() {
+ var args = new Options().arguments;
+ if (args.isEmpty) {
+ for (int i = 0; i < NUM_SERVERS; ++i) {
+ makeServer().then((server) {
+ runClientProcess(server.port).then((_) => server.close());
+ });
+ }
+ } else if (args[0] == 'client') {
+ int port = int.parse(args[1]);
+ runClient(port);
+ } else {
+ Expect.fail('Unknown arguments to socket_cross_process_test.dart');
+ }
+}
+
+Future makeServer() {
+ return ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
+ server.listen((request) {
+ request.pipe(request);
+ });
+ return server;
+ });
+}
+
+Future runClientProcess(int port) {
+ return Process.run(Platform.executable,
+ []..addAll(Platform.executableArguments)
+ ..add(Platform.script)
+ ..add('client')
+ ..add(port.toString())).then((ProcessResult result) {
+ if (result.exitCode != 0 || !result.stdout.contains('SUCCESS')) {
+ print("Client failed, exit code ${result.exitCode}");
+ print(" stdout:");
+ print(result.stdout);
+ print(" stderr:");
+ print(result.stderr);
+ Expect.fail('Client subprocess exit code: ${result.exitCode}');
+ }
+ });
+}
+
+runClient(int port) {
+ Socket.connect(InternetAddress.LOOPBACK_IP_V4, port).then((connection) {
+ connection.listen((_) { }, onDone: () => print('SUCCESS'));
+ connection.close();
+ });
+}

Powered by Google App Engine
This is Rietveld 408576698