vmservice: basic object graph serialization.

runtime/vm/service.cc

 // Copyright (c) 2013, 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.
 
 #include "vm/service.h"
 
 #include "include/dart_api.h"
 #include "platform/globals.h"
 
 #include "vm/compiler.h"
@@ skipping 2248 matching lines @@
   return true;
 }
 
 
 static bool HandleHeapMap(Isolate* isolate, JSONStream* js) {
   isolate->heap()->PrintHeapMapToJSONStream(isolate, js);
   return true;
 }
 
 
+static bool HandleGraph(Isolate* isolate, JSONStream* js) {
+  Service::SendGraphEvent(isolate);
+  // TODO(koda): Provide some id that ties this request to async response(s).
+  JSONObject jsobj(js);
+  jsobj.AddProperty("type", "OK");
+  jsobj.AddProperty("id", "ok");
+  return true;
+}
+
+
+void Service::SendGraphEvent(Isolate* isolate) {
+  uint8_t* buffer = NULL;
+  WriteStream stream(&buffer, &allocator, 1 * MB);
+  ObjectGraph graph(isolate);
+  graph.Serialize(&stream);
+  JSONStream js;
+  {
+    JSONObject jsobj(&js);
+    jsobj.AddProperty("type", "ServiceEvent");
+    jsobj.AddPropertyF("id", "_graphEvent");
+    jsobj.AddProperty("eventType", "_Graph");
+    jsobj.AddProperty("isolate", isolate);
+  }
+  const String& message = String::Handle(String::New(js.ToCString()));
+  SendEvent(kEventFamilyDebug, message, buffer, stream.bytes_written());
+}
+
+
 class ContainsAddressVisitor : public FindObjectVisitor {
  public:
   ContainsAddressVisitor(Isolate* isolate, uword addr)
       : FindObjectVisitor(isolate), addr_(addr) { }
   virtual ~ContainsAddressVisitor() { }
 
   virtual uword filter_addr() const { return addr_; }
 
   virtual bool FindObject(RawObject* obj) const {
     // Free list elements are not real objects, so skip them.
@@ skipping 52 matching lines @@
   { "_malformedjson", HandleMalformedJson },
   { "_malformedobject", HandleMalformedObject },
   { "_echo", HandleIsolateEcho },
   { "", HandleIsolate },
   { "address", HandleAddress },
   { "allocationprofile", HandleAllocationProfile },
   { "classes", HandleClasses },
   { "code", HandleCode },
   { "coverage", HandleCoverage },
   { "debug", HandleDebug },
+  { "graph", HandleGraph },
   { "heapmap", HandleHeapMap },
   { "libraries", HandleLibraries },
   { "metrics", HandleMetrics },
   { "objects", HandleObjects },
   { "profile", HandleProfile },
   { "scripts", HandleScripts },
   { "stacktrace", HandleStackTrace },
   { "typearguments", HandleTypeArguments },
 };
 
@@ skipping 365 matching lines @@
   while (current != NULL) {
     if (strcmp(name, current->name()) == 0) {
       return current;
     }
     current = current->next();
   }
   return NULL;
 }
 
 }  // namespace dart