Add test_runner.dart to Dart version of test scripts. Include TestRunnerTest unit test.

tools/testing/dart/test_runner.dart

Index: tools/testing/dart/test_runner.dart
diff --git a/tools/testing/dart/test_runner.dart b/tools/testing/dart/test_runner.dart
new file mode 100644
index 0000000000000000000000000000000000000000..8a720d6faf3f7f96e8231e0f5acefb5e49db981d
--- /dev/null
+++ b/tools/testing/dart/test_runner.dart
@@ -0,0 +1,156 @@
+// Copyright (c) 2011, 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.
+
+#library("test_runner");
+
+
+#import("status_file_parser.dart");
+
+/**
+ * Classes and methods for executing tests.
+ *
+ * This module includes:
+ * - Managing parallel execution of tests, including timeout checks.
+ * - Evaluating the output of each test as pass/fail/crash/timeout.
+ */
+
+// Possible outcomes of running a test.
+final CRASH = "Crash";
+final TIMEOUT = "Timeout";
+final FAIL = "Fail";
+final PASS = "Pass";
+// An indication to skip the test.  The caller is responsible for skipping it.
+final SKIP = "Skip";
+
+String getDartShellFileName() {
+  var names = ["out/Debug_ia32/dart_bin",
+               "out/Release_ia32/dart_bin",
+               "xcodebuild/Debug_ia32/dart_bin",
+               "xcodebuild/Release_ia32/dart_bin",
+               "Debug_ia32/dart_bin.exe",
+               "Release_ia32/dart_bin.exe"];
+  for (var name in names) {
+    if (new File(name).existsSync()) {
+      return name;
+    }
+  }
+  Expect.fail("Cound not find the Dart shell executable.");
+}
+
+
+class TestCase {
+  String executablePath;
+  List<String> arguments;
+  String commandLine;
+  TestOutput output;
+  Set<String> expectedOutcomes;
+  Function completedHandler;
+
+  TestCase(this.executablePath, this.arguments,
+           this.completedHandler, this.expectedOutcomes) {
+    commandLine = executablePath;
+    for (var arg in arguments) {
+      commandLine += " " + arg;
+    }
+  }
+
+  bool get isNegative() => false;
+
+  void completed() { completedHandler(this); }    
+}
+
+
+class TestOutput {
+  // The TestCase this is the output from.
+  TestCase testCase;
+  int exitCode;
+  bool timedOut;
+  bool failed = false;
+  List<String> stdout;
+  List<String> stderr;
+  Duration time;
+  
+  TestOutput(this.testCase, this.exitCode, this.timedOut, this.stdout,
+             this.stderr, this.time) {
+    testCase.output = this;
+  }
+
+  String get result() =>
+      hasCrashed ? CRASH : (hasTimedOut ? TIMEOUT : (hasFailed ? FAIL : PASS));
+
+  bool get unexpectedOutput() => !testCase.expectedOutcomes.contains(result);
+  
+  bool get hasCrashed() => !timedOut && exitCode != 255 && exitCode != 0;
+
+  bool get hasTimedOut() => timedOut;
+
+  bool get didFail() => exitCode != 0 && !hasCrashed;
+
+  // Reverse result of a negative test.
+  bool get hasFailed() => (testCase.isNegative ? !didFail : didFail);
+}
+
+
+class RunningProcess {
+  Process process;
+  TestCase testCase;
+  int timeout;
+  bool timedOut = false;
+  Date startTime;
+  Timer timeoutTimer;
+  List<String> stdout;
+  List<String> stderr;
+  List<Function> handlers;
+
+  static final int NO_TIMEOUT = 0;
+
+  RunningProcess(this.testCase, [this.timeout = NO_TIMEOUT]);
+
+  void exitHandler(int exitCode) {
+    new TestOutput(testCase, exitCode, timedOut, stdout,
+                   stderr, new Date.now().difference(startTime));
+    process.close();
+    timeoutTimer.cancel();
+    testCase.completed();
+  }
+
+  void makeReadHandler(StringInputStream source, List<String> destination) {
+    return () {
+      if (source.closed) return;  // TODO(whesse): Remove when bug is fixed.
+      var line = source.readLine();
+      while (null != line) {
+        destination.add(line);
+        line = source.readLine();
+      }
+    };
+  }
+
+  void start() {
+    Expect.isFalse(testCase.expectedOutcomes.contains(SKIP));
+    process = new Process(testCase.executablePath, testCase.arguments);
+    process.exitHandler = exitHandler;
+    startTime = new Date.now();
+    process.start();
+    
+    InputStream stdoutStream = process.stdout;
+    InputStream stderrStream = process.stderr;
+    stdout = new List<String>();
+    stderr = new List<String>();
+    StringInputStream stdoutStringStream = new StringInputStream(stdoutStream);
+    StringInputStream stderrStringStream = new StringInputStream(stderrStream);
+    stdoutStringStream.dataHandler =
+        makeReadHandler(stdoutStringStream, stdout);
+    stderrStringStream.dataHandler =
+        makeReadHandler(stderrStringStream, stderr);
+    if (timeout != NO_TIMEOUT) {
+      timeoutTimer = new Timer(timeoutHandler, 1000 * timeout, false);
+    }
+  }
+
+  void timeoutHandler(Timer unusedTimer) {
+    timedOut = true;
+    process.kill();
+  }
+}
+