| OLD | NEW |
| 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 library analyzer.task.model; | 5 library analyzer.task.model; |
| 6 | 6 |
| 7 import 'dart:collection'; | 7 import 'dart:collection'; |
| 8 import 'dart:developer'; |
| 8 | 9 |
| 9 import 'package:analyzer/src/generated/engine.dart' hide AnalysisTask; | 10 import 'package:analyzer/src/generated/engine.dart' hide AnalysisTask; |
| 10 import 'package:analyzer/src/generated/error.dart' show AnalysisError; | 11 import 'package:analyzer/src/generated/error.dart' show AnalysisError; |
| 11 import 'package:analyzer/src/generated/java_engine.dart'; | 12 import 'package:analyzer/src/generated/java_engine.dart'; |
| 12 import 'package:analyzer/src/generated/source.dart'; | 13 import 'package:analyzer/src/generated/source.dart'; |
| 13 import 'package:analyzer/src/generated/utilities_general.dart'; | 14 import 'package:analyzer/src/generated/utilities_general.dart'; |
| 14 import 'package:analyzer/src/task/driver.dart'; | 15 import 'package:analyzer/src/task/driver.dart'; |
| 15 import 'package:analyzer/src/task/model.dart'; | 16 import 'package:analyzer/src/task/model.dart'; |
| 16 | 17 |
| 17 /** | 18 /** |
| (...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 77 * Clients are expected to extend this class when creating new tasks. | 78 * Clients are expected to extend this class when creating new tasks. |
| 78 */ | 79 */ |
| 79 abstract class AnalysisTask { | 80 abstract class AnalysisTask { |
| 80 /** | 81 /** |
| 81 * A table mapping the types of analysis tasks to the number of times each | 82 * A table mapping the types of analysis tasks to the number of times each |
| 82 * kind of task has been performed. | 83 * kind of task has been performed. |
| 83 */ | 84 */ |
| 84 static final Map<Type, int> countMap = new HashMap<Type, int>(); | 85 static final Map<Type, int> countMap = new HashMap<Type, int>(); |
| 85 | 86 |
| 86 /** | 87 /** |
| 88 * A table mapping the types of analysis tasks to user tags used to collect |
| 89 * timing data for the Observatory. |
| 90 */ |
| 91 static Map<Type, UserTag> tagMap = new HashMap<Type, UserTag>(); |
| 92 |
| 93 /** |
| 87 * A table mapping the types of analysis tasks to stopwatches used to compute | 94 * A table mapping the types of analysis tasks to stopwatches used to compute |
| 88 * how much time was spent executing each kind of task. | 95 * how much time was spent executing each kind of task. |
| 89 */ | 96 */ |
| 90 static final Map<Type, Stopwatch> stopwatchMap = | 97 static final Map<Type, Stopwatch> stopwatchMap = |
| 91 new HashMap<Type, Stopwatch>(); | 98 new HashMap<Type, Stopwatch>(); |
| 92 | 99 |
| 93 /** | 100 /** |
| 94 * The context in which the task is to be performed. | 101 * The context in which the task is to be performed. |
| 95 */ | 102 */ |
| 96 final AnalysisContext context; | 103 final AnalysisContext context; |
| (...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 221 if (contextName == null) { | 228 if (contextName == null) { |
| 222 contextName = 'unnamed'; | 229 contextName = 'unnamed'; |
| 223 } | 230 } |
| 224 AnalysisEngine.instance.instrumentationService | 231 AnalysisEngine.instance.instrumentationService |
| 225 .logAnalysisTask(contextName, this); | 232 .logAnalysisTask(contextName, this); |
| 226 // | 233 // |
| 227 // Gather statistics on the performance of the task. | 234 // Gather statistics on the performance of the task. |
| 228 // | 235 // |
| 229 int count = countMap[runtimeType]; | 236 int count = countMap[runtimeType]; |
| 230 countMap[runtimeType] = count == null ? 1 : count + 1; | 237 countMap[runtimeType] = count == null ? 1 : count + 1; |
| 238 // UserTag tag = tagMap.putIfAbsent( |
| 239 // runtimeType, () => new UserTag(runtimeType.toString())); |
| 231 Stopwatch stopwatch = stopwatchMap[runtimeType]; | 240 Stopwatch stopwatch = stopwatchMap[runtimeType]; |
| 232 if (stopwatch == null) { | 241 if (stopwatch == null) { |
| 233 stopwatch = new Stopwatch(); | 242 stopwatch = new Stopwatch(); |
| 234 stopwatchMap[runtimeType] = stopwatch; | 243 stopwatchMap[runtimeType] = stopwatch; |
| 235 } | 244 } |
| 245 // UserTag previousTag = tag.makeCurrent(); |
| 246 // try { |
| 236 stopwatch.start(); | 247 stopwatch.start(); |
| 237 // | 248 // |
| 238 // Actually perform the task. | 249 // Actually perform the task. |
| 239 // | 250 // |
| 240 try { | 251 try { |
| 241 if (dependencyCycle != null && !handlesDependencyCycles) { | 252 if (dependencyCycle != null && !handlesDependencyCycles) { |
| 242 throw new InfiniteTaskLoopException(this, dependencyCycle); | 253 throw new InfiniteTaskLoopException(this, dependencyCycle); |
| 243 } | 254 } |
| 244 internalPerform(); | 255 internalPerform(); |
| 245 } finally { | 256 } finally { |
| 246 stopwatch.stop(); | 257 stopwatch.stop(); |
| 247 } | 258 } |
| 259 // } finally { |
| 260 // previousTag.makeCurrent(); |
| 261 // } |
| 248 } on AnalysisException { | 262 } on AnalysisException { |
| 249 rethrow; | 263 rethrow; |
| 250 } catch (exception, stackTrace) { | 264 } catch (exception, stackTrace) { |
| 251 throw new AnalysisException( | 265 throw new AnalysisException( |
| 252 'Unexpected exception while performing $description', | 266 'Unexpected exception while performing $description', |
| 253 new CaughtException(exception, stackTrace)); | 267 new CaughtException(exception, stackTrace)); |
| 254 } | 268 } |
| 255 } | 269 } |
| 256 } | 270 } |
| 257 | 271 |
| 258 /** | 272 /** |
| 259 * A description of a [List]-based analysis result that can be computed by an | 273 * A description of a [List]-based analysis result that can be computed by an |
| 260 * [AnalysisTask]. | 274 * [AnalysisTask]. |
| 261 * | 275 * |
| 262 * Clients are not expected to subtype this class. | 276 * Clients are not expected to subtype this class. |
| 263 */ | 277 */ |
| 264 abstract class ListResultDescriptor<E> implements ResultDescriptor<List<E>> { | 278 abstract class ListResultDescriptor<E> implements ResultDescriptor<List<E>> { |
| 265 /** | 279 /** |
| 266 * Initialize a newly created analysis result to have the given [name] and | 280 * Initialize a newly created analysis result to have the given [name] and |
| 267 * [defaultValue]. If a [cachingPolicy] is provided, it will control how long | 281 * [defaultValue]. If a [cachingPolicy] is provided, it will control how long |
| 268 * values associated with this result will remain in the cache. | 282 * values associated with this result will remain in the cache. |
| 269 */ | 283 */ |
| 270 factory ListResultDescriptor(String name, List<E> defaultValue, | 284 factory ListResultDescriptor(String name, List<E> defaultValue, |
| 271 {ResultCachingPolicy<List<E>> cachingPolicy}) = ListResultDescriptorImpl< | 285 {ResultCachingPolicy<List<E>> cachingPolicy}) = ListResultDescriptorImpl< |
| 272 E>; | 286 E>; |
| 273 | 287 |
| 274 @override | 288 @override |
| 275 ListTaskInput<E> of(AnalysisTarget target); | 289 ListTaskInput<E> of(AnalysisTarget target, {bool flushOnAccess: false}); |
| 276 } | 290 } |
| 277 | 291 |
| 278 /** | 292 /** |
| 279 * A description of an input to an [AnalysisTask] that can be used to compute | 293 * A description of an input to an [AnalysisTask] that can be used to compute |
| 280 * that input. | 294 * that input. |
| 281 * | 295 * |
| 282 * Clients are not expected to subtype this class. | 296 * Clients are not expected to subtype this class. |
| 283 */ | 297 */ |
| 284 abstract class ListTaskInput<E> extends TaskInput<List<E>> { | 298 abstract class ListTaskInput<E> extends TaskInput<List<E>> { |
| 285 /** | 299 /** |
| (...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 380 */ | 394 */ |
| 381 V get defaultValue; | 395 V get defaultValue; |
| 382 | 396 |
| 383 /** | 397 /** |
| 384 * Return the name of this descriptor. | 398 * Return the name of this descriptor. |
| 385 */ | 399 */ |
| 386 String get name; | 400 String get name; |
| 387 | 401 |
| 388 /** | 402 /** |
| 389 * Return a task input that can be used to compute this result for the given | 403 * Return a task input that can be used to compute this result for the given |
| 390 * [target]. | 404 * [target]. If [flushOnAccess] is `true` then the value of this result that |
| 405 * is associated with the [target] will be flushed when it is accessed. |
| 391 */ | 406 */ |
| 392 TaskInput<V> of(AnalysisTarget target); | 407 TaskInput<V> of(AnalysisTarget target, {bool flushOnAccess: false}); |
| 393 } | 408 } |
| 394 | 409 |
| 395 /** | 410 /** |
| 396 * A specification of the given [result] for the given [target]. | 411 * A specification of the given [result] for the given [target]. |
| 397 * | 412 * |
| 398 * Clients are not expected to subtype this class. | 413 * Clients are not expected to subtype this class. |
| 399 */ | 414 */ |
| 400 class TargetedResult { | 415 class TargetedResult { |
| 401 /** | 416 /** |
| 402 * An empty list of results. | 417 * An empty list of results. |
| (...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 523 | 538 |
| 524 /** | 539 /** |
| 525 * Set the [value] that was computed for the current result. | 540 * Set the [value] that was computed for the current result. |
| 526 * | 541 * |
| 527 * Throws a [StateError] if [moveNext] has not been invoked or if the last | 542 * Throws a [StateError] if [moveNext] has not been invoked or if the last |
| 528 * invocation of [moveNext] returned `false`. | 543 * invocation of [moveNext] returned `false`. |
| 529 */ | 544 */ |
| 530 void set currentValue(Object value); | 545 void set currentValue(Object value); |
| 531 | 546 |
| 532 /** | 547 /** |
| 548 * Return `true` if the value accessed by this input builder should be flushed |
| 549 * from the cache at the time it is retrieved. |
| 550 */ |
| 551 bool get flushOnAccess; |
| 552 |
| 553 /** |
| 533 * Return the [value] that was computed by this builder. | 554 * Return the [value] that was computed by this builder. |
| 534 * | 555 * |
| 535 * Throws a [StateError] if [moveNext] has not been invoked or if the last | 556 * Throws a [StateError] if [moveNext] has not been invoked or if the last |
| 536 * invocation of [moveNext] returned `true`. | 557 * invocation of [moveNext] returned `true`. |
| 537 * | 558 * |
| 538 * Returns `null` if no value could be computed due to a circular dependency. | 559 * Returns `null` if no value could be computed due to a circular dependency. |
| 539 */ | 560 */ |
| 540 V get inputValue; | 561 V get inputValue; |
| 541 | 562 |
| 542 /** | 563 /** |
| (...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 646 /** | 667 /** |
| 647 * A work should be done, but without any special urgency. | 668 * A work should be done, but without any special urgency. |
| 648 */ | 669 */ |
| 649 NORMAL, | 670 NORMAL, |
| 650 | 671 |
| 651 /** | 672 /** |
| 652 * Nothing to do. | 673 * Nothing to do. |
| 653 */ | 674 */ |
| 654 NONE | 675 NONE |
| 655 } | 676 } |
| OLD | NEW |