Add notification of analyzed files

pkg/analysis_server/lib/src/analysis_server.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.
 
 library analysis.server;
 
 import 'dart:async';
 import 'dart:collection';
 import 'dart:core' hide Resource;
 import 'dart:math' show max;
@@ skipping 54 matching lines @@
 
 /**
  * Instances of the class [AnalysisServer] implement a server that listens on a
  * [CommunicationChannel] for analysis requests and process them.
  */
 class AnalysisServer {
   /**
    * The version of the analysis server. The value should be replaced
    * automatically during the build.
    */
-  static final String VERSION = '1.7.0';
+  static final String VERSION = '1.8.0';
 
   /**
    * The number of milliseconds to perform operations before inserting
    * a 1 millisecond delay so that the VM and dart:io can deliver content
    * to stdin. This should be removed once the underlying problem is fixed.
    */
   static int performOperationDelayFreqency = 25;
 
   /**
    * The channel from which requests are received and to which responses should
@@ skipping 71 matching lines @@
    * True if there is a pending future which will execute [performOperation].
    */
   bool performOperationPending = false;
 
   /**
    * A set of the [ServerService]s to send notifications for.
    */
   Set<ServerService> serverServices = new HashSet<ServerService>();
 
   /**
+   * A set of the [GeneralAnalysisService]s to send notifications for.
+   */
+  Set<GeneralAnalysisService> generalAnalysisServices =
+      new HashSet<GeneralAnalysisService>();
+
+  /**
    * A table mapping [AnalysisService]s to the file paths for which these
    * notifications should be sent.
    */
   Map<AnalysisService, Set<String>> analysisServices =
       new HashMap<AnalysisService, Set<String>>();
 
   /**
    * A table mapping [AnalysisContext]s to the completers that should be
    * completed when analysis of this context is finished.
    */
@@ skipping 578 matching lines @@
     } finally {
       if (_test_onOperationPerformedCompleter != null) {
         _test_onOperationPerformedCompleter.complete(operation);
         _test_onOperationPerformedCompleter = null;
       }
       if (!operationQueue.isEmpty) {
         ServerPerformanceStatistics.intertask.makeCurrent();
         _schedulePerformOperation();
       } else {
         sendStatusNotification(null);
+        if (generalAnalysisServices

[Paul Berry, 2015/07/13 21:51:13]

Consider putting this before the call to sendStatusNotifcation(null) so that
when the client receives a status message indicating that analysis is done,
there will be no further notifications pending.  This should make integration
testing easier (should we choose to integration test this feature :)).

[Brian Wilkerson, 2015/07/13 22:05:03]

Done

+            .contains(GeneralAnalysisService.ANALYZED_FILES)) {
+          sendAnalysisNotificationAnalyzedFiles(this);
+        }
         if (_onAnalysisCompleteCompleter != null) {
           _onAnalysisCompleteCompleter.complete();
           _onAnalysisCompleteCompleter = null;
         }
         ServerPerformanceStatistics.idle.makeCurrent();
       }
     }
   }
 
   /**
@@ skipping 168 matching lines @@
             }
           }
         }
       }
     });
     // remember new subscriptions
     this.analysisServices = subscriptions;
   }
 
   /**
+   * Implementation for `analysis.setGeneralSubscriptions`.
+   */
+  void setGeneralAnalysisSubscriptions(
+      List<GeneralAnalysisService> subscriptions) {
+    Set<GeneralAnalysisService> newServices = subscriptions.toSet();
+    if (newServices.contains(GeneralAnalysisService.ANALYZED_FILES) &&
+        !generalAnalysisServices
+            .contains(GeneralAnalysisService.ANALYZED_FILES) &&
+        isAnalysisComplete()) {
+      sendAnalysisNotificationAnalyzedFiles(this);
+    }
+    generalAnalysisServices = newServices;
+  }
+
+  /**
    * Set the priority files to the given [files].
    */
   void setPriorityFiles(String requestId, List<String> files) {
     // Note: when a file is a priority file, that information needs to be
     // propagated to all contexts that analyze the file, so that all contexts
     // will be able to do incremental resolution of the file.  See
     // dartbug.com/22209.
     Map<AnalysisContext, List<Source>> sourceMap =
         new HashMap<AnalysisContext, List<Source>>();
     List<String> unanalyzed = new List<String>();
@@ skipping 564 matching lines @@
   /**
    * The [PerformanceTag] for time spent in server request handlers.
    */
   static PerformanceTag serverRequests = new PerformanceTag('serverRequests');
 
   /**
    * The [PerformanceTag] for time spent in split store microtasks.
    */
   static PerformanceTag splitStore = new PerformanceTag('splitStore');
 }