Display call site data for functions.

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] represents a persistent object within the vm.
 abstract class ServiceObject extends Observable {
   static int LexicalSortName(ServiceObject o1, ServiceObject o2) {
     return o1.name.compareTo(o2.name);
@@ skipping 1895 matching lines @@
     script = map['script'];
     tokenPos = map['tokenPos'];
     endTokenPos = map['endTokenPos'];
     code = _convertNull(map['code']);
     unoptimizedCode = _convertNull(map['unoptimizedCode']);
     isOptimizable = map['optimizable'];
     isInlinable = map['inlinable'];
     deoptimizations = map['deoptimizations'];
     usageCounter = map['usageCounter'];
   }
+
+  // TODO(rmacnak): Generalize and move to Coverage.
+  void processCallSiteData(List callSiteMaps) {
+    var callSites = new List();
+    for (var callSiteMap in callSiteMaps) {
+      callSites.add(new CallSite.fromMap(callSiteMap));
+    }
+    script._processCallSites(callSites);
+  }
+
+  Future refreshCallSiteData() {
+    Map params = {};
+    if (this is! Isolate) {
+      params['targetId'] = id;
+    }
+    return isolate.invokeRpcNoUpgrade('getCallSiteData', params).then(
+        (ObservableMap map) {
+          var data = new ServiceObject._fromMap(isolate, map);
+          assert(data.type == '_CallSiteData');
+          var callSites = data['callSites'];
+          assert(callSites != null);
+          processCallSiteData(callSites);
+          return this;
+        });
+  }
 }
 
 
 class Field extends ServiceObject {
   @observable var /* Library or Class */ owner;
   @observable Instance declaredType;
   @observable bool isStatic;
   @observable bool isFinal;
   @observable bool isConst;
   @observable Instance value;
@@ skipping 93 matching lines @@
     // TODO(turnidge): This is not so efficient.  Consider improving.
     for (var bpt in this.script.isolate.breakpoints) {
       if (bpt.script == this.script &&
           bpt.script.tokenToLine(bpt.tokenPos) == line) {
         this.bpt = bpt;
       }
     }
   }
 }
 
+class CallSite {
+  final String name;
+  final int line;
+  final int column;

[Cutch, 2015/03/09 18:22:42]

Can we store tokenPos and script instead?

[rmacnak, 2015/03/09 23:16:02]

Done.

+  final List<CallSiteEntry> entries;
+
+  CallSite(this.name, this.line, this.column, this.entries);
+
+  factory CallSite.fromMap(Map siteMap) {
+    var name = siteMap['name'];
+    var line = siteMap['line'];
+    var column = siteMap['column'];
+    var entries = new List<CallSiteEntry>();
+    for (var entryMap in siteMap['cacheEntries']) {
+      entries.add(new CallSiteEntry.fromMap(entryMap));
+    }
+    return new CallSite(name, line, column, entries);
+  }
+
+  operator ==(other) {
+    return line == other.line && column == other.column;
+  }
+  int get hashCode => (line << 8) | column;
+
+  String toString() => "CallSite($name, $line:$column)";
+}
+
+class CallSiteEntry {

[Cutch, 2015/03/09 18:22:42]

Maybe rename to InstanceCall?

abstract class Call {
  int count;
}

class InstanceCall extends Call {
  Class receiver;
}

+  final Class receiverClass;
+  final int count;
+
+  CallSiteEntry(this.receiverClass, this.count);
+
+  factory CallSiteEntry.fromMap(Map entryMap) {
+    return new CallSiteEntry(entryMap['receiverClass'],
+                             entryMap['count']);
+  }
+
+  String toString() => "CallSiteEntry(${receiverClass.name}, $count)";
+}
+
 class Script extends ServiceObject with Coverage {
+  Set callSites = new Set();
   final lines = new ObservableList<ScriptLine>();
   final _hits = new Map<int, int>();
   @observable String kind;
   @observable int firstTokenPos;
   @observable int lastTokenPos;
   @observable Library owningLibrary;
   bool get canCache => true;
   bool get immutable => true;
 
   String _shortUrl;
@@ skipping 64 matching lines @@
     }
 
     for (var line in lines) {
       // Remove possible breakpoints on lines with no tokens.
       if (!lineSet.contains(line.line)) {
         line.possibleBpt = false;
       }
     }
   }
 
+  void _processCallSites(List newCallSites) {
+    var mergedCallSites = new Set();
+    mergedCallSites.addAll(newCallSites);
+    mergedCallSites.addAll(callSites);
+    callSites = mergedCallSites;
+    // Notify any Observers that this Script's state has changed.
+    notifyChange(null);
+  }
+
   void _processHits(List scriptHits) {
     // Update hits table.
     for (var i = 0; i < scriptHits.length; i += 2) {
       var line = scriptHits[i];
       var hit = scriptHits[i + 1]; // hit status.
       assert(line >= 1); // Lines start at 1.
       var oldHits = _hits[line];
       if (oldHits != null) {
         hit += oldHits;
       }
@@ skipping 708 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);
     }
   }
 }