Prioritize analysis operations for contexts with priority files.

pkg/analysis_server/lib/src/analysis_server.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.
 
 library analysis.server;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:analysis_server/src/analysis_logger.dart';
@@ skipping 629 matching lines @@
     if (!performOperationPending) {
       _schedulePerformOperation();
     }
   }
 
   /**
    * Schedules analysis of the given context.
    */
   void schedulePerformAnalysisOperation(AnalysisContext context) {
     _onAnalysisStartedController.add(context);
-    bool isPriority = _isPriorityContext(context);
-    scheduleOperation(new PerformAnalysisOperation(context, isPriority, false));
+    scheduleOperation(new PerformAnalysisOperation(context, false));
   }
 
   /**
    * This method is called when analysis of the given [AnalysisContext] is
    * done.
    */
   void sendContextAnalysisDoneNotifications(AnalysisContext context,
       AnalysisDoneReason reason) {
     Completer<AnalysisDoneReason> completer =
         contextAnalysisDoneCompleters.remove(context);
@@ skipping 162 matching lines @@
       throw new RequestFailure(
           new Response.unanalyzedPriorityFiles(requestId, buffer.toString()));
     }
     folderMap.forEach((Folder folder, AnalysisContext context) {
       List<Source> sourceList = sourceMap[context];
       if (sourceList == null) {
         sourceList = Source.EMPTY_ARRAY;
       }
       context.analysisPriorityOrder = sourceList;
     });
+    operationQueue.reschedule();
     Source firstSource = files.length > 0 ? getSource(files[0]) : null;
     _onPriorityChangeController.add(new PriorityChangeEvent(firstSource));
   }
 
   /**
    * Returns `true` if errors should be reported for [file] with the given
    * absolute path.
    */
   bool shouldSendErrorsNotificationFor(String file) {
     return !_noErrorNotification &&
@@ skipping 78 matching lines @@
     //
     // Update the defaults used to create new contexts.
     //
     AnalysisOptionsImpl options = contextDirectoryManager.defaultOptions;
     optionUpdaters.forEach((OptionUpdater optionUpdater) {
       optionUpdater(options);
     });
   }
 
   /**
-   * Returns `true` if the given [AnalysisContext] is a priority one.
-   */
-  bool _isPriorityContext(AnalysisContext context) {
-    // TODO(scheglov) implement support for priority sources/contexts
-    return false;
-  }
-
-  /**
    * Schedules [performOperation] exection.
    */
   void _schedulePerformOperation() {
     assert(!performOperationPending);
     new Future(performOperation);
     performOperationPending = true;
   }
 }
 
 
@@ skipping 134 matching lines @@
    * [packageUriResolver].
    */
   SourceFactory _createSourceFactory(UriResolver packageUriResolver) {
     List<UriResolver> resolvers = <UriResolver>[
         new DartUriResolver(analysisServer.defaultSdk),
         new ResourceUriResolver(resourceProvider),
         packageUriResolver];
     return new SourceFactory(resolvers);
   }
 }