Roll Observatory packages and add a roll script

packages/analyzer/lib/src/task/inputs.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.inputs;
 
 import 'dart:collection';
 
 import 'package:analyzer/task/model.dart';
 
 /**
  * A function that converts an object of the type [B] into a [TaskInput].
  * This is used, for example, by a [ListToListTaskInput] to create task inputs
  * for each value in a list of values.
  */
 typedef TaskInput<E> GenerateTaskInputs<B, E>(B object);
 
 /**
  * A function that maps one [value] to another value.
  */
 typedef R Mapper<P, R>(P value);
 
 /**
  * An input to an [AnalysisTask] that is computed by accessing a single result
  * defined on a single target.
  */
+class ConstantTaskInput<V> extends TaskInputImpl<V> {
+  final V value;
+
+  ConstantTaskInput(this.value);
+
+  @override
+  TaskInputBuilder<V> createBuilder() {
+    return new ConstantTaskInputBuilder<V>(this);
+  }
+}
+
+/**
+ * A [TaskInputBuilder] used to build an input based on a [ConstantTaskInput].
+ */
+class ConstantTaskInputBuilder<V> implements TaskInputBuilder<V> {
+  final ConstantTaskInput input;
+
+  ConstantTaskInputBuilder(this.input);
+
+  @override
+  ResultDescriptor get currentResult => null;
+
+  @override
+  AnalysisTarget get currentTarget => null;
+
+  @override
+  void set currentValue(Object value) {
+    throw new StateError('Only supported after moveNext() returns true');
+  }
+
+  @override
+  bool get flushOnAccess => false;
+
+  @override
+  V get inputValue => input.value;
+
+  @override
+  void currentValueNotAvailable() {
+    throw new StateError('Only supported after moveNext() returns true');
+  }
+
+  @override
+  bool moveNext() => false;
+}
+
+/**
+ * An input to an [AnalysisTask] that is computed by accessing a single result
+ * defined on a single target.
+ */
 class ListTaskInputImpl<E> extends SimpleTaskInput<List<E>>
