Rank most retaining instances for each class.

runtime/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 675 matching lines @@
   void update(Map heapMap) {
     used = heapMap['used'];
     capacity = heapMap['capacity'];
     external = heapMap['external'];
     collections = heapMap['collections'];
     totalCollectionTimeInSeconds = heapMap['time'];
     averageCollectionPeriodInMillis = heapMap['avgCollectionPeriodMillis'];
   }
 }
 
+class HeapSnapshot extends Observable {

[Cutch, 2015/01/07 00:25:26]

Why does this class extend from Observable?

[koda, 2015/01/09 18:46:56]

Done.

+  final ObjectGraph graph;
+  final DateTime timeStamp;
+  final Isolate isolate;
+  
+  HeapSnapshot(this.isolate, ByteData data) :
+      graph = new ObjectGraph(new ReadStream(data)),
+      timeStamp = new DateTime.now() {
+  }
+  
+  List<Future<ServiceObject>> getMostRetained({int classId, int limit}) {
+    var result = [];
+    for (var v in graph.getMostRetained(classId: classId, limit: limit)) {
+      var address = v.addressForWordSize(isolate.vm.architectureBits ~/ 8);
+      result.add(isolate.get(
+          'address/${address.toRadixString(16)}?ref=true').then((obj) {
+        obj.retainedSize = v.retainedSize;
+        return new Future(() => obj);
+      }));
+    }
+    return result;
+  }
+  
+  
+}
+
 /// State for a running isolate.
 class Isolate extends ServiceObjectOwner with Coverage {
   @reflectable VM get vm => owner;
   @reflectable Isolate get isolate => this;
   @observable ObservableMap counters = new ObservableMap();
 
   String get link => '/${_id}';
 
   @observable ServiceEvent pauseEvent = null;
   bool get _isPaused => pauseEvent != null;
@@ skipping 141 matching lines @@
 
   @observable final Map<String, double> timers =
       toObservable(new Map<String, double>());
 
   final HeapSpace newSpace = new HeapSpace();
   final HeapSpace oldSpace = new HeapSpace();
 
   @observable String fileAndLine;
 
   @observable DartError error;
+  @observable HeapSnapshot latestSnapshot;
+  Completer<HeapSnapshot> snapshotFetch;

[Cutch, 2015/01/07 00:25:26]

Any reason why snapshotFetch is public?

[koda, 2015/01/09 18:46:56]

Done.

+  
+  void loadHeapSnapshot(ServiceEvent event) {

[Cutch, 2015/01/07 00:25:26]

Any reason why this is public?

...

I see now that we call it from app. We should probably revisit event delivery at
some point.

[koda, 2015/01/09 18:46:55]

Yes. I think there should be per-isolate event streams in addition to the global
one, but I didn't want to add that in this CL.

+    latestSnapshot = new HeapSnapshot(this, event.data);
+    snapshotFetch.complete(latestSnapshot);
+  }
+  
+  Future<HeapSnapshot> fetchHeapSnapshot() {
+    if (snapshotFetch == null || snapshotFetch.isCompleted) {
+      get('graph');
+      snapshotFetch = new Completer<HeapSnapshot>();
+    }
+    return snapshotFetch.future;
+  }
 
   void updateHeapsFromMap(ObservableMap map) {
     newSpace.update(map['new']);
     oldSpace.update(map['old']);
   }
 
   void _update(ObservableMap map, bool mapIsRef) {
     mainPort = map['mainPort'];
     name = map['name'];
     vmName = map['name'];
@@ skipping 667 matching lines @@
   Future<ServiceObject> get(String command) {
     return isolate.get(id + "/$command");
   }
 
   String toString() => 'Class($vmName)';
 }
 
 class Instance extends ServiceObject {
   @observable Class clazz;
   @observable int size;
+  @observable int retainedSize;
   @observable String valueAsString;  // If primitive.
   @observable bool valueAsStringIsTruncated;
   @observable ServiceFunction closureFunc;  // If a closure.
   @observable Context closureCtxt;  // If a closure.
   @observable String name;  // If a Type.
   @observable int length; // If a List.
 
   @observable var typeClass;
   @observable var fields;
   @observable var nativeFields;
@@ skipping 1181 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);
     }
   }
 }