add completion tests

pkg/analysis_server/benchmark/perf/analysis_timing_tests.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 server.performance.analysis.timing;
 
 import 'dart:async';
 import 'dart:io';
 
 import 'package:analysis_server/src/protocol.dart';
 import 'package:args/args.dart';
 import 'package:test_reflective_loader/test_reflective_loader.dart';
 import 'package:unittest/unittest.dart';
 
 import '../../test/utils.dart';
 import 'performance_tests.dart';
 
 /**
  * Pass in the directory of the source to be analyzed as option `--source`,
  * optionally specify a priority file with `--priority` and the specific
- * test to run with `--test`.  If no test is specified, the default is
+ * test to run with `--metric`.  If no test is specified, the default is
  * `analysis`.
  */
 main(List<String> arguments) {
   initializeTestEnvironment();
   ArgParser parser = _createArgParser();
   var args = parser.parse(arguments);
   if (args[SOURCE_OPTION] == null) {
     print('path to source directory must be specified');
     exit(1);
   }
   source = args[SOURCE_OPTION];
   priorityFile = args[PRIORITY_FILE_OPTION];
-  var metricNameParam = args[METRIC_NAME_OPTION] ?? DEFAULT_METRIC;
+  metricNames.addAll(args[METRIC_NAME_OPTION]);
+  unittestConfiguration.timeout = new Duration(minutes: 20);
 
-  metricNames.addAll(metricNameParam);
-
-  defineReflectiveTests(TimingTest);
+  if (metricNames.isEmpty) {
+    defineReflectiveTests(AnalysisTimingTest);
+  } else {
+    defineReflectiveTests(SubscriptionTimingTest);
+  }
 }
 
 const DEFAULT_METRIC = 'analysis';
 const METRIC_NAME_OPTION = 'metric';
 const PRIORITY_FILE_OPTION = 'priority';
 const SOURCE_OPTION = 'source';
 
 final metricNames = <String>[];
 String priorityFile;
 String source;
 
 ArgParser _createArgParser() => new ArgParser()
   ..addOption(METRIC_NAME_OPTION,
       help: 'metric name (defaults to `analysis`)', allowMultiple: true)
   ..addOption(SOURCE_OPTION, help: 'full path to source directory for analysis')
   ..addOption(PRIORITY_FILE_OPTION,
       help: '(optional) full path to a priority file');
 
 class AbstractTimingTest extends AbstractAnalysisServerPerformanceTest {
   @override
   Future setUp() => super.setUp().then((_) {
         sourceDirectory = new Directory(source);
         subscribeToStatusNotifications();
       });
 }
 
+@reflectiveTest
+class AnalysisTimingTest extends AbstractTimingTest {
+  Future test_timing() {
+    // Set root after subscribing to avoid empty notifications.
+    setAnalysisRoot();
+
+    stopwatch.start();
+    return analysisFinished.then((_) {
+      print('analysis completed in ${stopwatch.elapsed}');
+      stopwatch.reset();
+    });
+  }
+}
+
 class Metric {
   List<Duration> timings = <Duration>[];
   Stream eventStream;
   AnalysisService service;
   String name;
   Metric(this.name, this.service, this.eventStream);
   String toString() => '$name: $service, ${eventStream.runtimeType}, $timings';
 }
 
 @reflectiveTest
-class TimingTest extends AbstractTimingTest {
+class SubscriptionTimingTest extends AbstractTimingTest {
   List<Metric> _metrics;
 
   List<Metric> get metrics =>
       _metrics ??= metricNames.map((name) => getMetric(name)).toList();
 
   Metric getMetric(String name) {
     switch (name) {
       case 'folding':
         return new Metric(name, AnalysisService.FOLDING, onAnalysisFolding);
       case 'highlighting':
@@ skipping 12 matching lines @@
             name, AnalysisService.OCCURRENCES, onAnalysisOccurrences);
       case 'overrides':
         return new Metric(name, AnalysisService.OVERRIDES, onAnalysisOverrides);
     }
     print('no metric found for $name');
     exit(1);
     return null; // Won't get here.
   }
 
   Future test_timing() {
-    //debugStdio();
+//   debugStdio();
 
     expect(metrics, isNotEmpty);
     expect(priorityFile, isNotNull,
         reason: 'A priority file must be specified for '
             '${metrics.first.name} testing.');
 
     stopwatch.start();
 
     metrics.forEach((Metric m) => m.eventStream.listen((_) {
           m.timings.add(
@@ skipping 10 matching lines @@
 
     sendAnalysisSetPriorityFiles([priorityFile]);
 
     return analysisFinished.then((_) {
       print('analysis completed in ${stopwatch.elapsed}');
       metrics.forEach((Metric m) => print('${m.name} timings: ${m.timings}'));
       stopwatch.reset();
     });
   }
 }