-    with ListTaskInputMixin<E> implements ListTaskInput<E> {
+    with ListTaskInputMixin<E>
+    implements ListTaskInput<E> {
   /**
    * Initialize a newly created task input that computes the input by accessing
    * the given [result] associated with the given [target].
    */
   ListTaskInputImpl(AnalysisTarget target, ResultDescriptor<List<E>> result)
-      : super(target, result);
+      : super._unflushable(target, result);
 }
 
 /**
  * A mixin-ready implementation of [ListTaskInput].
  */
 abstract class ListTaskInputMixin<E> implements ListTaskInput<E> {
   ListTaskInput /*<V>*/ toList(UnaryFunction<E, dynamic /*<V>*/ > mapper) {
     return new ListToListTaskInput<E, dynamic /*V*/ >(this, mapper);
   }
 
@@ skipping 116 matching lines @@
     _resultValue = new HashMap<B, E>();
   }
 }
 
 /**
  * A mixin-ready implementation of [MapTaskInput].
  */
 abstract class MapTaskInputMixin<K, V> implements MapTaskInput<K, V> {
   TaskInput<List /*<E>*/ > toFlattenList(
       BinaryFunction<K, dynamic /*element of V*/, dynamic /*<E>*/ > mapper) {
-    return new MapToFlattenListTaskInput<K, dynamic /*element of V*/, dynamic /*E*/ >(
+    return new MapToFlattenListTaskInput<K, dynamic /*element of V*/,
+        dynamic /*E*/ >(
         this as MapTaskInput<K, List /*<element of V>*/ >, mapper);
   }
 }
 
 /**
  * A [TaskInput] that is computed by the following steps.
  *
  * First the [base] task input is used to compute a [Map]-valued result.
  * The values of the [Map] must be [List]s.
  *
@@ skipping 52 matching lines @@
   @override
   void set currentValue(Object value) {
     if (currentBuilder == null) {
       throw new StateError(
           'Cannot set the result value when there is no current result');
     }
     currentBuilder.currentValue = value;
   }
 
   @override
+  bool get flushOnAccess => currentBuilder.flushOnAccess;
+
+  @override
   void currentValueNotAvailable() {
     if (currentBuilder == null) {
       throw new StateError(
           'Cannot set the result value when there is no current result');
     }
     currentBuilder.currentValueNotAvailable();
   }
 
   @override
   bool moveNext() {
@@ skipping 40 matching lines @@
     }
     // No more Map values/keys to transform.
     return false;
   }
 }
 
 /**
  * An input to an [AnalysisTask] that is computed by mapping the value of
  * another task input to a list of values.
  */
-class ObjectToListTaskInput<E> extends TaskInputImpl<List<E>> with ListTaskInputMixin<E>
+class ObjectToListTaskInput<E> extends TaskInputImpl<List<E>>
+    with ListTaskInputMixin<E>
     implements ListTaskInput<E> {
   /**
    * The input used to compute the value to be mapped.
    */
   final TaskInput baseInput;
 
   /**
    * The function used to map the value of the base input to the list of values.
    */
   final Mapper<Object, List<E>> mapper;
@@ skipping 69 matching lines @@
   @override
   void set currentValue(Object value) {
     if (builder == null) {
       throw new StateError(
           'Cannot set the result value when there is no current result');
     }
     builder.currentValue = value;
   }
 
   @override
+  bool get flushOnAccess => builder.flushOnAccess;
+
+  @override
   List<E> get inputValue {
     if (builder != null) {
       throw new StateError('Result value has not been created');
     }
     return _inputValue;
   }
 
   @override
   void currentValueNotAvailable() {
     if (builder == null) {
@@ skipping 31 matching lines @@
    * The target on which the result is defined.
    */
   final AnalysisTarget target;
 
   /**
    * The result to be accessed.
    */
   final ResultDescriptor<V> result;
 
   /**
+   * Return `true` if the value accessed by this input builder should be flushed
+   * from the cache at the time it is retrieved.
+   */
+  final bool flushOnAccess;
+
+  /**
    * Initialize a newly created task input that computes the input by accessing
    * the given [result] associated with the given [target].
    */
-  SimpleTaskInput(this.target, this.result);
+  SimpleTaskInput(this.target, this.result, {this.flushOnAccess: false});
+
+  /**
+   * Initialize a newly created task input that computes the input by accessing
+   * the given [result] associated with the given [target].
+   */
+  SimpleTaskInput._unflushable(this.target, this.result)
+      : flushOnAccess = false;
 
   @override
   TaskInputBuilder<V> createBuilder() => new SimpleTaskInputBuilder<V>(this);
 }
 
 /**
  * A [TaskInputBuilder] used to build an input based on a [SimpleTaskInput].
  */
 class SimpleTaskInputBuilder<V> implements TaskInputBuilder<V> {
   /**
@@ skipping 51 matching lines @@
   void set currentValue(Object value) {
     if (_state != _AT) {
       throw new StateError(
           'Cannot set the result value when there is no current result');
     }
     _resultValue = value as V;
     _resultSet = true;
   }
 
   @override
+  bool get flushOnAccess => input.flushOnAccess;
+
+  @override
   V get inputValue {
     if (_state != _AFTER) {
       throw new StateError('Result value has not been created');
     }
     return _resultValue;
   }
 
   @override
   void currentValueNotAvailable() {
     if (_state != _AT) {
@@ skipping 88 matching lines @@
   @override
   void set currentValue(Object value) {
     if (currentBuilder == null) {
       throw new StateError(
           'Cannot set the result value when there is no current result');
     }
     currentBuilder.currentValue = value;
   }
 
   @override
+  bool get flushOnAccess => currentBuilder.flushOnAccess;
+
+  @override
   Map<String, Object> get inputValue {
     if (nameIndex < inputNames.length) {
       throw new StateError('Result value has not been created');
     }
     return inputs;
   }
 
   /**
    * Assuming that there is a current input, return its name.
    */
@@ skipping 27 matching lines @@
       if (currentBuilder.inputValue != null) {
         inputs[_currentName] = currentBuilder.inputValue;
       }
       nameIndex++;
     }
     if (nameIndex >= inputNames.length) {
       // There is no next value, so we're done.
       return false;
     }
     currentBuilder = inputDescriptors[_currentName].createBuilder();
-    // NOTE: This assumes that every builder will require at least one result
-    // value to be created. If that assumption is every broken, this method will
-    // need to be changed to advance until we find a builder that does require
-    // a result to be computed (or run out of builders).
-    return currentBuilder.moveNext();
+    while (!currentBuilder.moveNext()) {
+      if (currentBuilder.inputValue != null) {
+        inputs[_currentName] = currentBuilder.inputValue;
+      }
+      nameIndex++;
+      if (nameIndex >= inputNames.length) {
+        // There is no next value, so we're done.
+        return false;
+      }
+      currentBuilder = inputDescriptors[_currentName].createBuilder();
+    }
+    return true;
   }
 }
 
 /**
  * An input to an [AnalysisTask] that is computed by the following steps. First
  * another (base) task input is used to compute a [List]-valued result. An input
  * generator function is then used to map each element of that list to a task
  * input. Finally, each of the task inputs are used to access analysis results,
  * and a collection of the analysis results is used as the input to the task.
  */
@@ skipping 74 matching lines @@
   @override
   void set currentValue(Object value) {
     if (currentBuilder == null) {
       throw new StateError(
           'Cannot set the result value when there is no current result');
     }
     currentBuilder.currentValue = value;
   }
 
   @override
+  bool get flushOnAccess => currentBuilder.flushOnAccess;
+
+  @override
   C get inputValue {
     if (currentBuilder != null || _resultValue == null) {
       throw new StateError('Result value has not been created');
     }
     return _resultValue;
   }
 
   /**
    * The list of values being built.
    */
@@ skipping 47 matching lines @@
       return false;
     }
     _baseListElement = _baseList[_baseListIndex];
     currentBuilder = input.generateTaskInputs(_baseListElement).createBuilder();
     return currentBuilder.moveNext();
   }
 
   void _addResultElement(B baseElement, E resultElement);
   void _initResultValue();
 }