| OLD | NEW |
| 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 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. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 /** | 5 /** |
| 6 * Classes and methods for executing tests. | 6 * Classes and methods for executing tests. |
| 7 * | 7 * |
| 8 * This module includes: | 8 * This module includes: |
| 9 * - Managing parallel execution of tests, including timeout checks. | 9 * - Managing parallel execution of tests, including timeout checks. |
| 10 * - Evaluating the output of each test as pass/fail/crash/timeout. | 10 * - Evaluating the output of each test as pass/fail/crash/timeout. |
| (...skipping 592 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 603 Map<String, String> environment) { | 603 Map<String, String> environment) { |
| 604 var command = | 604 var command = |
| 605 new CompilationCommand._( | 605 new CompilationCommand._( |
| 606 displayName, outputFile, neverSkipCompilation, | 606 displayName, outputFile, neverSkipCompilation, |
| 607 bootstrapDependencies, executable, arguments, environment); | 607 bootstrapDependencies, executable, arguments, environment); |
| 608 return _getUniqueCommand(command); | 608 return _getUniqueCommand(command); |
| 609 } | 609 } |
| 610 | 610 |
| 611 AnalysisCommand getAnalysisCommand( | 611 AnalysisCommand getAnalysisCommand( |
| 612 String displayName, executable, arguments, environmentOverrides, | 612 String displayName, executable, arguments, environmentOverrides, |
| 613 {String flavor: 'dartanalyzer'}) { | 613 {String flavor: 'dart2analyzer'}) { |
| 614 var command = new AnalysisCommand._( | 614 var command = new AnalysisCommand._( |
| 615 flavor, displayName, executable, arguments, environmentOverrides); | 615 flavor, displayName, executable, arguments, environmentOverrides); |
| 616 return _getUniqueCommand(command); | 616 return _getUniqueCommand(command); |
| 617 } | 617 } |
| 618 | 618 |
| 619 VmCommand getVmCommand(String executable, | 619 VmCommand getVmCommand(String executable, |
| 620 List<String> arguments, | 620 List<String> arguments, |
| 621 Map<String, String> environmentOverrides) { | 621 Map<String, String> environmentOverrides) { |
| 622 var command = new VmCommand._(executable, arguments, environmentOverrides); | 622 var command = new VmCommand._(executable, arguments, environmentOverrides); |
| 623 return _getUniqueCommand(command); | 623 return _getUniqueCommand(command); |
| (...skipping 1819 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2443 // TODO(kustermann): The [timeout] parameter should be a property of Command | 2443 // TODO(kustermann): The [timeout] parameter should be a property of Command |
| 2444 Future<CommandOutput> runCommand( | 2444 Future<CommandOutput> runCommand( |
| 2445 dgraph.Node node, Command command, int timeout); | 2445 dgraph.Node node, Command command, int timeout); |
| 2446 } | 2446 } |
| 2447 | 2447 |
| 2448 class CommandExecutorImpl implements CommandExecutor { | 2448 class CommandExecutorImpl implements CommandExecutor { |
| 2449 final Map globalConfiguration; | 2449 final Map globalConfiguration; |
| 2450 final int maxProcesses; | 2450 final int maxProcesses; |
| 2451 final int maxBrowserProcesses; | 2451 final int maxBrowserProcesses; |
| 2452 | 2452 |
| 2453 // For dartanalyzer batch processing we keep a list of batch processes. | 2453 // For dart2js and analyzer batch processing, |
| 2454 // we keep a list of batch processes. |
| 2454 final _batchProcesses = new Map<String, List<BatchRunnerProcess>>(); | 2455 final _batchProcesses = new Map<String, List<BatchRunnerProcess>>(); |
| 2455 // We keep a BrowserTestRunner for every configuration. | 2456 // We keep a BrowserTestRunner for every configuration. |
| 2456 final _browserTestRunners = new Map<Map, BrowserTestRunner>(); | 2457 final _browserTestRunners = new Map<Map, BrowserTestRunner>(); |
| 2457 | 2458 |
| 2458 bool _finishing = false; | 2459 bool _finishing = false; |
| 2459 | 2460 |
| 2460 CommandExecutorImpl( | 2461 CommandExecutorImpl( |
| 2461 this.globalConfiguration, this.maxProcesses, this.maxBrowserProcesses); | 2462 this.globalConfiguration, this.maxProcesses, this.maxBrowserProcesses); |
| 2462 | 2463 |
| 2463 Future cleanup() { | 2464 Future cleanup() { |
| (...skipping 496 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2960 } | 2961 } |
| 2961 } | 2962 } |
| 2962 | 2963 |
| 2963 void eventAllTestsDone() { | 2964 void eventAllTestsDone() { |
| 2964 for (var listener in _eventListener) { | 2965 for (var listener in _eventListener) { |
| 2965 listener.allDone(); | 2966 listener.allDone(); |
| 2966 } | 2967 } |
| 2967 _allDone(); | 2968 _allDone(); |
| 2968 } | 2969 } |
| 2969 } | 2970 } |
| OLD | NEW |