Detect and recover from infinite task loops

pkg/analyzer/lib/src/task/driver.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 analyzer.src.task.driver;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:analyzer/src/context/cache.dart';
@@ skipping 395 matching lines @@
   bool moveNext() {
     if (pendingItems.isEmpty) {
       currentItem = null;
       return false;
     }
     currentItem = pendingItems.removeLast();
     WorkItem childItem = currentItem.gatherInputs(taskManager);
     while (childItem != null) {
       pendingItems.add(currentItem);
       currentItem = childItem;
+      if (_hasInfiniteTaskLoop()) {
+        currentItem = pendingItems.removeLast();
+        try {
+          throw new InfiniteTaskLoopException(childItem);
+        } on InfiniteTaskLoopException catch (exception, stackTrace) {
+          currentItem.exception = new CaughtException(exception, stackTrace);
+        }
+        return true;
+      }
       childItem = currentItem.gatherInputs(taskManager);
     }
     return true;
   }
+
+  /**
+   * Check to see whether the current work item is attempting to perform the
+   * same task on the same target as any of the pending work items. If it is,
+   * then throw an [InfiniteTaskLoopException].
+   */
+  bool _hasInfiniteTaskLoop() {
+    TaskDescriptor descriptor = currentItem.descriptor;
+    AnalysisTarget target = currentItem.target;
+    for (WorkItem item in pendingItems) {
+      if (item.descriptor == descriptor && item.target == target) {
+        return true;
+      }
+    }
+    return false;
+  }
 }
+
+/**
+ * An exception indicating that an attempt was made to perform a task on a
+ * target while gathering the inputs to perform the same task for the same
+ * target.
+ */
+class InfiniteTaskLoopException extends AnalysisException {
+  /**
+   * Initialize a newly created exception to represent an attempt to perform
+   * the task for the target represented by the given [item].
+   */
+  InfiniteTaskLoopException(WorkItem item) : super('Infinite loop while performing task ${item.descriptor.name} for ${item.target}');
+}