Record/replay support to test.py

tools/test.dart

 #!/usr/bin/env 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.
 
 /**
  * This file is the entrypoint of the dart test suite.  This suite is used
  * to test:
  *
  *     1. the dart vm
  *     2. the dart2js compiler
  *     3. the dartc static analyzer
  *     4. the dart core library
  *     5. other standard dart libraries (DOM bindings, ui libraries,
  *            io libraries etc.)
  *
  * This script is normally invoked by test.py.  (test.py finds the dart vm
  * and passses along all command line arguments to this script.)
  *
  * The command line args of this script are documented in
  * "tools/testing/test_options.dart".
  *
  */
 
 library test;
 
 import "dart:async";
 import "dart:io";
+import "testing/dart/http_server.dart";
+import "testing/dart/record_and_replay.dart";
+import "testing/dart/test_options.dart";
+import "testing/dart/test_progress.dart";
 import "testing/dart/test_runner.dart";
-import "testing/dart/test_options.dart";
 import "testing/dart/test_suite.dart";
-import "testing/dart/test_progress.dart";
-import "testing/dart/http_server.dart";
 import "testing/dart/utils.dart";
 
 import "../compiler/tests/dartc/test_config.dart";
 import "../runtime/tests/vm/test_config.dart";
 import "../samples/tests/dartc/test_config.dart";
 import "../tests/co19/test_config.dart";
 import "../tests/lib/analyzer/test_config.dart";
 
 /**
  * The directories that contain test suites which follow the conventions
@@ skipping 36 matching lines @@
   var maxProcesses = firstConf['tasks'];
   var progressIndicator = firstConf['progress'];
   // TODO(kustermann): Remove this option once the buildbots don't use it
   // anymore.
   var failureSummary = firstConf['failure-summary'];
   BuildbotProgressIndicator.stepName = firstConf['step_name'];
   var verbose = firstConf['verbose'];
   var printTiming = firstConf['time'];
   var listTests = firstConf['list'];
 
+  var recordingPath = firstConf['record_to_file'];
+  var recordingOutputPath = firstConf['replay_from_file'];
+
+  if (recordingPath != null && recordingOutputPath != null) {
+    print("Fatal: Can't have the '--record_to_file' and '--replay_from_file'"
+          "at the same time. Exiting ...");
+    exit(1);
+  }
+
+  var testCaseRecorder;
+  if (recordingPath != null) {
+    testCaseRecorder = new TestCaseRecorder(new Path(recordingPath));
+  }
+
+  var testCaseOutputArchive;
+  if (recordingOutputPath != null) {
+      testCaseOutputArchive = new TestCaseOutputArchive();
+      testCaseOutputArchive.loadFromPath(new Path(recordingOutputPath));
+  }
+
+
   if (!firstConf['append_logs'])  {
     var file = new File(TestUtils.flakyFileName());
     if (file.existsSync()) {
       file.deleteSync();
     }
   }
 
   DebugLogger.init(firstConf['write_debug_log'] ?
       TestUtils.debugLogfile() : null, append: firstConf['append_logs']);
 
@@ skipping 109 matching lines @@
                                                      startTime,
                                                      formatter));
     if (printTiming) {
       eventListener.add(new TimingPrinter(startTime));
     }
     eventListener.add(new SkippedCompilationsPrinter());
     eventListener.add(new LeftOverTempDirPrinter());
   }
   eventListener.add(new ExitCodeSetter());
 
+
   void startProcessQueue() {
     // Start process queue.
     new ProcessQueue(maxProcesses,
                      maxBrowserProcesses,
                      startTime,
                      testSuites,
                      eventListener,
                      allTestsFinished,
                      verbose,
-                     listTests);
+                     listTests,
+                     testCaseRecorder,
+                     testCaseOutputArchive);
   }
 
   // Start all the HTTP servers required before starting the process queue.
   if (serverFutures.isEmpty) {
     startProcessQueue();
   } else {
     Future.wait(serverFutures).then((_) => startProcessQueue());
   }
 }
 
@@ skipping 38 matching lines @@
 void main() {
   deleteTemporaryDartDirectories().then((_) {
     var optionsParser = new TestOptionsParser();
     var configurations = optionsParser.parse(new Options().arguments);
     if (configurations != null && configurations.length > 0) {
       testConfigurations(configurations);
     }
   });
 }