Report incremental/full analysis performance via instrumentation.

pkg/analyzer/lib/src/generated/engine.dart

 // 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.
 
 // This code was auto-generated, is not intended to be edited, and is subject to
 // significant change. Please see the README file for more information.
 
 library engine;
 
 import "dart:math" as math;
@@ skipping 903 matching lines @@
    */
   static int _PRIORITY_ORDER_SIZE_DELTA = 4;
 
   /**
    * A flag indicating whether trace output should be produced as analysis tasks are performed. Used
    * for debugging.
    */
   static bool _TRACE_PERFORM_TASK = false;
 
   /**
+   * The next context identifier.
+   */
+  static int _NEXT_ID = 0;
+
+  /**
+   * The unique identifier of this context.
+   */
+  final int _id = _NEXT_ID++;
+
+  /**
    * The set of analysis options controlling the behavior of this context.
    */
   AnalysisOptionsImpl _options = new AnalysisOptionsImpl();
 
   /**
    * A flag indicating whether errors related to sources in the SDK should be generated and
    * reported.
    */
   bool _generateSdkErrors = true;
 
@@ skipping 75 matching lines @@
    * [cacheLock] before accessing this field.
    */
   IncrementalAnalysisCache _incrementalAnalysisCache;
 
   /**
    * The object used to manage the list of sources that need to be analyzed.
    */
   WorkManager _workManager = new WorkManager();
 
   /**
+   * The [Stopwatch] of the current "perform tasks cycle".
+   */
+  Stopwatch _performAnalysisTaskStopwatch;
+
+  /**
    * The controller for sending [SourcesChangedEvent]s.
    */
   StreamController<SourcesChangedEvent> _onSourcesChangedController;
 
   /**
    * The listeners that are to be notified when various analysis results are produced in this
    * context.
    */
   List<AnalysisListener> _listeners = new List<AnalysisListener>();
 
@@ skipping 1139 matching lines @@
       print("----------------------------------------");
     }
     int getStart = JavaSystem.currentTimeMillis();
     AnalysisTask task = nextAnalysisTask;
     int getEnd = JavaSystem.currentTimeMillis();
     if (task == null && _validateCacheConsistency()) {
       task = nextAnalysisTask;
     }
     if (task == null) {
       _validateLastIncrementalResolutionResult();
+      if (_performAnalysisTaskStopwatch != null) {
+        AnalysisEngine.instance.instrumentationService.logPerformance(
+            AnalysisPerformanceKind.FULL,
+            _performAnalysisTaskStopwatch,
+            'context_id=$_id');
+        _performAnalysisTaskStopwatch = null;
+      }
       return new AnalysisResult(
           _getChangeNotices(true),
           getEnd - getStart,
           null,
           -1);
     }
+    if (_performAnalysisTaskStopwatch == null) {
+      _performAnalysisTaskStopwatch = new Stopwatch()..start();
+    }
     String taskDescription = task.toString();
     _notifyAboutToPerformTask(taskDescription);
     if (_TRACE_PERFORM_TASK) {
       print(taskDescription);
     }
     int performStart = JavaSystem.currentTimeMillis();
     try {
       task.perform(_resultRecorder);
     } on ObsoleteSourceAnalysisException catch (exception, stackTrace) {
       AnalysisEngine.instance.logger.logInformation(
@@ skipping 34 matching lines @@
     if (incrementalResolutionValidation_lastUnitSource == null ||
         incrementalResolutionValidation_lastLibrarySource == null ||
         incrementalResolutionValidation_lastUnit == null) {
       return;
     }
     CompilationUnit fullUnit = getResolvedCompilationUnit2(
         incrementalResolutionValidation_lastUnitSource,
         incrementalResolutionValidation_lastLibrarySource);
     if (fullUnit != null) {
       try {
-        assertSameResolution(incrementalResolutionValidation_lastUnit, fullUnit);
+        assertSameResolution(
+            incrementalResolutionValidation_lastUnit,
+            fullUnit);
       } on IncrementalResolutionMismatch catch (mismatch, stack) {
         String failure = mismatch.message;
-        String message = 'Incremental resolution mismatch:\n$failure\nat\n$stack';
+        String message =
+            'Incremental resolution mismatch:\n$failure\nat\n$stack';
         AnalysisEngine.instance.logger.logError(message);
       }
     }
     incrementalResolutionValidation_lastUnitSource = null;
     incrementalResolutionValidation_lastLibrarySource = null;
     incrementalResolutionValidation_lastUnit = null;
   }
 
   @override
   void recordLibraryElements(Map<Source, LibraryElement> elementMap) {
@@ skipping 2724 matching lines @@
       return false;
     }
     // prepare the existing unit
     Source librarySource = librarySources[0];
     CompilationUnit oldUnit =
         getResolvedCompilationUnit2(unitSource, librarySource);
     if (oldUnit == null) {
       return false;
     }
     // do resolution
+    Stopwatch perfCounter = new Stopwatch()..start();
     PoorMansIncrementalResolver resolver = new PoorMansIncrementalResolver(
         typeProvider,
         unitSource,
         dartEntry,
         analysisOptions.incrementalApi);
     bool success = resolver.resolve(oldUnit, newCode);
+    AnalysisEngine.instance.instrumentationService.logPerformance(
+        AnalysisPerformanceKind.INCREMENTAL,
+        perfCounter,
+        'success=$success,context_id=$_id,code_length=${newCode.length}');
     if (!success) {
       return false;
     }
     // if validation, remember the result, but throw it away
     if (analysisOptions.incrementalValidation) {
       incrementalResolutionValidation_lastUnitSource = oldUnit.element.source;
-      incrementalResolutionValidation_lastLibrarySource = oldUnit.element.library.source;
+      incrementalResolutionValidation_lastLibrarySource =
+          oldUnit.element.library.source;
       incrementalResolutionValidation_lastUnit = oldUnit;
       return false;
     }
     // prepare notice
     ChangeNoticeImpl notice = _getNotice(unitSource);
     notice.compilationUnit = oldUnit;
     // apply updated errors
     {
       LineInfo lineInfo = getLineInfo(unitSource);
       notice.setErrors(dartEntry.allErrors, lineInfo);
@@ skipping 7152 matching lines @@
     if (element.id == _id) {
       result = element;
       throw new _ElementByIdFinderException();
     }
     super.visitElement(element);
   }
 }
 
 class _ElementByIdFinderException {
 }