Add asynchronous test suite runner to Dart rewrite of test scripts.

tools/testing/dart/test_runner.dart

 // 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");
 
 /**
@@ skipping 25 matching lines @@
     }
   }
   Expect.fail("Cound not find the Dart shell executable.");
 }
 
 
 class TestCase {
   String executablePath;
   List<String> arguments;
   String commandLine;
+  String displayName;
   TestOutput output;
   Set<String> expectedOutcomes;
   Function completedHandler;
 
-  TestCase(this.executablePath, this.arguments,
+  TestCase(this.displayName, 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); }    
@@ skipping 86 matching lines @@
       timeoutTimer = new Timer(timeoutHandler, 1000 * timeout, false);
     }
   }
 
   void timeoutHandler(Timer unusedTimer) {
     timedOut = true;
     process.kill();
   }
 }
 
+
+class ProcessQueue {
+  int numProcesses = 0;
+  final int maxProcesses = 4;

[Mads Ager (google), 2011/11/08 08:26:06]

Let's do this right and take this as an argument? We have

var platform = new Platform();
platform.numberOfProcessors();

to give the actual number of available processors (and we should implement the
-j option to the script).

+  Queue<TestCase> tests;
+
+  ProcessQueue(this.tests);
+
+  runTests() {
+    print("           ***");

[Mads Ager (google), 2011/11/08 08:26:06]

Remove.

[Bill Hesse, 2011/11/08 14:38:56]

Done.

+    while (numProcesses < maxProcesses && !tests.isEmpty()) {
+      TestCase test = tests.removeFirst();
+      print("running ${test.displayName}");

[Mads Ager (google), 2011/11/08 08:26:06]

Add a TODO here to refactor this into various test output methods.

[Bill Hesse, 2011/11/08 14:38:56]

Done.

+      Function old_callback = test.completedHandler;

[Mads Ager (google), 2011/11/08 08:26:06]

Why do you extract old_callback here? Why not just use it below?

[Bill Hesse, 2011/11/08 14:38:56]

I think that won't work.  We will call the current value of
test.completedHandler, which will be the Function wrapper, and we will have an
infinite regress.

+      Function wrapper = (TestCase test_arg) {
+        numProcesses--;
+        print("finished ${test_arg.displayName}");
+        runTests();
+        old_callback(test_arg);
+      };
+      test.completedHandler = wrapper;
+        
+      new RunningProcess(test, 60).start();

[Mads Ager (google), 2011/11/08 08:26:06]

Add TODO here to take the actual timeout information from the test case?

[Bill Hesse, 2011/11/08 14:38:56]

Done.

+      numProcesses++;
+    }
+  }
+}
+
+
+class AsyncProcessQueue {

[Mads Ager (google), 2011/11/08 08:26:06]

Let's switch the names. This should be the ProcessQueue and the other one should
be SyncProcessQueue or ProcessQueueSync.

[Bill Hesse, 2011/11/08 14:38:56]

Only Async version provided, called ProcessQueue.
Done.

+  int numProcesses = 0;
+  final int maxProcesses = 4;

[Mads Ager (google), 2011/11/08 08:26:06]

Let's pass in the actual number of processors?

[Bill Hesse, 2011/11/08 14:38:56]

Done.

+  Queue<TestCase> tests;
+
+  AsyncProcessQueue() : tests = new Queue<TestCase>();
+
+  runTests() {
+    print("           ***");

[Mads Ager (google), 2011/11/08 08:26:06]

Remove.

[Bill Hesse, 2011/11/08 14:38:56]

Done.

+    while (numProcesses < maxProcesses && !tests.isEmpty()) {

[Mads Ager (google), 2011/11/08 08:26:06]

I don't think you need the while loop here. You are always spinning up one test
at a time and getting one completed callback at a time. So just start the next
test in the queue? So change the while to an if?

[Bill Hesse, 2011/11/08 14:38:56]

Done.

+      TestCase test = tests.removeFirst();
+      print("running ${test.displayName}");
+      Function old_callback = test.completedHandler;
+      Function wrapper = (TestCase test_arg) {
+        numProcesses--;
+        print("finished ${test_arg.displayName}");
+        runTests();
+        old_callback(test_arg);
+      };
+      test.completedHandler = wrapper;
+        
+      new RunningProcess(test, 60).start();
+      numProcesses++;
+    }
+  }
+
+  runTest(TestCase test) {
+    tests.add(test);
+    runTests();
+  }
+    
+}
+