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 1019 matching lines @@
       }
       int count = sourcesToInvalidate.length;
       for (int i = 0; i < count; i++) {
         Source source = sourcesToInvalidate[i];
         SourceEntry entry = _getReadableSourceEntry(source);
         if (entry is DartEntry) {
           DartEntry dartEntry = entry;
           DartEntryImpl dartCopy = dartEntry.writableCopy;
           dartCopy.invalidateAllResolutionInformation(false);
           _cache.put(source, dartCopy);
-          SourcePriority priority = SourcePriority.UNKNOWN;
-          SourceKind kind = dartCopy.kind;
-          if (kind == SourceKind.LIBRARY) {
-            priority = SourcePriority.LIBRARY;
-          } else if (kind == SourceKind.PART) {
-            priority = SourcePriority.NORMAL_PART;
-          }
-          _workManager.add(source, priority);
+          _workManager.add(source, _computePriority(dartCopy));
         } else if (entry is HtmlEntry) {
           HtmlEntry htmlEntry = entry;
           HtmlEntryImpl htmlCopy = htmlEntry.writableCopy;
           htmlCopy.invalidateAllResolutionInformation(false);
           _cache.put(source, htmlCopy);
           _workManager.add(source, SourcePriority.HTML);
         }
       }
     }
   }
