Invalidate resolution of analysisOptions/sourceFactory changes.

pkg/analyzer/lib/src/task/dart_work_manager.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.src.task.dart_work_manager;
 
 import 'dart:collection';
 
 import 'package:analyzer/src/context/cache.dart';
 import 'package:analyzer/src/generated/engine.dart'
@@ skipping 72 matching lines @@
    * Initialize a newly created manager.
    */
   DartWorkManager(this.context);
 
   /**
    * Returns the correctly typed result of `context.analysisCache`.
    */
   AnalysisCache get analysisCache => context.analysisCache;
 
   /**
+   * The partition that contains analysis results that are not shared with other
+   * contexts.
+   */
+  CachePartition get privateAnalysisCachePartition =>
+      context.privateAnalysisCachePartition;
+
+  /**
    * Specifies that the client want the given [result] of the given [target]
    * to be computed with priority.
    */
   void addPriorityResult(AnalysisTarget target, ResultDescriptor result) {
     priorityResultQueue.add(new TargetedResult(target, result));
   }
 
   /**
    * Notifies the manager about changes in the explicit source list.
    */
@@ skipping 133 matching lines @@
   WorkOrderPriority getNextResultPriority() {
     if (priorityResultQueue.isNotEmpty) {
       return WorkOrderPriority.PRIORITY;
     }
     if (unknownSourceQueue.isNotEmpty || librarySourceQueue.isNotEmpty) {
       return WorkOrderPriority.NORMAL;
     }
     return WorkOrderPriority.NONE;
   }
 
+  /**
+   * Notifies the manager about analysis options changes.
+   */
+  void onAnalysisOptionsChanged() {
+    _invalidateAllLocalResolutionInformation(false);
+  }
+
+  /**
+   * Notifies the manager about [SourceFactory] changes.
+   */
+  void onSourceFactoryChanged() {
+    _invalidateAllLocalResolutionInformation(true);
+  }
+
   @override
   void resultsComputed(
       AnalysisTarget target, Map<ResultDescriptor, dynamic> outputs) {
     // Organize sources.
     if (_isDartSource(target)) {
       SourceKind kind = outputs[SOURCE_KIND];
       if (kind != null) {
         unknownSourceQueue.remove(target);
         if (kind == SourceKind.LIBRARY &&
             context.shouldErrorsBeAnalyzed(target, null)) {
@@ skipping 48 matching lines @@
         context.getNotice(source).setErrors(info.errors, info.lineInfo);
       }
     }
   }
 
   void unitIncrementallyResolved(Source librarySource, Source unitSource) {
     librarySourceQueue.add(librarySource);
   }
 
   /**
+   * Invalidate all of the resolution results computed by this context. The flag
+   * [invalidateUris] should be `true` if the cached results of converting URIs
+   * to source files should also be invalidated.
+   */
+  void _invalidateAllLocalResolutionInformation(bool invalidateUris) {
+    CachePartition partition = privateAnalysisCachePartition;
+    // Prepare targets and values to invalidate.
+    List<Source> dartSources = <Source>[];
+    List<LibrarySpecificUnit> unitTargets = <LibrarySpecificUnit>[];
+    MapIterator<AnalysisTarget, CacheEntry> iterator = partition.iterator();
+    while (iterator.moveNext()) {
+      AnalysisTarget target = iterator.key;
+      // Optionally gather Dart sources to invalidate URIs resolution.
+      if (invalidateUris && _isDartSource(target)) {
+        dartSources.add(target);
+      }
+      // LibrarySpecificUnit(s) are roots of Dart resolution.
+      // When one is invalidated, invalidation is propagated to all resolution.
+      if (target is LibrarySpecificUnit) {
+        unitTargets.add(target);
+        Source library = target.library;
+        if (context.exists(library)) {
+          librarySourceQueue.add(library);
+        }
+      }
+    }
+    // Invalidate targets and values.
+    unitTargets.forEach(partition.remove);
+    for (Source dartSource in dartSources) {
+      CacheEntry entry = partition.get(dartSource);
+      if (dartSource != null) {
+        // TODO(scheglov) we invalidate too much.
+        // Would be nice to invalidate just URLs resolution.
+        entry.setState(PARSED_UNIT, CacheState.INVALID);
+        entry.setState(IMPORTED_LIBRARIES, CacheState.INVALID);
+        entry.setState(EXPLICITLY_IMPORTED_LIBRARIES, CacheState.INVALID);
+        entry.setState(EXPORTED_LIBRARIES, CacheState.INVALID);
+        entry.setState(INCLUDED_PARTS, CacheState.INVALID);
+      }
+    }
+  }
+
+  /**
    * Invalidate  [CONTAINING_LIBRARIES] for the given [source].
    * [CONTAINING_LIBRARIES] does not have dependencies, so we manage it here.
    * The [source] may be a part, or a library whose contents is updated so
    * will be a part.
    */
   void _invalidateContainingLibraries(Source source) {
     CacheEntry entry = analysisCache.get(source);
     if (entry != null) {
       entry.setState(CONTAINING_LIBRARIES, CacheState.INVALID);
     }
@@ skipping 23 matching lines @@
         }
       }
     }
     _invalidateContainingLibraries(library);
   }
 
   static bool _isDartSource(AnalysisTarget target) {
     return target is Source && AnalysisEngine.isDartFileName(target.fullName);
   }
 }