Schedule unknown priority source analysis.

pkg/analyzer/test/src/task/dart_work_manager_test.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 test.src.task.dart_work_manager_test;
 
 import 'package:analyzer/src/context/cache.dart';
 import 'package:analyzer/src/generated/ast.dart';
 import 'package:analyzer/src/generated/engine.dart'
     show
@@ skipping 201 matching lines @@
     manager.libraryPartsMap[library2] = [part1, part2];
     // remove part1
     manager.applyChange([], [], [part1]);
     expect(manager.partLibrariesMap[part1], isNull);
     expect(manager.partLibrariesMap[part2], unorderedEquals([library2]));
     expect(manager.partLibrariesMap[part3], unorderedEquals([library1]));
     expect(manager.libraryPartsMap[library1], [part1, part3]);
     expect(manager.libraryPartsMap[library2], [part1, part2]);
   }
 
-  void test_applyPriorityTargets_library() {
+  void test_applyPriorityTargets_isLibrary_computeErrors() {
+    when(context.shouldErrorsBeAnalyzed(source2, null)).thenReturn(true);
+    when(context.shouldErrorsBeAnalyzed(source3, null)).thenReturn(true);
     entry1.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
     entry2.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
     entry3.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
     manager.priorityResultQueue
         .add(new TargetedResult(source1, LIBRARY_ERRORS_READY));
     manager.priorityResultQueue
         .add(new TargetedResult(source2, LIBRARY_ERRORS_READY));
     // -source1 +source3
     manager.applyPriorityTargets([source2, source3]);
     expect(manager.priorityResultQueue, unorderedEquals([
       new TargetedResult(source2, LIBRARY_ERRORS_READY),
       new TargetedResult(source3, LIBRARY_ERRORS_READY)
     ]));
     // get next request
     TargetedResult request = manager.getNextResult();
     expect(request.target, source2);
     expect(request.result, LIBRARY_ERRORS_READY);
   }
 
-  void test_applyPriorityTargets_part() {
+  void test_applyPriorityTargets_isLibrary_computeUnit() {
+    when(context.shouldErrorsBeAnalyzed(source2, null)).thenReturn(false);
+    when(context.shouldErrorsBeAnalyzed(source3, null)).thenReturn(false);
+    entry1.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
+    entry2.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
+    entry3.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
+    manager.priorityResultQueue
+        .add(new TargetedResult(source1, LIBRARY_ERRORS_READY));
+    manager.priorityResultQueue
+        .add(new TargetedResult(source2, LIBRARY_ERRORS_READY));
+    // -source1 +source3
+    manager.applyPriorityTargets([source2, source3]);
+    expect(manager.priorityResultQueue, unorderedEquals([
+      new TargetedResult(
+          new LibrarySpecificUnit(source2, source2), RESOLVED_UNIT),
+      new TargetedResult(
+          new LibrarySpecificUnit(source3, source3), RESOLVED_UNIT),
+    ]));
+  }
+
+  void test_applyPriorityTargets_isPart() {
     entry1.setValue(SOURCE_KIND, SourceKind.PART, []);
     entry2.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
     entry3.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
     // +source2 +source3
     when(context.getLibrariesContaining(source1))
         .thenReturn([source2, source3]);
     manager.applyPriorityTargets([source1]);
     expect(manager.priorityResultQueue, unorderedEquals([
       new TargetedResult(source2, LIBRARY_ERRORS_READY),
       new TargetedResult(source3, LIBRARY_ERRORS_READY)
     ]));
     // get next request
     TargetedResult request = manager.getNextResult();
     expect(request.target, source2);
     expect(request.result, LIBRARY_ERRORS_READY);
   }
 
+  void test_applyPriorityTargets_isUnknown() {
+    manager.applyPriorityTargets([source2, source3]);
+    expect(manager.priorityResultQueue, unorderedEquals([
+      new TargetedResult(source2, SOURCE_KIND),
+      new TargetedResult(source3, SOURCE_KIND)
+    ]));
+    // get next request
+    TargetedResult request = manager.getNextResult();
+    expect(request.target, source2);
+    expect(request.result, SOURCE_KIND);
+  }
+
   void test_getErrors() {
     AnalysisError error1 =
         new AnalysisError(source1, 1, 0, ScannerErrorCode.MISSING_DIGIT);
     AnalysisError error2 =
         new AnalysisError(source1, 2, 0, ScannerErrorCode.MISSING_DIGIT);
     when(context.getLibrariesContaining(source1)).thenReturn([source2]);
     LineInfo lineInfo = new LineInfo([0]);
     entry1.setValue(LINE_INFO, lineInfo, []);
     entry1.setValue(SCAN_ERRORS, <AnalysisError>[error1], []);
     context.getCacheEntry(new LibrarySpecificUnit(source2, source1)).setValue(
@@ skipping 293 matching lines @@
     manager.resultsComputed(
         new LibrarySpecificUnit(source1, source2), {RESOLVED_UNIT: unit});
     ChangeNoticeImpl notice = context.getNotice(source2);
     expect(notice.parsedDartUnit, isNull);
     expect(notice.resolvedDartUnit, unit);
     expect(notice.lineInfo, lineInfo);
   }
 
   void test_resultsComputed_sourceKind_isLibrary() {
     manager.unknownSourceQueue.addAll([source1, source2, source3]);
+    when(context.prioritySources).thenReturn(<Source>[]);
     when(context.shouldErrorsBeAnalyzed(source2, null)).thenReturn(true);
     manager.resultsComputed(source2, {SOURCE_KIND: SourceKind.LIBRARY});
     expect_librarySourceQueue([source2]);
     expect_unknownSourceQueue([source1, source3]);
   }
 
+  void test_resultsComputed_sourceKind_isLibrary_isPriority_computeErrors() {
+    manager.unknownSourceQueue.addAll([source1, source2, source3]);
+    when(context.prioritySources).thenReturn(<Source>[source2]);
+    when(context.shouldErrorsBeAnalyzed(source2, null)).thenReturn(true);
+    manager.resultsComputed(source2, {SOURCE_KIND: SourceKind.LIBRARY});
+    expect_unknownSourceQueue([source1, source3]);
+    expect(manager.priorityResultQueue,
+        unorderedEquals([new TargetedResult(source2, LIBRARY_ERRORS_READY)]));
+  }
+
+  void test_resultsComputed_sourceKind_isLibrary_isPriority_computeUnit() {
+    manager.unknownSourceQueue.addAll([source1, source2, source3]);
+    when(context.prioritySources).thenReturn(<Source>[source2]);
+    when(context.shouldErrorsBeAnalyzed(source2, null)).thenReturn(false);
+    manager.resultsComputed(source2, {SOURCE_KIND: SourceKind.LIBRARY});
+    expect_unknownSourceQueue([source1, source3]);
+    expect(manager.priorityResultQueue, unorderedEquals([
+      new TargetedResult(
+          new LibrarySpecificUnit(source2, source2), RESOLVED_UNIT)
+    ]));
+  }
+
   void test_resultsComputed_sourceKind_isPart() {
     manager.unknownSourceQueue.addAll([source1, source2, source3]);
     manager.resultsComputed(source2, {SOURCE_KIND: SourceKind.PART});
     expect_librarySourceQueue([]);
     expect_unknownSourceQueue([source1, source3]);
   }
 
   CacheEntry _getOrCreateEntry(Source source) {
     CacheEntry entry = cache.get(source);
     if (entry == null) {
@@ skipping 30 matching lines @@
   }
 
   @override
   ChangeNoticeImpl getNotice(Source source) {
     return _pendingNotices.putIfAbsent(
         source, () => new ChangeNoticeImpl(source));
   }
 
   noSuchMethod(Invocation invocation) => super.noSuchMethod(invocation);
 }