| Index: sdk/lib/_internal/pub_generated/lib/src/command/cache_repair.dart
|
| diff --git a/sdk/lib/_internal/pub_generated/lib/src/command/cache_repair.dart b/sdk/lib/_internal/pub_generated/lib/src/command/cache_repair.dart
|
| index 0df9b1663afcba0d7dd678483d0a9c200737d283..d8305ff763d391060e6b5a12d13ca348b057c773 100644
|
| --- a/sdk/lib/_internal/pub_generated/lib/src/command/cache_repair.dart
|
| +++ b/sdk/lib/_internal/pub_generated/lib/src/command/cache_repair.dart
|
| @@ -1,15 +1,24 @@
|
| +// Copyright (c) 2014, 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 pub.command.cache_repair;
|
| +
|
| import 'dart:async';
|
| +
|
| import '../command.dart';
|
| import '../exit_codes.dart' as exit_codes;
|
| import '../io.dart';
|
| import '../log.dart' as log;
|
| import '../source/cached.dart';
|
| import '../utils.dart';
|
| +
|
| +/// Handles the `cache repair` pub command.
|
| class CacheRepairCommand extends PubCommand {
|
| String get description => "Reinstall cached packages.";
|
| String get usage => "pub cache repair";
|
| String get docUrl => "http://dartlang.org/tools/pub/cmd/pub-cache.html";
|
| +
|
| Future onRun() {
|
| final completer0 = new Completer();
|
| scheduleMicrotask(() {
|
| @@ -17,24 +26,22 @@ class CacheRepairCommand extends PubCommand {
|
| var successes = 0;
|
| var failures = 0;
|
| var it0 = cache.sources.iterator;
|
| - break0(x3) {
|
| + break0() {
|
| join0() {
|
| join1() {
|
| join2() {
|
| join3() {
|
| - completer0.complete(null);
|
| + completer0.complete();
|
| }
|
| if (failures > 0) {
|
| flushThenExit(exit_codes.UNAVAILABLE).then((x0) {
|
| try {
|
| x0;
|
| join3();
|
| - } catch (e0) {
|
| - completer0.completeError(e0);
|
| + } catch (e0, s0) {
|
| + completer0.completeError(e0, s0);
|
| }
|
| - }, onError: (e1) {
|
| - completer0.completeError(e1);
|
| - });
|
| + }, onError: completer0.completeError);
|
| } else {
|
| join3();
|
| }
|
| @@ -63,37 +70,40 @@ class CacheRepairCommand extends PubCommand {
|
| join0();
|
| }
|
| }
|
| - continue0(x4) {
|
| + var trampoline0;
|
| + continue0() {
|
| + trampoline0 = null;
|
| if (it0.moveNext()) {
|
| - Future.wait([]).then((x2) {
|
| - var source = it0.current;
|
| - join4() {
|
| - source.repairCachedPackages().then((x1) {
|
| + var source = it0.current;
|
| + join4() {
|
| + source.repairCachedPackages().then((x1) {
|
| + trampoline0 = () {
|
| + trampoline0 = null;
|
| try {
|
| var results = x1;
|
| successes += results.first;
|
| failures += results.last;
|
| - continue0(null);
|
| - } catch (e2) {
|
| - completer0.completeError(e2);
|
| + trampoline0 = continue0;
|
| + } catch (e1, s1) {
|
| + completer0.completeError(e1, s1);
|
| }
|
| - }, onError: (e3) {
|
| - completer0.completeError(e3);
|
| - });
|
| - }
|
| - if (source is! CachedSource) {
|
| - continue0(null);
|
| - } else {
|
| - join4();
|
| - }
|
| - });
|
| + };
|
| + do trampoline0(); while (trampoline0 != null);
|
| + }, onError: completer0.completeError);
|
| + }
|
| + if (source is! CachedSource) {
|
| + continue0();
|
| + } else {
|
| + join4();
|
| + }
|
| } else {
|
| - break0(null);
|
| + break0();
|
| }
|
| }
|
| - continue0(null);
|
| - } catch (e4) {
|
| - completer0.completeError(e4);
|
| + trampoline0 = continue0;
|
| + do trampoline0(); while (trampoline0 != null);
|
| + } catch (e, s) {
|
| + completer0.completeError(e, s);
|
| }
|
| });
|
| return completer0.future;
|
|
|