Initial UI for Metrics in Observatory

runtime/bin/vmservice/observatory/lib/src/service/object.dart

 // Copyright (c) 2014, 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.
 
 part of service;
 
 /// A [ServiceObject] is an object known to the VM service and is tied
 /// to an owning [Isolate].
 abstract class ServiceObject extends Observable {
   static int LexicalSortName(ServiceObject o1, ServiceObject o2) {
@@ skipping 58 matching lines @@
     var type = _stripRef(map['type']);
     var obj = null;
     assert(type != 'VM');
     switch (type) {
       case 'Class':
         obj = new Class._empty(owner);
         break;
       case 'Code':
         obj = new Code._empty(owner);
         break;
+      case 'Counter':
+        obj = new ServiceMetric._empty(owner);
+        break;
       case 'Error':
         obj = new DartError._empty(owner);
         break;
       case 'Function':
         obj = new ServiceFunction._empty(owner);
         break;
+      case 'Gauge':
+        obj = new ServiceMetric._empty(owner);
+        break;
       case 'Isolate':
         obj = new Isolate._empty(owner.vm);
         break;
       case 'Library':
         obj = new Library._empty(owner);
         break;
       case 'ServiceError':
         obj = new ServiceError._empty(owner);
         break;
       case 'ServiceEvent':
@@ skipping 599 matching lines @@
     return new Future.value(objectClass);
   }
 
   ServiceObject getFromMap(ObservableMap map) {
     if (map == null) {
       return null;
     }
     String id = map['id'];
     var obj = _cache[id];
     if (obj != null) {
+      // Consider calling update when map is not a reference.
       return obj;
     }
     // Build the object from the map directly.
     obj = new ServiceObject._fromMap(this, map);
     if (obj != null && obj.canCache) {
       _cache[id] = obj;
     }
     return obj;
   }
 
@@ skipping 292 matching lines @@
     return get("debug/resume").then((result) {
         if (result is DartError) {
           // TODO(turnidge): Handle this more gracefully.
           Logger.root.severe(result.message);
         }
         return isolate.reload();
       });
   }
 
   Future stepInto() {
-    print('isolate.stepInto');
     return get("debug/resume?step=into").then((result) {
         if (result is DartError) {
           // TODO(turnidge): Handle this more gracefully.
           Logger.root.severe(result.message);
         }
         return isolate.reload();
       });
   }
 
   Future stepOver() {
     return get("debug/resume?step=over").then((result) {
         if (result is DartError) {
           // TODO(turnidge): Handle this more gracefully.
           Logger.root.severe(result.message);
         }
         return isolate.reload();
       });
   }
 
   Future stepOut() {
     return get("debug/resume?step=out").then((result) {
         if (result is DartError) {
           // TODO(turnidge): Handle this more gracefully.
           Logger.root.severe(result.message);
         }
         return isolate.reload();
       });
   }
 
+  final ObservableMap<String, ServiceMetric> dartMetrics =
+      new ObservableMap<String, ServiceMetric>();
+
+  final ObservableMap<String, ServiceMetric> vmMetrics =
+      new ObservableMap<String, ServiceMetric>();
+
+  Future<ObservableMap<String, ServiceMetric>> _refreshMetrics(
+      String id,
+      ObservableMap<String, ServiceMetric> metricsMap) {
+    return get(id).then((result) {
+      if (result is DartError) {
+        // TODO(turnidge): Handle this more gracefully.
+        Logger.root.severe(result.message);
+        return null;
+      }
+      // Clear metrics map.
+      metricsMap.clear();
+      // Repopulate metrics map.
+      var members = result['members'];
+      for (var metric in members) {
+        metricsMap[metric.id] = metric;
+      }
+      return metricsMap;
+    });
+  }
+
+  Future<ObservableMap<String, ServiceMetric>> refreshDartMetrics() {
+    return _refreshMetrics('metrics', dartMetrics);
+  }
+
+  Future<ObservableMap<String, ServiceMetric>> refreshVMMetrics() {
+    return _refreshMetrics('metrics/vm', vmMetrics);
+  }
+
+  Future refreshMetrics() {
+    return refreshDartMetrics().then((_) => refreshVMMetrics());
+  }
+
   String toString() => "Isolate($_id)";
 }
 
 /// A [ServiceObject] which implements [ObservableMap].
 class ServiceMap extends ServiceObject implements ObservableMap {
   final ObservableMap _map = new ObservableMap();
   static String objectIdRingPrefix = 'objects/';
 
   bool get canCache {
     return (_serviceType == 'Class' ||
@@ skipping 478 matching lines @@
         if (!_isTrivialToken(token)) {
           return false;
         }
       }
     }
     return true;
   }
 
   ScriptLine(this.script, this.line, this.text) {
     possibleBpt = !_isTrivialLine(text);
-    
+
     // TODO(turnidge): This is not so efficient.  Consider improving.
     for (var bpt in this.script.isolate.breakpoints['breakpoints']) {
       var bptScript = bpt['location']['script'];
       var bptTokenPos = bpt['location']['tokenPos'];
       if (bptScript == this.script &&
           bptScript.tokenToLine(bptTokenPos) == line) {
         this.bpt = bpt;
       }
     }
   }
