| 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 2371 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2382 completer.complete(line); | 2382 completer.complete(line); |
| 2383 first = false; | 2383 first = false; |
| 2384 } | 2384 } |
| 2385 // We need to drain a pipe continuously. | 2385 // We need to drain a pipe continuously. |
| 2386 }); | 2386 }); |
| 2387 return completer.future; | 2387 return completer.future; |
| 2388 } | 2388 } |
| 2389 | 2389 |
| 2390 Future _startProcess() async { | 2390 Future _startProcess() async { |
| 2391 final executable = io.Platform.executable; | 2391 final executable = io.Platform.executable; |
| 2392 final arguments = ['runtime/tools/kernel-service.dart', '--batch']; | 2392 final arguments = ['utils/kernel-service/kernel-service.dart', '--batch']; |
| 2393 | 2393 |
| 2394 try { | 2394 try { |
| 2395 _port = -1; | 2395 _port = -1; |
| 2396 _process = await io.Process.start(executable, arguments); | 2396 _process = await io.Process.start(executable, arguments); |
| 2397 _process.exitCode.then(_onExit); | 2397 _process.exitCode.then(_onExit); |
| 2398 _process.stderr.drain(); | 2398 _process.stderr.drain(); |
| 2399 | 2399 |
| 2400 final readyMsg = await _firstLine(_process.stdout); | 2400 final readyMsg = await _firstLine(_process.stdout); |
| 2401 final data = readyMsg.split(' '); | 2401 final data = readyMsg.split(' '); |
| 2402 assert(data[0] == 'READY'); | 2402 assert(data[0] == 'READY'); |
| (...skipping 938 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3341 } | 3341 } |
| 3342 } | 3342 } |
| 3343 | 3343 |
| 3344 void eventAllTestsDone() { | 3344 void eventAllTestsDone() { |
| 3345 for (var listener in _eventListener) { | 3345 for (var listener in _eventListener) { |
| 3346 listener.allDone(); | 3346 listener.allDone(); |
| 3347 } | 3347 } |
| 3348 _allDone(); | 3348 _allDone(); |
| 3349 } | 3349 } |
| 3350 } | 3350 } |
| OLD | NEW |