| Index: pkg/analysis_server/lib/src/operation/operation_queue.dart
|
| diff --git a/pkg/analysis_server/lib/src/operation/operation_queue.dart b/pkg/analysis_server/lib/src/operation/operation_queue.dart
|
| index b26c677f60e2d6d7479d42c899f2cdfc2fd0f491..6ef1b84fd35fb243d761479ac6626f36faebc8e1 100644
|
| --- a/pkg/analysis_server/lib/src/operation/operation_queue.dart
|
| +++ b/pkg/analysis_server/lib/src/operation/operation_queue.dart
|
| @@ -8,21 +8,15 @@ import 'dart:collection';
|
|
|
| import 'package:analysis_server/src/analysis_server.dart';
|
| import 'package:analysis_server/src/operation/operation.dart';
|
| -import 'package:analysis_server/src/operation/operation_analysis.dart';
|
|
|
|
|
| /**
|
| * A queue of operations in an [AnalysisServer].
|
| */
|
| class ServerOperationQueue {
|
| - final List<ServerOperationPriority> _analysisPriorities = [
|
| - ServerOperationPriority.ANALYSIS_CONTINUE,
|
| - ServerOperationPriority.ANALYSIS];
|
| -
|
| - final AnalysisServer _server;
|
| final List<Queue<ServerOperation>> _queues = <Queue<ServerOperation>>[];
|
|
|
| - ServerOperationQueue(this._server) {
|
| + ServerOperationQueue() {
|
| for (int i = 0; i < ServerOperationPriority.COUNT; i++) {
|
| var queue = new DoubleLinkedQueue<ServerOperation>();
|
| _queues.add(queue);
|
| @@ -60,23 +54,11 @@ class ServerOperationQueue {
|
| * Returns the next operation to perform or `null` if empty.
|
| */
|
| ServerOperation take() {
|
| - // try to find a priority analysis operarion
|
| - for (ServerOperationPriority priority in _analysisPriorities) {
|
| - Queue<ServerOperation> queue = _queues[priority.ordinal];
|
| - for (PerformAnalysisOperation operation in queue) {
|
| - if (_server.isPriorityContext(operation.context)) {
|
| - queue.remove(operation);
|
| - return operation;
|
| - }
|
| - }
|
| - }
|
| - // non-priority operations
|
| for (Queue<ServerOperation> queue in _queues) {
|
| if (!queue.isEmpty) {
|
| return queue.removeFirst();
|
| }
|
| }
|
| - // empty
|
| return null;
|
| }
|
| }
|
|
|