analysis server performance measurement driver first cut

pkg/analysis_server/test/performance/operation.dart

+library server.operation;
+
+import 'dart:async';
+
+import 'package:analysis_server/src/protocol.dart';
+import 'package:logging/logging.dart';
+
+import 'driver.dart';
+
+class InfoOperation extends Operation {
+  final String message;
+
+  InfoOperation(this.message);
+
+  @override
+  Future perform(Driver driver) {
+    driver.logger.log(Level.INFO, message);
+    return null;
+  }
+}
+
+/**
+ * An [Operation] represents an action such as sending a request to the server.
+ */
+abstract class Operation {
+  Future perform(Driver driver);
+}
+
+/**
+ * A [RequestOperation] sends a [JSON] request to the server.
+ */
+class RequestOperation extends Operation {
+  final Map<String, dynamic> json;
+
+  RequestOperation(this.json);
+
+  @override
+  Future perform(Driver driver) {
+    String method = json['method'];
+    driver.logger.log(Level.FINE, 'Sending request: $method\n  $json');
+    driver.send(method, json['params']).then((response) {
+      driver.logger.log(Level.FINE, 'Response received: $method : $response');
+    }).catchError((e, s) {
+      driver.logger.log(Level.WARNING, 'Request failed: $method\n  $e\n$s');
+      throw 'Send request failed: $e';
+    });
+    return null;
+  }
+}
+
+class StartServerOperation extends Operation {
+  @override
+  Future perform(Driver driver) {
+    return driver.startServer();
+  }
+}
+
+class WaitForAnalysisCompleteOperation extends Operation {
+  @override
+  Future perform(Driver driver) {
+    DateTime start = new DateTime.now();
+    driver.logger.log(Level.FINE, 'waiting for analysis to complete');
+    StreamSubscription<ServerStatusParams> subscription;
+    Timer timer;
+    Completer completer = new Completer();
+    bool isAnalyzing = false;
+    subscription = driver.onServerStatus.listen((ServerStatusParams params) {
+      // TODO (danrubel) ensure that server.setSubscriptions STATUS is set
+      if (params.analysis != null) {
+        if (params.analysis.isAnalyzing) {
+          isAnalyzing = true;
+        } else {
+          subscription.cancel();
+          timer.cancel();
+          DateTime end = new DateTime.now();
+          Duration delta = end.difference(start);
+          driver.logger.log(Level.FINE, 'analysis complete after $delta');
+          completer.complete();
+          driver.results.record('analysis complete', delta);
+        }
+      }
+    });
+    timer = new Timer.periodic(new Duration(milliseconds: 20), (_) {
+      if (!isAnalyzing) {
+        // TODO (danrubel) revisit this once source change requests are implemented
+        subscription.cancel();
+        timer.cancel();
+        driver.logger.log(Level.INFO, 'analysis never started');
+        completer.complete();
+        return;
+      }
+      // Timeout if no communcation received within the last 10 seconds.
+      double currentTime = driver.server.currentElapseTime;
+      double lastTime = driver.server.lastCommunicationTime;
+      if (currentTime - lastTime > 10) {
+        subscription.cancel();
+        timer.cancel();
+        String message = 'gave up waiting for analysis to complete';
+        driver.logger.log(Level.WARNING, message);
+        completer.completeError(message);
+      }
+    });
+    return completer.future;
+  }
+}