@@ skipping 657 matching lines @@
     localAddress = map['localAddress'];
     localPort = map['localPort'];
     remoteAddress = map['remoteAddress'];
     remotePort = map['remotePort'];
 
     fd = map['fd'];
     socketOwner = map['owner'];
   }
 }
 
+class MetricSample {
+  final double value;
+  final DateTime time;
+  MetricSample(this.value) : time = new DateTime.now();
+}
+
+class ServiceMetric extends ServiceObject {
+  ServiceMetric._empty(ServiceObjectOwner owner) : super._empty(owner) {
+  }
+
+  bool get canCache => true;
+  bool get immutable => false;
+
+  @observable bool recording = false;
+  MetricPoller poller;
+
+  final ObservableList<MetricSample> samples =
+      new ObservableList<MetricSample>();
+  int _sampleBufferSize = 100;
+  int get sampleBufferSize => _sampleBufferSize;
+  set sampleBufferSize(int size) {
+    _sampleBufferSize = size;
+    _removeOld();
+  }
+
+  void addSample(MetricSample sample) {
+    samples.add(sample);
+    _removeOld();
+  }
+
+  void _removeOld() {
+    // TODO(johnmccutchan): If this becomes hot, consider using a circular
+    // buffer.
+    if (samples.length > _sampleBufferSize) {
+      int count = samples.length - _sampleBufferSize;
+      samples.removeRange(0, count);
+    }
+  }
+
+  @observable String description;
+  @observable double value = 0.0;
+  // Only a guage has a non-null min and max.
+  @observable double min;
+  @observable double max;
+
+  bool get isGauge => (min != null) && (max != null);
+
+  void _update(ObservableMap map, bool mapIsRef) {
+    name = map['name'];
+    description = map['description'];
+    vmName = map['name'];
+    value = map['value'];
+    min = map['min'];
+    max = map['max'];
+  }
+
+  String toString() => "ServiceMetric($_id)";
+}
+
+class MetricPoller {
+  // Metrics to be polled.
+  final List<ServiceMetric> metrics = new List<ServiceMetric>();
+  final Duration pollPeriod;
+  Timer _pollTimer;
+
+  MetricPoller(int milliseconds) :
+      pollPeriod = new Duration(milliseconds: milliseconds) {
+    start();
+  }
+
+  void start() {
+    _pollTimer = new Timer.periodic(pollPeriod, _onPoll);
+  }
+
+  void cancel() {
+    if (_pollTimer != null) {
+      _pollTimer.cancel();
+    }
+    _pollTimer = null;
+  }
+
+  void _onPoll(_) {
+    // Reload metrics and add a sample to each.
+    for (var metric in metrics) {
+      metric.reload().then((m) {
+        m.addSample(new MetricSample(m.value));
+      });
+    }
+  }
+}
+
 // Convert any ServiceMaps representing a null instance into an actual null.
 _convertNull(obj) {
   if (obj is ServiceMap &&
       obj.serviceType == 'Null') {
     return null;
   }
   return obj;
 }
 
 // Returns true if [map] is a service map. i.e. it has the following keys:
@@ skipping 36 matching lines @@
     var v = list[i];
     if ((v is ObservableMap) && _isServiceMap(v)) {
       list[i] = owner.getFromMap(v);
     } else if (v is ObservableList) {
       _upgradeObservableList(v, owner);
     } else if (v is ObservableMap) {
       _upgradeObservableMap(v, owner);
     }
   }
 }