| Index: tools/gardening/lib/compare_failures.dart
|
| diff --git a/tools/gardening/lib/compare_failures.dart b/tools/gardening/lib/compare_failures.dart
|
| deleted file mode 100644
|
| index 5f225dd2b5de7617abdf42b656c3148a1c4af199..0000000000000000000000000000000000000000
|
| --- a/tools/gardening/lib/compare_failures.dart
|
| +++ /dev/null
|
| @@ -1,314 +0,0 @@
|
| -// Copyright (c) 2017, 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.
|
| -
|
| -/// Compares the test log of a build step with previous builds.
|
| -///
|
| -/// Use this to detect flakiness of failures, especially timeouts.
|
| -
|
| -import 'dart:async';
|
| -import 'dart:convert';
|
| -import 'dart:io';
|
| -
|
| -import 'src/buildbot_structures.dart';
|
| -import 'src/util.dart';
|
| -
|
| -main(List<String> args) async {
|
| - if (args.length != 1) {
|
| - print('Usage: compare_failures <log-uri>');
|
| - exit(1);
|
| - }
|
| - String url = args.first;
|
| - if (!url.endsWith('/text')) {
|
| - // Use the text version of the stdio log.
|
| - url += '/text';
|
| - }
|
| - Uri uri = Uri.parse(url);
|
| - HttpClient client = new HttpClient();
|
| - BuildUri buildUri = new BuildUri(uri);
|
| - List<BuildResult> results = await readBuildResults(client, buildUri);
|
| - print(generateBuildResultsSummary(buildUri, results));
|
| - client.close();
|
| -}
|
| -
|
| -/// Creates a [BuildResult] for [buildUri] and, if it contains failures, the
|
| -/// [BuildResult]s for the previous 5 builds.
|
| -Future<List<BuildResult>> readBuildResults(
|
| - HttpClient client, BuildUri buildUri) async {
|
| - List<BuildResult> summaries = <BuildResult>[];
|
| - BuildResult firstSummary = await readBuildResult(client, buildUri);
|
| - summaries.add(firstSummary);
|
| - if (firstSummary.hasFailures) {
|
| - for (int i = 0; i < 10; i++) {
|
| - buildUri = buildUri.prev();
|
| - summaries.add(await readBuildResult(client, buildUri));
|
| - }
|
| - }
|
| - return summaries;
|
| -}
|
| -
|
| -/// Reads the content of [uri] as text.
|
| -Future<String> readUriAsText(HttpClient client, Uri uri) async {
|
| - HttpClientRequest request = await client.getUrl(uri);
|
| - HttpClientResponse response = await request.close();
|
| - return UTF8.decode(await response.expand((l) => l).toList());
|
| -}
|
| -
|
| -/// Parses the [buildUri] test log and creates a [BuildResult] for it.
|
| -Future<BuildResult> readBuildResult(
|
| - HttpClient client, BuildUri buildUri) async {
|
| - Uri uri = buildUri.toUri();
|
| - log('Reading $uri');
|
| - String text = await readUriAsText(client, uri);
|
| -
|
| - bool inFailure = false;
|
| - List<String> currentFailure;
|
| - bool parsingTimingBlock = false;
|
| -
|
| - List<TestFailure> failures = <TestFailure>[];
|
| - List<Timing> timings = <Timing>[];
|
| - for (String line in text.split('\n')) {
|
| - if (currentFailure != null) {
|
| - if (line.startsWith('!@@@STEP_CLEAR@@@')) {
|
| - failures.add(new TestFailure(buildUri, currentFailure));
|
| - currentFailure = null;
|
| - } else {
|
| - currentFailure.add(line);
|
| - }
|
| - } else if (inFailure && line.startsWith('@@@STEP_FAILURE@@@')) {
|
| - inFailure = false;
|
| - } else if (line.startsWith('!@@@STEP_FAILURE@@@')) {
|
| - inFailure = true;
|
| - } else if (line.startsWith('FAILED:')) {
|
| - currentFailure = <String>[];
|
| - currentFailure.add(line);
|
| - }
|
| - if (line.startsWith('--- Total time:')) {
|
| - parsingTimingBlock = true;
|
| - } else if (parsingTimingBlock) {
|
| - if (line.startsWith('0:')) {
|
| - timings.addAll(parseTimings(buildUri, line));
|
| - } else {
|
| - parsingTimingBlock = false;
|
| - }
|
| - }
|
| - }
|
| - return new BuildResult(buildUri, failures, timings);
|
| -}
|
| -
|
| -/// Generate a summary of the timeouts and other failures in [results].
|
| -String generateBuildResultsSummary(
|
| - BuildUri buildUri, List<BuildResult> results) {
|
| - StringBuffer sb = new StringBuffer();
|
| - sb.write('Results for $buildUri:\n');
|
| - Set<TestConfiguration> timeoutIds = new Set<TestConfiguration>();
|
| - for (BuildResult result in results) {
|
| - timeoutIds.addAll(result.timeouts.map((TestFailure failure) => failure.id));
|
| - }
|
| - if (timeoutIds.isNotEmpty) {
|
| - int firstBuildNumber = results.first.buildUri.buildNumber;
|
| - int lastBuildNumber = results.last.buildUri.buildNumber;
|
| - Map<TestConfiguration, Map<int, Map<String, Timing>>> map =
|
| - <TestConfiguration, Map<int, Map<String, Timing>>>{};
|
| - Set<String> stepNames = new Set<String>();
|
| - for (BuildResult result in results) {
|
| - for (Timing timing in result.timings) {
|
| - Map<int, Map<String, Timing>> builds =
|
| - map.putIfAbsent(timing.step.id, () => <int, Map<String, Timing>>{});
|
| - stepNames.add(timing.step.stepName);
|
| - builds.putIfAbsent(timing.uri.buildNumber, () => <String, Timing>{})[
|
| - timing.step.stepName] = timing;
|
| - }
|
| - }
|
| - sb.write('Timeouts for ${buildUri} :\n');
|
| - map.forEach((TestConfiguration id, Map<int, Map<String, Timing>> timings) {
|
| - if (!timeoutIds.contains(id)) return;
|
| - sb.write('$id\n');
|
| - sb.write(
|
| - '${' ' * 8} ${stepNames.map((t) => padRight(t, 14)).join(' ')}\n');
|
| - for (int buildNumber = firstBuildNumber;
|
| - buildNumber >= lastBuildNumber;
|
| - buildNumber--) {
|
| - Map<String, Timing> steps = timings[buildNumber] ?? const {};
|
| - sb.write(padRight(' ${buildNumber}: ', 8));
|
| - for (String stepName in stepNames) {
|
| - Timing timing = steps[stepName];
|
| - if (timing != null) {
|
| - sb.write(' ${timing.time}');
|
| - } else {
|
| - sb.write(' --------------');
|
| - }
|
| - }
|
| - sb.write('\n');
|
| - }
|
| - sb.write('\n');
|
| - });
|
| - }
|
| - Set<TestConfiguration> errorIds = new Set<TestConfiguration>();
|
| - for (BuildResult result in results) {
|
| - errorIds.addAll(result.errors.map((TestFailure failure) => failure.id));
|
| - }
|
| - if (errorIds.isNotEmpty) {
|
| - int firstBuildNumber = results.first.buildUri.buildNumber;
|
| - int lastBuildNumber = results.last.buildUri.buildNumber;
|
| - Map<TestConfiguration, Map<int, TestFailure>> map =
|
| - <TestConfiguration, Map<int, TestFailure>>{};
|
| - for (BuildResult result in results) {
|
| - for (TestFailure failure in result.errors) {
|
| - map.putIfAbsent(failure.id, () => <int, TestFailure>{})[
|
| - failure.uri.buildNumber] = failure;
|
| - }
|
| - }
|
| - sb.write('Errors for ${buildUri} :\n');
|
| - // TODO(johnniwinther): Improve comparison of non-timeouts.
|
| - map.forEach((TestConfiguration id, Map<int, TestFailure> failures) {
|
| - if (!errorIds.contains(id)) return;
|
| - sb.write('$id\n');
|
| - for (int buildNumber = firstBuildNumber;
|
| - buildNumber >= lastBuildNumber;
|
| - buildNumber--) {
|
| - TestFailure failure = failures[buildNumber];
|
| - sb.write(padRight(' ${buildNumber}: ', 8));
|
| - if (failure != null) {
|
| - sb.write(padRight(failure.expected, 10));
|
| - sb.write(' / ');
|
| - sb.write(padRight(failure.actual, 10));
|
| - } else {
|
| - sb.write(' ' * 10);
|
| - sb.write(' / ');
|
| - sb.write(padRight('-- OK --', 10));
|
| - }
|
| - sb.write('\n');
|
| - }
|
| - sb.write('\n');
|
| - });
|
| - }
|
| - return sb.toString();
|
| -}
|
| -
|
| -/// The results of a build step.
|
| -class BuildResult {
|
| - final BuildUri buildUri;
|
| - final List<TestFailure> _failures;
|
| - final List<Timing> _timings;
|
| -
|
| - BuildResult(this.buildUri, this._failures, this._timings);
|
| -
|
| - /// `true` of the build result has test failures.
|
| - bool get hasFailures => _failures.isNotEmpty;
|
| -
|
| - /// Returns the top-20 timings found in the build log.
|
| - Iterable<Timing> get timings => _timings;
|
| -
|
| - /// Returns the [TestFailure]s for tests that timed out.
|
| - Iterable<TestFailure> get timeouts {
|
| - return _failures
|
| - .where((TestFailure failure) => failure.actual == 'Timeout');
|
| - }
|
| -
|
| - /// Returns the [TestFailure]s for failing tests that did not time out.
|
| - Iterable<TestFailure> get errors {
|
| - return _failures
|
| - .where((TestFailure failure) => failure.actual != 'Timeout');
|
| - }
|
| -
|
| - String toString() {
|
| - StringBuffer sb = new StringBuffer();
|
| - sb.write('$buildUri\n');
|
| - sb.write('Failures:\n${_failures.join('\n-----\n')}\n');
|
| - sb.write('\nTimings:\n${_timings.join('\n')}');
|
| - return sb.toString();
|
| - }
|
| -}
|
| -
|
| -/// Test failure data derived from the test failure summary in the build step
|
| -/// stdio log.
|
| -class TestFailure {
|
| - final BuildUri uri;
|
| - final TestConfiguration id;
|
| - final String expected;
|
| - final String actual;
|
| - final String text;
|
| -
|
| - factory TestFailure(BuildUri uri, List<String> lines) {
|
| - List<String> parts = split(lines.first, ['FAILED: ', ' ', ' ']);
|
| - String configName = parts[1];
|
| - String archName = parts[2];
|
| - String testName = parts[3];
|
| - TestConfiguration id =
|
| - new TestConfiguration(configName, archName, testName);
|
| - String expected = split(lines[1], ['Expected: '])[1];
|
| - String actual = split(lines[2], ['Actual: '])[1];
|
| - return new TestFailure.internal(
|
| - uri, id, expected, actual, lines.skip(3).join('\n'));
|
| - }
|
| -
|
| - TestFailure.internal(
|
| - this.uri, this.id, this.expected, this.actual, this.text);
|
| -
|
| - String toString() {
|
| - StringBuffer sb = new StringBuffer();
|
| - sb.write('FAILED: $id\n');
|
| - sb.write('Expected: $expected\n');
|
| - sb.write('Actual: $actual\n');
|
| - sb.write(text);
|
| - return sb.toString();
|
| - }
|
| -}
|
| -
|
| -/// Id for a single test step, for instance the compilation and run steps of
|
| -/// a test.
|
| -class TestStep {
|
| - final String stepName;
|
| - final TestConfiguration id;
|
| -
|
| - TestStep(this.stepName, this.id);
|
| -
|
| - String toString() {
|
| - return '$stepName - $id';
|
| - }
|
| -
|
| - int get hashCode => stepName.hashCode * 13 + id.hashCode * 17;
|
| -
|
| - bool operator ==(other) {
|
| - if (identical(this, other)) return true;
|
| - if (other is! TestStep) return false;
|
| - return stepName == other.stepName && id == other.id;
|
| - }
|
| -}
|
| -
|
| -/// The timing result for a single test step.
|
| -class Timing {
|
| - final BuildUri uri;
|
| - final String time;
|
| - final TestStep step;
|
| -
|
| - Timing(this.uri, this.time, this.step);
|
| -
|
| - String toString() {
|
| - return '$time - $step';
|
| - }
|
| -}
|
| -
|
| -/// Create the [Timing]s for the [line] as found in the top-20 timings of a
|
| -/// build step stdio log.
|
| -List<Timing> parseTimings(BuildUri uri, String line) {
|
| - List<String> parts = split(line, [' - ', ' - ', ' ']);
|
| - String time = parts[0];
|
| - String stepName = parts[1];
|
| - String configName = parts[2];
|
| - String testNames = parts[3];
|
| - List<Timing> timings = <Timing>[];
|
| - for (String name in testNames.split(',')) {
|
| - name = name.trim();
|
| - int slashPos = name.indexOf('/');
|
| - String archName = name.substring(0, slashPos);
|
| - String testName = name.substring(slashPos + 1);
|
| - timings.add(new Timing(
|
| - uri,
|
| - time,
|
| - new TestStep(
|
| - stepName, new TestConfiguration(configName, archName, testName))));
|
| - }
|
| - return timings;
|
| -}
|
|
|