Support refresh of individual analysis roots (issue 22254)

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:math' show max;
 
@@ skipping 715 matching lines @@
         if (_onAnalysisCompleteCompleter != null) {
           _onAnalysisCompleteCompleter.complete();
           _onAnalysisCompleteCompleter = null;
         }
         ServerPerformanceStatistics.idle.makeCurrent();
       }
     }
   }
 
   /**
-   * Trigger reanalysis of all files from disk.
+   * Trigger reanalysis of all files in the given list of analysis [roots], or
+   * everything if the analysis roots is `null`.
    */
-  void reanalyze() {
+  void reanalyze(List<Resource> roots) {
     // Clear any operations that are pending.
-    operationQueue.clear();
+    if (roots == null) {
+      operationQueue.clear();
+    } else {
+      for (AnalysisContext context in _getContexts(roots)) {
+        operationQueue.contextRemoved(context);
+      }
+    }
     // Instruct the contextDirectoryManager to rebuild all contexts from
     // scratch.
-    contextDirectoryManager.refresh();
+    contextDirectoryManager.refresh(roots);
   }
 
   /**
    * Schedules execution of the given [ServerOperation].
    */
   void scheduleOperation(ServerOperation operation) {
     addOperation(operation);
     _schedulePerformOperation();
   }
 
@@ skipping 335 matching lines @@
     //
     // Update the defaults used to create new contexts.
     //
     AnalysisOptionsImpl options = contextDirectoryManager.defaultOptions;
     optionUpdaters.forEach((OptionUpdater optionUpdater) {
       optionUpdater(options);
     });
   }
 
   /**
+   * Return a set of contexts containing all of the resources in the given list
+   * of [resources].
+   */
+  Set<AnalysisContext> _getContexts(List<Resource> resources) {
+    Set<AnalysisContext> contexts = new HashSet<AnalysisContext>();
+    resources.forEach((Resource resource) {
+      if (resource is Folder) {
+        contexts.addAll(contextDirectoryManager.contextsInAnalysisRoot(resource));
+      }
+    });
+    return contexts;
+  }
+
+  /**
    * Returns the [CompilationUnit] of the Dart file with the given [source] that
    * should be used to resend notifications for already resolved unit.
    * Returns `null` if the file is not a part of any context, library has not
    * been yet resolved, or any problem happened.
    */
   CompilationUnit _getResolvedCompilationUnitToResendNotification(
       AnalysisContext context, Source source) {
     List<Source> librarySources = context.getLibrariesContaining(source);
     if (librarySources.isEmpty) {
       return null;
@@ skipping 314 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');
 }