New analyzer snapshot.

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:collection';
@@ skipping 1619 matching lines @@
     bool hintsEnabled = _options.hint;
     //
     // Look for priority sources that need to be analyzed.
     //
     for (Source source in _priorityOrder) {
       _getSourcesNeedingProcessing(source, _cache.get(source), true, hintsEnabled, sources);
     }
     //
     // Look for non-priority sources that need to be analyzed.
     //
-    MapIterator<Source, SourceEntry> iterator = _cache.iterator();
-    while (iterator.moveNext()) {
-      _getSourcesNeedingProcessing(iterator.key, iterator.value, false, hintsEnabled, sources);
+    WorkManager_WorkIterator iterator = _workManager.iterator();
+    while (iterator.hasNext) {
+      Source source = iterator.next();
+      _getSourcesNeedingProcessing(source, _cache.get(source), false, hintsEnabled, sources);
     }
     return new List<Source>.from(sources);
   }
 
   @override
   AnalysisContextStatistics get statistics {
     bool hintsEnabled = _options.hint;
     AnalysisContextStatisticsImpl statistics = new AnalysisContextStatisticsImpl();
     MapIterator<Source, SourceEntry> iterator = _cache.iterator();
     while (iterator.moveNext()) {
@@ skipping 111 matching lines @@
     int getStart = JavaSystem.currentTimeMillis();
     AnalysisTask task = nextAnalysisTask;
     int getEnd = JavaSystem.currentTimeMillis();
     if (task == null && _validateCacheConsistency()) {
       task = nextAnalysisTask;
     }
     if (task == null) {
       return new AnalysisResult(_getChangeNotices(true), getEnd - getStart, null, -1);
     }
     String taskDescription = task.toString();
-    if (!_reportedLoop && !_recentTasks.add(taskDescription)) {
-      PrintStringWriter writer = new PrintStringWriter();
-      writer.print("Performing repeated task: ");
-      writer.println(taskDescription);
-      for (String description in _recentTasks) {
-        writer.print("  ");
-        writer.println(description);
-      }
-      _logInformation(writer.toString());
-    }
+    //    if (!reportedLoop && !recentTasks.add(taskDescription)) {
+    //      reportedLoop = true;
+    //      @SuppressWarnings("resource")
+    //      PrintStringWriter writer = new PrintStringWriter();
+    //      writer.print("Performing repeated task: ");
+    //      writer.println(taskDescription);
+    //      for (String description : recentTasks) {
+    //        writer.print("  ");
+    //        writer.println(description);
+    //      }
+    //      logInformation(writer.toString());
+    //    }
     _notifyAboutToPerformTask(taskDescription);
     if (_TRACE_PERFORM_TASK) {
       print(taskDescription);
     }
     int performStart = JavaSystem.currentTimeMillis();
     try {
       task.perform(_resultRecorder);
     } on ObsoleteSourceAnalysisException catch (exception) {
       AnalysisEngine.instance.logger.logInformation2("Could not perform analysis task: ${taskDescription}", exception);
     } on AnalysisException catch (exception) {
@@ skipping 1557 matching lines @@
         } else {
           sourcesToRemove.add(source);
         }
       }
     } finally {
       int count = sourcesToRemove.length;
       for (int i = 0; i < count; i++) {
         _workManager.remove(sourcesToRemove[i]);
       }
     }
-    //      //
-    //      // Look for a non-priority source that needs to be analyzed and was missed by the loop above.
-    //      //
-    //      for (Map.Entry<Source, SourceEntry> entry : cache.entrySet()) {
-    //        source = entry.getKey();
-    //        TaskData taskData = getNextAnalysisTaskForSource(source, entry.getValue(), false, hintsEnabled);
-    //        AnalysisTask task = taskData.getTask();
-    //        if (task != null) {
-    //          System.out.println("Failed to analyze " + source.getFullName());
-    //          return task;
-    //        }
-    //      }
     if (hasBlockedTask) {
       // All of the analysis work is blocked waiting for an asynchronous task to complete.
       return WaitForAsyncTask.instance;
     }
     return null;
   }
 
   /**
    * Look at the given source to see whether a task needs to be performed related to it. Return the
    * task that should be performed, or `null` if there is no more work to be done for the
@@ skipping 2884 matching lines @@
    * The logger that should receive information about errors within the analysis engine.
    */
   Logger _logger = Logger.NULL;
 
   /**
    * The partition manager being used to manage the shared partitions.
    */
   final PartitionManager partitionManager = new PartitionManager();
 
   /**
+   * A flag indicating whether union types should be used.
+   */
+  bool enableUnionTypes = false;
+
+  /**
+   * A flag indicating whether union types should have strict semantics. This option has no effect
+   * when `enabledUnionTypes` is `false`.
+   */
+  bool strictUnionTypes = false;
+
+  /**
+   * Clear any caches holding on to analysis results so that a full re-analysis will be performed
+   * the next time an analysis context is created.
+   */
+  void clearCaches() {
+    partitionManager.clearCache();
+  }
+
+  /**
    * Create a new context in which analysis can be performed.
    *
    * @return the analysis context that was created
    */
   AnalysisContext createAnalysisContext() {
     //
     // If instrumentation is ignoring data, return an uninstrumented analysis context.
     //
     if (Instrumentation.isNullLogger) {
       return new AnalysisContextImpl();
@@ skipping 5963 matching lines @@
     InstrumentationBuilder instrumentation = Instrumentation.builder2("Analysis-performAnalysisTask");
     _checkThread(instrumentation);
     try {
       instrumentation.metric3("contextId", _contextId);
       AnalysisResult result = _basis.performAnalysisTask();
       if (result.changeNotices != null) {
         instrumentation.metric2("ChangeNotice-count", result.changeNotices.length);
       }
       return result;
     } finally {
-      instrumentation.log2(2);
+      instrumentation.log2(15);
     }
   }
 
   @override
   void recordLibraryElements(Map<Source, LibraryElement> elementMap) {
     _basis.recordLibraryElements(elementMap);
   }
 
   @override
   void removeListener(AnalysisListener listener) {
@@ skipping 941 matching lines @@
    * A table mapping SDK's to the partitions used for those SDK's.
    */
   HashMap<DartSdk, SdkCachePartition> _sdkPartitions = new HashMap<DartSdk, SdkCachePartition>();
 
   /**
    * The default cache size for a Dart SDK partition.
    */
   static int _DEFAULT_SDK_CACHE_SIZE = 256;
 
   /**
+   * Clear any cached data being maintained by this manager.
+   */
+  void clearCache() {
+    _sdkPartitions.clear();
+  }
+
+  /**
    * Return the partition being used for the given SDK, creating the partition if necessary.
    *
    * @param sdk the SDK for which a partition is being requested
    * @return the partition being used for the given SDK
    */
   SdkCachePartition forSdk(DartSdk sdk) {
     SdkCachePartition partition = _sdkPartitions[sdk];
     if (partition == null) {
       partition = new SdkCachePartition(sdk.context as InternalAnalysisContext, _DEFAULT_SDK_CACHE_SIZE);
       _sdkPartitions[sdk] = partition;
@@ skipping 2353 matching lines @@
     _index++;
     if (_index >= WorkManager_this._workQueues[_queueIndex].length) {
       _index = 0;
       _queueIndex++;
       while (_queueIndex < WorkManager_this._workQueues.length && WorkManager_this._workQueues[_queueIndex].isEmpty) {
         _queueIndex++;
       }
     }
   }
 }