Dispose private cache partition on AnalysisContext.dispose().

pkg/analyzer/lib/src/context/cache.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.context.cache;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:analyzer/src/generated/engine.dart'
@@ skipping 301 matching lines @@
     _setFlag(_EXPLICITLY_ADDED_FLAG, explicitlyAdded);
   }
 
   /**
    * Return a list of result descriptors for results whose state is not
    * [CacheState.INVALID].
    */
   List<ResultDescriptor> get nonInvalidResults => _resultMap.keys.toList();
 
   /**
+   * Notifies the entry that the client is going to stop using it.
+   */
+  void dispose() {
+    _resultMap.forEach((descriptor, data) {
+      TargetedResult result = new TargetedResult(target, descriptor);
+      for (TargetedResult dependedOnResult in data.dependedOnResults) {
+        ResultData dependedOnData = _partition._getDataFor(dependedOnResult);
+        if (dependedOnData != null) {
+          dependedOnData.dependentResults.remove(result);
+        }
+      }
+    });
+    _resultMap.clear();
+  }
+
+  /**
    * Fix the state of the [exception] to match the current state of the entry.
    */
   void fixExceptionState() {
     if (!hasErrorState()) {
       _exception = null;
     }
   }
 
   /**
    * Look up the [ResultData] of [descriptor], or add a new one if it isn't
@@ skipping 181 matching lines @@
     }
     if (deltaResult == DeltaResult.KEEP_CONTINUE) {
       thisData = _resultMap[descriptor];
     }
     if (thisData == null) {
       return;
     }
     // Stop depending on other results.
     TargetedResult thisResult = new TargetedResult(target, descriptor);
     for (TargetedResult dependedOnResult in thisData.dependedOnResults) {
-      ResultData data = _partition._getDataFor(dependedOnResult, orNull: true);
+      ResultData data = _partition._getDataFor(dependedOnResult);
       if (data != null) {
         data.dependentResults.remove(thisResult);
       }
     }
     // Invalidate results that depend on this result.
     List<TargetedResult> dependentResults = thisData.dependentResults.toList();
     for (TargetedResult dependentResult in dependentResults) {
       CacheEntry entry = _partition.get(dependentResult.target);
       if (entry != null) {
         entry._invalidate(dependentResult.result, delta);
@@ skipping 18 matching lines @@
       _invalidate(result, null);
     }
   }
 
   /**
    * Set the [dependedOn] on which this result depends.
    */
   void _setDependedOnResults(ResultData thisData, TargetedResult thisResult,
       List<TargetedResult> dependedOn) {
     thisData.dependedOnResults.forEach((TargetedResult dependedOnResult) {
-      ResultData data = _partition._getDataFor(dependedOnResult, orNull: true);
+      ResultData data = _partition._getDataFor(dependedOnResult);
       if (data != null) {
         data.dependentResults.remove(thisResult);
       }
     });
     thisData.dependedOnResults = dependedOn;
     thisData.dependedOnResults.forEach((TargetedResult dependedOnResult) {
-      ResultData data = _partition._getDataFor(dependedOnResult, orNull: true);
+      ResultData data = _partition._getDataFor(dependedOnResult);
       if (data != null) {
         data.dependentResults.add(thisResult);
       }
     });
   }
 
   /**
    * Set states of the given and dependent results to [CacheState.ERROR] and
    * their values to the corresponding default values
    */
@@ skipping 242 matching lines @@
    */
   Map<AnalysisTarget, CacheEntry> get map => _targetMap;
 
   /**
    * Return the stream that is notified when a value is invalidated.
    */
   Stream<InvalidatedResult> get onResultInvalidated =>
       _onResultInvalidated.stream;
 
   /**
+   * Notifies the partition that the client is going to stop using it.
+   */
+  void dispose() {
+    for (CacheEntry entry in _targetMap.values) {
+      entry.dispose();
+    }
+    _targetMap.clear();
+  }
+
+  /**
    * Return the entry associated with the given [target].
    */
   CacheEntry get(AnalysisTarget target) => _targetMap[target];
 
   /**
    * Return [Source]s whose full path is equal to the given [path].
    * Maybe empty, but not `null`.
    */
   List<Source> getSourcesWithFullName(String path) {
     List<Source> sources = _pathToSources[path];
@@ skipping 80 matching lines @@
   void _addIfSource(AnalysisTarget target) {
     if (target is Source) {
       _sources.add(target);
       {
         String fullName = target.fullName;
         _pathToSources.putIfAbsent(fullName, () => <Source>[]).add(target);
       }
     }
   }
 
-  ResultData _getDataFor(TargetedResult result, {bool orNull: false}) {
+  ResultData _getDataFor(TargetedResult result) {
     CacheEntry entry = context.analysisCache.get(result.target);
-    if (orNull) {
-      return entry != null ? entry._resultMap[result.result] : null;
-    } else {
-      return entry.getResultData(result.result);
-    }
+    return entry != null ? entry._resultMap[result.result] : null;
   }
 
   /**
    * Return the [CacheFlushManager] for the given [descriptor], not `null`.
    */
   CacheFlushManager _getFlushManager(ResultDescriptor descriptor) {
     ResultCachingPolicy policy = descriptor.cachingPolicy;
     if (identical(policy, DEFAULT_CACHING_POLICY)) {
       return UnlimitedCacheFlushManager.INSTANCE;
     }
@@ skipping 208 matching lines @@
   void resultAccessed(TargetedResult result) {}
 
   @override
   List<TargetedResult> resultStored(TargetedResult newResult, newValue) {
     return TargetedResult.EMPTY_LIST;
   }
 
   @override
   void targetRemoved(AnalysisTarget target) {}
 }