Decorate build mode with using PerformanceLog.

pkg/analyzer_cli/lib/src/build_mode.dart

 // Copyright (c) 2015, 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 analyzer_cli.src.build_mode;
 
 import 'dart:async';
 import 'dart:io' as io;
 
 import 'package:analyzer/error/error.dart';
@@ skipping 116 matching lines @@
 /**
  * Analyzer used when the "--build-mode" option is supplied.
  */
 class BuildMode {
   final ResourceProvider resourceProvider;
   final CommandLineOptions options;
   final AnalysisStats stats;
 
   SummaryDataStore summaryDataStore;
   AnalysisOptions analysisOptions;
-  AnalysisDriver analysisDriver;
   Map<Uri, File> uriToFileMap;
   final List<Source> explicitSources = <Source>[];
   final List<PackageBundle> unlinkedBundles = <PackageBundle>[];
 
+  PerformanceLog logger = new PerformanceLog(null);
+  AnalysisDriver analysisDriver;
+
   PackageBundleAssembler assembler;
   final Set<Source> processedSources = new Set<Source>();
   final Map<String, UnlinkedUnit> uriToUnit = <String, UnlinkedUnit>{};
 
   BuildMode(this.resourceProvider, this.options, this.stats);
 
   bool get _shouldOutputSummary =>
       options.buildSummaryOutput != null ||
       options.buildSummaryOutputSemantic != null;
 
   /**
    * Perform package analysis according to the given [options].
    */
   Future<ErrorSeverity> analyze() async {
-    // Write initial progress message.
-    if (!options.machineFormat) {
-      outSink.writeln("Analyzing ${options.sourceFiles.join(', ')}...");
-    }
+    return await logger.runAsync('Analyze', () async {
+      // Write initial progress message.
+      if (!options.machineFormat) {
+        outSink.writeln("Analyzing ${options.sourceFiles.join(', ')}...");
+      }
 
-    // Create the URI to file map.
-    uriToFileMap = _createUriToFileMap(options.sourceFiles);
-    if (uriToFileMap == null) {
-      io.exitCode = ErrorSeverity.ERROR.ordinal;
-      return ErrorSeverity.ERROR;
-    }
-
-    // BuildMode expects sourceFiles in the format "<uri>|<filepath>",
-    // but the rest of the code base does not understand this format.
-    // Rewrite sourceFiles, stripping the "<uri>|" prefix, so that it
-    // does not cause problems with code that does not expect this format.
-    options.rewriteSourceFiles(options.sourceFiles
-        .map((String uriPipePath) =>
-            uriPipePath.substring(uriPipePath.indexOf('|') + 1))
-        .toList());
-
-    // Prepare the analysis driver.
-    try {
-      _createAnalysisDriver();
-    } on ConflictingSummaryException catch (e) {
-      errorSink.writeln('$e');
-      io.exitCode = ErrorSeverity.ERROR.ordinal;
-      return ErrorSeverity.ERROR;
-    }
-
-    // Add sources.
-    for (Uri uri in uriToFileMap.keys) {
-      File file = uriToFileMap[uri];
-      if (!file.exists) {
-        errorSink.writeln('File not found: ${file.path}');
+      // Create the URI to file map.
+      uriToFileMap = _createUriToFileMap(options.sourceFiles);
+      if (uriToFileMap == null) {
         io.exitCode = ErrorSeverity.ERROR.ordinal;
         return ErrorSeverity.ERROR;
       }
-      Source source = new FileSource(file, uri);
-      explicitSources.add(source);
-    }
 
-    // Write summary.
-    assembler = new PackageBundleAssembler();
-    if (_shouldOutputSummary) {
-      // Prepare all unlinked units.
-      for (var src in explicitSources) {
-        await _prepareUnlinkedUnit('${src.uri}');
+      // BuildMode expects sourceFiles in the format "<uri>|<filepath>",
+      // but the rest of the code base does not understand this format.
+      // Rewrite sourceFiles, stripping the "<uri>|" prefix, so that it
+      // does not cause problems with code that does not expect this format.
+      options.rewriteSourceFiles(options.sourceFiles
+          .map((String uriPipePath) =>
+              uriPipePath.substring(uriPipePath.indexOf('|') + 1))
+          .toList());
+
+      // Prepare the analysis driver.
+      try {
+        logger.run('Prepare analysis driver', () {
+          _createAnalysisDriver();
+        });
+      } on ConflictingSummaryException catch (e) {
+        errorSink.writeln('$e');
+        io.exitCode = ErrorSeverity.ERROR.ordinal;
+        return ErrorSeverity.ERROR;
       }
 
-      // Build and assemble linked libraries.
-      if (!options.buildSummaryOnlyUnlinked) {
-        // Prepare URIs of unlinked units that should be linked.
-        var unlinkedUris = new Set<String>();
-        for (var bundle in unlinkedBundles) {
-          unlinkedUris.addAll(bundle.unlinkedUnitUris);
+      // Add sources.
+      for (Uri uri in uriToFileMap.keys) {
+        File file = uriToFileMap[uri];
+        if (!file.exists) {
+          errorSink.writeln('File not found: ${file.path}');
+          io.exitCode = ErrorSeverity.ERROR.ordinal;
+          return ErrorSeverity.ERROR;
         }
-        for (var src in explicitSources) {
-          unlinkedUris.add('${src.uri}');
-        }
-        // Perform linking.
-        _computeLinkedLibraries(unlinkedUris);
-        assembler.recordDependencies(summaryDataStore);
+        Source source = new FileSource(file, uri);
+        explicitSources.add(source);
       }
 
-      // Write the whole package bundle.
-      PackageBundleBuilder bundle = assembler.assemble();
-      if (options.buildSummaryOutput != null) {
-        io.File file = new io.File(options.buildSummaryOutput);
-        file.writeAsBytesSync(bundle.toBuffer(), mode: io.FileMode.WRITE_ONLY);
+      // Write summary.
+      assembler = new PackageBundleAssembler();
+      if (_shouldOutputSummary) {
+        await logger.runAsync('Build and write output summary', () async {
+          // Prepare all unlinked units.
+          await logger.runAsync('Prepare unlinked units', () async {
+            for (var src in explicitSources) {
+              await _prepareUnlinkedUnit('${src.uri}');
+            }
+          });
+
+          // Build and assemble linked libraries.
+          if (!options.buildSummaryOnlyUnlinked) {
+            // Prepare URIs of unlinked units that should be linked.
+            var unlinkedUris = new Set<String>();
+            for (var bundle in unlinkedBundles) {
+              unlinkedUris.addAll(bundle.unlinkedUnitUris);
+            }
+            for (var src in explicitSources) {
+              unlinkedUris.add('${src.uri}');
+            }
+            // Perform linking.
+            _computeLinkedLibraries(unlinkedUris);
+            assembler.recordDependencies(summaryDataStore);
+          }
+
+          // Write the whole package bundle.
+          PackageBundleBuilder bundle = assembler.assemble();
+          if (options.buildSummaryOutput != null) {
+            io.File file = new io.File(options.buildSummaryOutput);
+            file.writeAsBytesSync(bundle.toBuffer(),
+                mode: io.FileMode.WRITE_ONLY);
+          }
+          if (options.buildSummaryOutputSemantic != null) {
+            bundle.flushInformative();
+            io.File file = new io.File(options.buildSummaryOutputSemantic);
+            file.writeAsBytesSync(bundle.toBuffer(),
+                mode: io.FileMode.WRITE_ONLY);
+          }
+        });
       }
-      if (options.buildSummaryOutputSemantic != null) {
-        bundle.flushInformative();
-        io.File file = new io.File(options.buildSummaryOutputSemantic);
-        file.writeAsBytesSync(bundle.toBuffer(), mode: io.FileMode.WRITE_ONLY);
+
+      if (options.buildSummaryOnly) {
+        return ErrorSeverity.NONE;
+      } else {
+        // Process errors.
+        await _printErrors(outputPath: options.buildAnalysisOutput);
+        return await _computeMaxSeverity();
       }
-    }
-
-    if (options.buildSummaryOnly) {
-      return ErrorSeverity.NONE;
-    } else {
-      // Process errors.
-      await _printErrors(outputPath: options.buildAnalysisOutput);
-      return await _computeMaxSeverity();
-    }
+    });
   }
 
   /**
    * Compute linked libraries for the given [libraryUris] using the linked
    * libraries of the [summaryDataStore] and unlinked units in [uriToUnit], and
    * add them to  the [assembler].
    */
   void _computeLinkedLibraries(Set<String> libraryUris) {
-    LinkedLibrary getDependency(String absoluteUri) =>
-        summaryDataStore.linkedMap[absoluteUri];
+    logger.run('Link output summary', () {
+      LinkedLibrary getDependency(String absoluteUri) =>
+          summaryDataStore.linkedMap[absoluteUri];
 
-    UnlinkedUnit getUnit(String absoluteUri) =>
-        summaryDataStore.unlinkedMap[absoluteUri] ?? uriToUnit[absoluteUri];
+      UnlinkedUnit getUnit(String absoluteUri) =>
+          summaryDataStore.unlinkedMap[absoluteUri] ?? uriToUnit[absoluteUri];
 
-    Map<String, LinkedLibraryBuilder> linkResult = link(
-        libraryUris,
-        getDependency,
-        getUnit,
-        analysisDriver.declaredVariables.get,
-        options.strongMode);
-    linkResult.forEach(assembler.addLinkedLibrary);
+      Map<String, LinkedLibraryBuilder> linkResult = link(
+          libraryUris,
+          getDependency,
+          getUnit,
+          analysisDriver.declaredVariables.get,
+          options.strongMode);
+      linkResult.forEach(assembler.addLinkedLibrary);
+    });
   }
 
   Future<ErrorSeverity> _computeMaxSeverity() async {
     ErrorSeverity maxSeverity = ErrorSeverity.NONE;
     if (!options.buildSuppressExitCode) {
       for (Source source in explicitSources) {
         ErrorsResult result = await analysisDriver.getErrors(source.fullName);
         for (AnalysisError error in result.errors) {
           ErrorSeverity processedSeverity = determineProcessedSeverity(
               error, options, analysisDriver.analysisOptions);
@@ skipping 12 matching lines @@
         recordDependencyInfo: _shouldOutputSummary);
 
     // Adds a bundle at `path` to `summaryDataStore`.
     PackageBundle addBundle(String path) {
       var bundle =
           new PackageBundle.fromBuffer(new io.File(path).readAsBytesSync());
       summaryDataStore.addBundle(path, bundle);
       return bundle;
     }
 
-    for (var path in options.buildSummaryInputs) {
-      var bundle = addBundle(path);
-      if (bundle.linkedLibraryUris.isEmpty &&
-          bundle.unlinkedUnitUris.isNotEmpty) {
-        throw new ArgumentError(
-            'Got an unlinked summary for --build-summary-input at `$path`. '
-            'Unlinked summaries should be provided with the '
-            '--build-summary-unlinked-input argument.');
+    int numInputs = options.buildSummaryInputs.length +
+        options.buildSummaryUnlinkedInputs.length;
+    logger.run('Add $numInputs input summaries', () {
+      for (var path in options.buildSummaryInputs) {
+        var bundle = addBundle(path);
+        if (bundle.linkedLibraryUris.isEmpty &&
+            bundle.unlinkedUnitUris.isNotEmpty) {
+          throw new ArgumentError(
+              'Got an unlinked summary for --build-summary-input at `$path`. '
+              'Unlinked summaries should be provided with the '
+              '--build-summary-unlinked-input argument.');
+        }
       }
-    }
 
-    for (var path in options.buildSummaryUnlinkedInputs) {
-      var bundle = addBundle(path);
-      unlinkedBundles.add(bundle);
-      if (bundle.linkedLibraryUris.isNotEmpty) {
-        throw new ArgumentError(
-            'Got a linked summary for --build-summary-input-unlinked at `$path`'
-            '. Linked bundles should be provided with the '
-            '--build-summary-input argument.');
+      for (var path in options.buildSummaryUnlinkedInputs) {
+        var bundle = addBundle(path);
+        unlinkedBundles.add(bundle);
+        if (bundle.linkedLibraryUris.isNotEmpty) {
+          throw new ArgumentError(
+              'Got a linked summary for --build-summary-input-unlinked at `$path`'
+              '. Linked bundles should be provided with the '
+              '--build-summary-input argument.');
+        }
       }
-    }
+    });
 
     DartSdk sdk;
-    PackageBundle sdkBundle;
-    if (options.dartSdkSummaryPath != null) {
-      SummaryBasedDartSdk summarySdk = new SummaryBasedDartSdk(
-          options.dartSdkSummaryPath, options.strongMode);
-      sdk = summarySdk;
-      sdkBundle = summarySdk.bundle;
-    } else {
-      FolderBasedDartSdk dartSdk = new FolderBasedDartSdk(resourceProvider,
-          resourceProvider.getFolder(options.dartSdkPath), options.strongMode);
-      dartSdk.analysisOptions =
-          Driver.createAnalysisOptionsForCommandLineOptions(
-              resourceProvider, options);
-      dartSdk.useSummary = !options.buildSummaryOnly;
-      sdk = dartSdk;
-      sdkBundle = dartSdk.getSummarySdkBundle(options.strongMode);
-    }
+    logger.run('Add SDK bundle', () {
+      PackageBundle sdkBundle;
+      if (options.dartSdkSummaryPath != null) {
+        SummaryBasedDartSdk summarySdk = new SummaryBasedDartSdk(
+            options.dartSdkSummaryPath, options.strongMode);
+        sdk = summarySdk;
+        sdkBundle = summarySdk.bundle;
+      } else {
+        FolderBasedDartSdk dartSdk = new FolderBasedDartSdk(
+            resourceProvider,
+            resourceProvider.getFolder(options.dartSdkPath),
+            options.strongMode);
+        dartSdk.analysisOptions =
+            Driver.createAnalysisOptionsForCommandLineOptions(
+                resourceProvider, options);
+        dartSdk.useSummary = !options.buildSummaryOnly;
+        sdk = dartSdk;
+        sdkBundle = dartSdk.getSummarySdkBundle(options.strongMode);
+      }
 
-    // Include SDK bundle to avoid parsing SDK sources.
-    summaryDataStore.addBundle(null, sdkBundle);
+      // Include SDK bundle to avoid parsing SDK sources.
+      summaryDataStore.addBundle(null, sdkBundle);
+    });
 
     var sourceFactory = new SourceFactory(<UriResolver>[
       new DartUriResolver(sdk),
       new InSummaryUriResolver(resourceProvider, summaryDataStore),
       new ExplicitSourceResolver(uriToFileMap)
     ]);
 
     analysisOptions = Driver.createAnalysisOptionsForCommandLineOptions(
         resourceProvider, options);
 
-    PerformanceLog logger = new PerformanceLog(null);
     AnalysisDriverScheduler scheduler = new AnalysisDriverScheduler(logger);
     analysisDriver = new AnalysisDriver(
         scheduler,
         logger,
         resourceProvider,
         new MemoryByteStore(),
         new FileContentOverlay(),
         null,
         sourceFactory,
         analysisOptions,
@@ skipping 49 matching lines @@
     UnlinkedUnitBuilder unlinkedUnit = serializeAstUnlinked(result.unit);
     uriToUnit[absoluteUri] = unlinkedUnit;
     assembler.addUnlinkedUnit(source, unlinkedUnit);
   }
 
   /**
    * Print errors for all explicit sources.  If [outputPath] is supplied, output
    * is sent to a new file at that path.
    */
   Future<Null> _printErrors({String outputPath}) async {
-    StringBuffer buffer = new StringBuffer();
-    var severityProcessor = (AnalysisError error) =>
-        determineProcessedSeverity(error, options, analysisOptions);
-    ErrorFormatter formatter = options.machineFormat
-        ? new MachineErrorFormatter(buffer, options, stats,
-            severityProcessor: severityProcessor)
-        : new HumanErrorFormatter(buffer, options, stats,
-            severityProcessor: severityProcessor);
-    for (Source source in explicitSources) {
-      var result = await analysisDriver.getErrors(source.fullName);
-      var errorInfo = new AnalysisErrorInfoImpl(result.errors, result.lineInfo);
-      formatter.formatErrors([errorInfo]);
-    }
-    formatter.flush();
-    if (!options.machineFormat) {
-      stats.print(buffer);
-    }
-    if (outputPath == null) {
-      StringSink sink = options.machineFormat ? errorSink : outSink;
-      sink.write(buffer);
-    } else {
-      new io.File(outputPath).writeAsStringSync(buffer.toString());
-    }
+    await logger.runAsync('Compute and print analysis errors', () async {
+      StringBuffer buffer = new StringBuffer();
+      var severityProcessor = (AnalysisError error) =>
+          determineProcessedSeverity(error, options, analysisOptions);
+      ErrorFormatter formatter = options.machineFormat
+          ? new MachineErrorFormatter(buffer, options, stats,
+              severityProcessor: severityProcessor)
+          : new HumanErrorFormatter(buffer, options, stats,
+              severityProcessor: severityProcessor);
+      for (Source source in explicitSources) {
+        var result = await analysisDriver.getErrors(source.fullName);
+        var errorInfo =
+            new AnalysisErrorInfoImpl(result.errors, result.lineInfo);
+        formatter.formatErrors([errorInfo]);
+      }
+      formatter.flush();
+      if (!options.machineFormat) {
+        stats.print(buffer);
+      }
+      if (outputPath == null) {
+        StringSink sink = options.machineFormat ? errorSink : outSink;
+        sink.write(buffer);
+      } else {
+        new io.File(outputPath).writeAsStringSync(buffer.toString());
+      }
+    });
   }
 }
 
 /**
  * Instances of the class [ExplicitSourceResolver] map URIs to files on disk
  * using a fixed mapping provided at construction time.
  */
 class ExplicitSourceResolver extends UriResolver {
   final Map<Uri, File> uriToFileMap;
   final Map<String, Uri> pathToUriMap;
@@ skipping 26 matching lines @@
    * Build the inverse mapping of [uriToSourceMap].
    */
   static Map<String, Uri> _computePathToUriMap(Map<Uri, File> uriToSourceMap) {
     Map<String, Uri> pathToUriMap = <String, Uri>{};
     uriToSourceMap.forEach((Uri uri, File file) {
       pathToUriMap[file.path] = uri;
     });
     return pathToUriMap;
   }
 }