Prioritize scheduling analysis for priority sources.

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/engine.dart'
     show CacheState, InternalAnalysisContext;
 import 'package:analyzer/src/generated/java_engine.dart' show CaughtException;
@@ skipping 105 matching lines @@
     entry1.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
     entry2.setValue(SOURCE_KIND, SourceKind.PART, []);
     entry3.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
     entry1.setValue(LIBRARY_ERRORS_READY, false, []);
     entry3.setValue(LIBRARY_ERRORS_READY, false, []);
     // change source2, schedule source1 and source3
     manager.applyChange([], [source2], []);
     expect_librarySourceQueue([source1, source3]);
   }
 
+  void test_applyPriorityTargets_library() {
+    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() {
+    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_getNextResult_hasLibraries_firstIsError() {
     entry1.setErrorState(caughtException, [LIBRARY_ERRORS_READY]);
     manager.librarySourceQueue.addAll([source1, source2]);
     TargetedResult request = manager.getNextResult();
     expect(request.target, source2);
     expect(request.result, LIBRARY_ERRORS_READY);
     // source1 is out, source2 is waiting
     expect_librarySourceQueue([source2]);
   }
 
@@ skipping 10 matching lines @@
   void test_getNextResult_hasLibraries_firstIsValid() {
     entry1.setValue(LIBRARY_ERRORS_READY, true, []);
     manager.librarySourceQueue.addAll([source1, source2]);
     TargetedResult request = manager.getNextResult();
     expect(request.target, source2);
     expect(request.result, LIBRARY_ERRORS_READY);
     // source1 is out, source2 is waiting
     expect_librarySourceQueue([source2]);
   }
 
-  void test_getNextResult_nothingToDo() {
-    TargetedResult request = manager.getNextResult();
-    expect(request, isNull);
-  }
-
   void test_getNextResult_hasPriority_firstIsError() {
     manager.addPriorityResult(source1, SOURCE_KIND);
     manager.addPriorityResult(source2, SOURCE_KIND);
     expect(manager.priorityResultQueue, unorderedEquals([
       new TargetedResult(source1, SOURCE_KIND),
       new TargetedResult(source2, SOURCE_KIND)
     ]));
     // configure state and get next result
     entry1.setErrorState(caughtException, [SOURCE_KIND]);
     TargetedResult request = manager.getNextResult();
@@ skipping 46 matching lines @@
     entry1.setValue(SOURCE_KIND, SourceKind.LIBRARY, []);
     manager.unknownSourceQueue.addAll([source1, source2]);
     TargetedResult request = manager.getNextResult();
     expect(request.target, source2);
     expect(request.result, SOURCE_KIND);
     // source1 is out, source2 is waiting
     expect_librarySourceQueue([]);
     expect_unknownSourceQueue([source2]);
   }
 
+  void test_getNextResult_nothingToDo() {
+    TargetedResult request = manager.getNextResult();
+    expect(request, isNull);
+  }
+
   void test_getNextResultPriority_hasLibrary() {
     manager.librarySourceQueue.addAll([source1]);
     expect(manager.getNextResultPriority(), WorkOrderPriority.NORMAL);
   }
 
   void test_getNextResultPriority_hasPriority() {
     manager.addPriorityResult(source1, SOURCE_KIND);
     expect(manager.getNextResultPriority(), WorkOrderPriority.PRIORITY);
   }
 
@@ skipping 49 matching lines @@
     CacheEntry entry = analysisCache.get(target);
     if (entry == null) {
       entry = new CacheEntry(target);
       analysisCache.put(entry);
     }
     return entry;
   }
 
   noSuchMethod(Invocation invocation) => super.noSuchMethod(invocation);
 }