analysis server performance measurement - work in progress

pkg/analysis_server/test/performance/operation.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.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;
-  }
-}
+import 'input_converter.dart';
 
 /**
  * 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 CommonInputConverter converter;
   final Map<String, dynamic> json;
 
-  RequestOperation(this.json);
+  RequestOperation(this.converter, this.json);
 
   @override
   Future perform(Driver driver) {
+    Stopwatch stopwatch = new Stopwatch();
     String method = json['method'];
     driver.logger.log(Level.FINE, 'Sending request: $method\n  $json');
+    stopwatch.start();
+    void recordResponse(bool success, response) {
+      stopwatch.stop();
+      Duration elapsed = stopwatch.elapsed;
+      driver.results.record(method, elapsed, success: success);
+      driver.logger.log(
+          Level.FINE, 'Response received: $method : $elapsed\n  $response');
+    }
     driver.send(method, json['params']).then((response) {
-      driver.logger.log(Level.FINE, 'Response received: $method : $response');
+      recordResponse(true, response);
     }).catchError((e, s) {
-      driver.logger.log(Level.WARNING, 'Request failed: $method\n  $e\n$s');
-      throw 'Send request failed: $e';
+      recordResponse(false, e);
+      converter.recordErrorResponse(json, e);
     });
     return null;
   }
 }
 
 class StartServerOperation extends Operation {
   @override
   Future perform(Driver driver) {
     return driver.startServer();
   }
@@ skipping 40 matching lines @@
         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;
   }
 }