Ports page for isolates

runtime/vm/port.cc

 // Copyright (c) 2012, 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/port.h"
 
+#include "vm/dart_entry.h"
 #include "platform/utils.h"
 #include "vm/dart_api_impl.h"
 #include "vm/isolate.h"
 #include "vm/lockers.h"
 #include "vm/message_handler.h"
 #include "vm/os_thread.h"
 
 namespace dart {
 
 DECLARE_FLAG(bool, trace_isolates);
@@ skipping 277 matching lines @@
   static const intptr_t kInitialCapacity = 8;
   // TODO(iposva): Verify whether we want to keep exponentially growing.
   ASSERT(Utils::IsPowerOfTwo(kInitialCapacity));
   map_ = new Entry[kInitialCapacity];
   memset(map_, 0, kInitialCapacity * sizeof(Entry));
   capacity_ = kInitialCapacity;
   used_ = 0;
   deleted_ = 0;
 }
 
+
+void PortMap::PrintPortsForMessageHandler(MessageHandler* handler,
+                                          JSONStream* stream) {
+  JSONObject jsobj(stream);
+  jsobj.AddProperty("type", "_Ports");
+  Object& msg_handler = Object::Handle();
+  {
+    JSONArray ports(&jsobj, "ports");
+    MutexLocker ml(mutex_);
+    for (intptr_t i = 0; i < capacity_; i++) {
+      if (map_[i].handler == handler) {
+        if (map_[i].state == kLivePort) {
+          JSONObject port(&ports);
+          port.AddProperty("type", "_Port");
+          port.AddPropertyF("name", "Isolate Port (%" Pd64 ")", map_[i].port);
+          msg_handler = DartLibraryCalls::LookupHandler(map_[i].port);
+          port.AddProperty("handler", msg_handler);
+        }
+      }
+    }
+  }
+}
+
 }  // namespace dart