@@ skipping 1479 matching lines @@
    */
   void _computeAllLibrariesDependingOn(Source library, HashSet<Source> librariesToInvalidate) {
     if (librariesToInvalidate.add(library)) {
       for (Source dependentLibrary in getLibrariesDependingOn(library)) {
         _computeAllLibrariesDependingOn(dependentLibrary, librariesToInvalidate);
       }
     }
   }
 
   /**
+   * Compute the priority that should be used when the source associated with the given entry is
+   * added to the work manager.
+   *
+   * @param dartEntry the entry associated with the source
+   * @return the priority that was computed
+   */
+  SourcePriority _computePriority(DartEntry dartEntry) {
+    SourceKind kind = dartEntry.kind;
+    if (kind == SourceKind.LIBRARY) {
+      return SourcePriority.LIBRARY;
+    } else if (kind == SourceKind.PART) {
+      return SourcePriority.NORMAL_PART;
+    }
+    return SourcePriority.UNKNOWN;
+  }
+
+  /**
    * Given the encoded form of a source, use the source factory to reconstitute the original source.
    *
    * @param encoding the encoded form of a source
    * @return the source represented by the encoding
    */
   Source _computeSourceFromEncoding(String encoding) => _sourceFactory.fromEncoding(encoding);
 
   /**
    * Return `true` if the given array of sources contains the given source.
    *
@@ skipping 690 matching lines @@
       int count = sourcesToRemove.length;
       for (int i = 0; i < count; i++) {
         _neededForResolution.remove(sourcesToRemove[i]);
       }
     }
     //
     // Look for a non-priority source that needs to be analyzed.
     //
     List<Source> sourcesToRemove = new List<Source>();
     WorkManager_WorkIterator sources = _workManager.iterator();
-    while (sources.hasNext) {
-      Source source = sources.next();
-      AnalysisContextImpl_TaskData taskData = _getNextAnalysisTaskForSource(source, _cache.get(source), false, hintsEnabled);
-      AnalysisTask task = taskData.task;
-      if (task != null) {
-        int count = sourcesToRemove.length;
-        for (int i = 0; i < count; i++) {
-          _workManager.remove(sourcesToRemove[i]);
+    try {
+      while (sources.hasNext) {
+        Source source = sources.next();
+        AnalysisContextImpl_TaskData taskData = _getNextAnalysisTaskForSource(source, _cache.get(source), false, hintsEnabled);
+        AnalysisTask task = taskData.task;
+        if (task != null) {
+          return task;
+        } else if (taskData.isBlocked) {
+          hasBlockedTask = true;
+        } else {
+          sourcesToRemove.add(source);
         }
-        return task;
-      } else if (taskData.isBlocked) {
-        hasBlockedTask = true;
-      } else {
-        sourcesToRemove.add(source);
       }
-    }
-    int count = sourcesToRemove.length;
-    for (int i = 0; i < count; i++) {
-      _workManager.remove(sourcesToRemove[i]);
+    } 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());
@@ skipping 15 matching lines @@
    * <b>Note:</b> This method must only be invoked while we are synchronized on [cacheLock].
    *
    * @param source the source to be checked
    * @param sourceEntry the cache entry associated with the source
    * @param isPriority `true` if the source is a priority source
    * @param hintsEnabled `true` if hints are currently enabled
    * @return the next task that needs to be performed for the given source
    */
   AnalysisContextImpl_TaskData _getNextAnalysisTaskForSource(Source source, SourceEntry sourceEntry, bool isPriority, bool hintsEnabled) {
     // Refuse to generate tasks for html based files that are above 1500 KB
-//    if (sourceEntry is HtmlEntryImpl && source is FileBasedSource) {
-//      // TODO (jwren) we still need to report an error of some kind back to the client.
-//      JavaFile file = (source as FileBasedSource).file;
-//      if (file.length() > (1500 * 1024)) {
-//        return new AnalysisContextImpl_TaskData(null, false);
-//      }
-//    }
+    if (_isTooBigHtmlSourceEntry(source, sourceEntry)) {
+      // TODO (jwren) we still need to report an error of some kind back to the client.
+      return new AnalysisContextImpl_TaskData(null, false);
+    }
     if (sourceEntry == null) {
       return new AnalysisContextImpl_TaskData(null, false);
     }
     CacheState contentState = sourceEntry.getState(SourceEntry.CONTENT);
     if (contentState == CacheState.INVALID) {
       return _createGetContentTask(source, sourceEntry);
     } else if (contentState == CacheState.IN_PROCESS) {
       // We are already in the process of getting the content. There's nothing else we can do with
       // this source until that's complete.
       return new AnalysisContextImpl_TaskData(null, true);
@@ skipping 346 matching lines @@
         }
       }
     }
   }
 
   /**
    * Invalidate all of the resolution results computed by this context.
    *
    * <b>Note:</b> This method must only be invoked while we are synchronized on [cacheLock].
    *
-   * @param invalidateUris true if the cached results of converting URIs to source files should also
-   *          be invalidated.
+   * @param invalidateUris `true` if the cached results of converting URIs to source files
+   *          should also be invalidated.
    */
   void _invalidateAllLocalResolutionInformation(bool invalidateUris) {
     HashMap<Source, List<Source>> oldPartMap = new HashMap<Source, List<Source>>();
     MapIterator<Source, SourceEntry> iterator = _privatePartition.iterator();
     while (iterator.moveNext()) {
       Source source = iterator.key;
       SourceEntry sourceEntry = iterator.value;
       if (sourceEntry is HtmlEntry) {
         HtmlEntryImpl htmlCopy = sourceEntry.writableCopy;
         htmlCopy.invalidateAllResolutionInformation(invalidateUris);
         iterator.value = htmlCopy;
+        _workManager.add(source, SourcePriority.HTML);
       } else if (sourceEntry is DartEntry) {
         DartEntry dartEntry = sourceEntry;
         oldPartMap[source] = dartEntry.getValue(DartEntry.INCLUDED_PARTS);
         DartEntryImpl dartCopy = dartEntry.writableCopy;
         dartCopy.invalidateAllResolutionInformation(invalidateUris);
         iterator.value = dartCopy;
-        _workManager.add(source, SourcePriority.UNKNOWN);
+        _workManager.add(source, _computePriority(dartCopy));
       }
     }
     _removeFromPartsUsingMap(oldPartMap);
   }
 
   /**
    * In response to a change to Angular entry point [HtmlElement], invalidate any results that
    * depend on it.
    *
    * <b>Note:</b> This method must only be invoked while we are synchronized on [cacheLock].
@@ skipping 108 matching lines @@
       }
     }
     for (LibraryElement exported in library.exportedLibraries) {
       if (_isClient(exported, htmlSource, visitedLibraries)) {
         return true;
       }
     }
     return false;
   }
 
+  bool _isTooBigHtmlSourceEntry(Source source, SourceEntry sourceEntry) => false;
+
   /**
    * Log the given debugging information.
    *
    * @param message the message to be added to the log
    */
   void _logInformation(String message) {
     AnalysisEngine.instance.logger.logInformation(message);
   }
 
   /**
@@ skipping 1083 matching lines @@
           throw new AnalysisException("A Dart file became a non-Dart file: ${source.fullName}");
         }
       }
       DartEntryImpl dartCopy = dartEntry.writableCopy;
       if (thrownException == null) {
         LineInfo lineInfo = task.lineInfo;
         dartCopy.setValue(SourceEntry.LINE_INFO, lineInfo);
         dartCopy.setValue(DartEntry.TOKEN_STREAM, task.tokenStream);
         dartCopy.setValue(DartEntry.SCAN_ERRORS, task.errors);
         _cache.storedAst(source);
-        _workManager.add(source, SourcePriority.NORMAL_PART);
         ChangeNoticeImpl notice = _getNotice(source);
         notice.setErrors(dartEntry.allErrors, lineInfo);
       } else {
         _removeFromParts(source, dartEntry);
         dartCopy.recordScanError(thrownException);
         _cache.removedAst(source);
       }
       _cache.put(source, dartCopy);
       dartEntry = dartCopy;
     } else {
@@ skipping 113 matching lines @@
   bool _sourceAvailable(Source source) {
     SourceEntry sourceEntry = _cache.get(source);
     if (sourceEntry == null) {
       sourceEntry = _createSourceEntry(source, true);
     } else {
       _sourceChanged(source);
       sourceEntry = _cache.get(source);
     }
     if (sourceEntry is HtmlEntry) {
       _workManager.add(source, SourcePriority.HTML);
-    } else {
-      _workManager.add(source, SourcePriority.UNKNOWN);
+    } else if (sourceEntry is DartEntry) {
+      _workManager.add(source, _computePriority(sourceEntry as DartEntry));
     }
     return sourceEntry is DartEntry;
   }
 
   /**
    * <b>Note:</b> This method must only be invoked while we are synchronized on [cacheLock].
    *
    * @param source the source that has been changed
    */
   void _sourceChanged(Source source) {
@@ skipping 507 matching lines @@
   }
 
   /**
    * Create an object to represent the information about the library defined by the compilation
    * unit with the given source.
    *
    * @param librarySource the source of the library's defining compilation unit
    * @return the library object that was created
    */
   ResolvableLibrary _createLibraryOrNull(Source librarySource) {
-    if (!AnalysisContextImpl_this.exists(librarySource)) {
-      return null;
-    }
     ResolvableLibrary library = new ResolvableLibrary(librarySource);
     SourceEntry sourceEntry = AnalysisContextImpl_this._cache.get(librarySource);
     if (sourceEntry is DartEntry) {
       LibraryElementImpl libraryElement = sourceEntry.getValue(DartEntry.ELEMENT) as LibraryElementImpl;
       if (libraryElement != null) {
         library.libraryElement = libraryElement;
       }
     }
     _libraryMap[librarySource] = library;
     return library;
@@ skipping 7041 matching lines @@
    * @param message an explanation of why the error occurred or what it means
    */
   void logError(String message);
 
   /**
    * Log the given exception as one representing an error.
    *
    * @param message an explanation of why the error occurred or what it means
    * @param exception the exception being logged
    */
-  void logError2(String message, exception);
+  void logError2(String message, Exception exception);
 
   /**
    * Log the given informational message.
    *
    * @param message an explanation of why the error occurred or what it means
    * @param exception the exception being logged
    */
   void logInformation(String message);
 
   /**
    * Log the given exception as one representing an informational message.
    *
    * @param message an explanation of why the error occurred or what it means
    * @param exception the exception being logged
    */
   void logInformation2(String message, Exception exception);
 }
 
 /**
  * Implementation of [Logger] that does nothing.
  */
 class Logger_NullLogger implements Logger {
   @override
   void logError(String message) {
   }
 
   @override
-  void logError2(String message, exception) {
+  void logError2(String message, Exception exception) {
   }
 
   @override
   void logInformation(String message) {
   }
 
   @override
-  void logInformation2(String message, exception) {
+  void logInformation2(String message, Exception exception) {
   }
 }
 
 /**
  * [NgComponentElementProcessor] applies [AngularComponentElement] by parsing mapped
  * attributes as expressions.
  */
 class NgComponentElementProcessor extends NgDirectiveProcessor {
   final AngularComponentElement _element;
 
@@ skipping 2723 matching lines @@
    * attempt to discover the underlying cause of a long-standing bug.
    *
    * @param newState the new state of the content
    * @return the new state of the content
    */
   CacheState _checkContentState(CacheState newState) {
     if (_contentState == CacheState.ERROR) {
       InstrumentationBuilder builder = Instrumentation.builder2("SourceEntryImpl-checkContentState");
       builder.data3("message", "contentState changing from ${_contentState} to ${newState}");
       //builder.data("source", source.getFullName());
-      builder.record(new AnalysisException());
+      builder.record(new CaughtException(new AnalysisException(), null));
       builder.log();
     }
     return newState;
   }
 }
 
 /**
  * The enumerated type `Priority` defines the priority levels used to return sources in an
  * optimal order. A smaller ordinal value equates to a higher priority.
  */
@@ skipping 281 matching lines @@
   void _advance() {
     _index++;
     if (_index >= WorkManager_this._workQueues[_queueIndex].length) {
       _index = 0;
       _queueIndex++;
       while (_queueIndex < WorkManager_this._workQueues.length && WorkManager_this._workQueues[_queueIndex].isEmpty) {
         _queueIndex++;
       }
     }
   }
-}
+}