VM Service isolate listing

runtime/bin/vmservice_impl.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 "bin/vmservice_impl.h"
 
 #include "include/dart_api.h"
 
 #include "bin/builtin.h"
 #include "bin/dartutils.h"
 #include "bin/resources.h"
 #include "bin/thread.h"
 #include "bin/isolate_data.h"
 
+#include "vm/dart_api_impl.h"
+#include "vm/object.h"
+#include "vm/dart_entry.h"
+#include "vm/snapshot.h"
+#include "vm/native_entry.h"
+#include "vm/native_arguments.h"
+#include "vm/isolate.h"
+#include "vm/port.h"
+#include "vm/message.h"

[siva, 2013/07/19 17:41:16]

We usually sort the include headers alphabetically....

[Cutch, 2013/07/19 18:15:02]

Done.

 
 namespace dart {
 namespace bin {
 
 // snapshot_buffer points to a snapshot if we link in a snapshot otherwise
 // it is initialized to NULL.
 extern const uint8_t* snapshot_buffer;
 #define RETURN_ERROR_HANDLE(handle)                             \
   if (Dart_IsError(handle)) {                                   \
     return handle;                                              \
   }
 
 #define SHUTDOWN_ON_ERROR(handle)                               \
   if (Dart_IsError(handle)) {                                   \
     error_msg_ = strdup(Dart_GetError(handle));                 \
     Dart_ExitScope();                                           \
     Dart_ShutdownIsolate();                                     \
     return false;                                               \
   }
 
 #define kLibraryResourceNamePrefix "/vmservice"
 static const char* kLibraryScriptResourceName =
     kLibraryResourceNamePrefix "/vmservice.dart";
 static const char* kLibrarySourceResourceNames[] = {
+    kLibraryResourceNamePrefix "/constants.dart",
+    kLibraryResourceNamePrefix "/resources.dart",
+    kLibraryResourceNamePrefix "/running_isolate.dart",
+    kLibraryResourceNamePrefix "/running_isolates.dart",
+    kLibraryResourceNamePrefix "/server.dart",
+    kLibraryResourceNamePrefix "/service_request.dart",
+    kLibraryResourceNamePrefix "/service_request_router.dart",
+    kLibraryResourceNamePrefix "/vmservice_io.dart",
     NULL
 };
 
 #define kClientResourceNamePrefix "/client/web/out"
 
 Dart_Isolate VmService::isolate_ = NULL;
 Dart_Port VmService::port_ = ILLEGAL_PORT;
 dart::Monitor* VmService::monitor_ = NULL;
 const char* VmService::error_msg_ = NULL;
 
 // These must be kept in sync with vmservice/constants.dart
 #define VM_SERVICE_ISOLATE_STARTUP_MESSAGE_ID 1
 #define VM_SERVICE_ISOLATE_SHUTDOWN_MESSAGE_ID 2
 
 
+static Dart_NativeFunction VmServiceNativeResolver(Dart_Handle name,
+                                                   int num_arguments);
+
+
 bool VmService::Start(intptr_t server_port) {
   monitor_ = new dart::Monitor();
   ASSERT(monitor_ != NULL);
   error_msg_ = NULL;
 
 
   {
     // Take lock before spawning new thread.
     MonitorLocker ml(monitor_);
     // Spawn new thread.
@@ skipping 58 matching lines @@
   if (!retval) {
     Dart_EnterIsolate(isolate_);
     Dart_ShutdownIsolate();
     error_msg_ = "Invalid isolate state - Unable to make it runnable.";
     return false;
   }
 
   Dart_EnterIsolate(isolate_);
   Dart_EnterScope();
 
+
   Dart_Handle library = Dart_RootLibrary();
+  // Set requested port.
+  DartUtils::SetIntegerField(library, "_port", server_port);
+  // Install native resolver.
+  result = Dart_SetNativeResolver(library, VmServiceNativeResolver);
+  SHUTDOWN_ON_ERROR(result);
   result = Dart_Invoke(library, DartUtils::NewString("main"), 0, NULL);
   SHUTDOWN_ON_ERROR(result);
 
   result = LoadResources(library);
   SHUTDOWN_ON_ERROR(result);
 
   port_ = Dart_GetMainPortId();
 
   Dart_ExitScope();
   Dart_ExitIsolate();
@@ skipping 134 matching lines @@
     Dart_EnterScope();
 
     Dart_Handle receievePort = Dart_GetReceivePort(port_);
     ASSERT(!Dart_IsError(receievePort));
     monitor_->Notify();
   }
 
   // Keep handling messages until the last active receive port is closed.
   Dart_Handle result = Dart_RunLoop();
   if (Dart_IsError(result)) {
-    printf("VmService error %s\n", Dart_GetError(result));
+    printf("VmService has exited with an error:\n%s\n", Dart_GetError(result));
   }
 
   _Stop();
 
   Dart_ExitScope();
   Dart_ExitIsolate();
 }
 
 
-
-
 static Dart_Handle MakeServiceControlMessage(Dart_Port port) {
   Dart_Handle list = Dart_NewList(2);
   ASSERT(!Dart_IsError(list));
   Dart_Handle sendPort = Dart_NewSendPort(port);
   ASSERT(!Dart_IsError(sendPort));
   Dart_ListSetAt(list, 1, sendPort);
   return list;
 }
 
 
@@ skipping 18 matching lines @@
   Dart_Isolate isolate = Dart_CurrentIsolate();
   ASSERT(isolate != NULL);
   ASSERT(Dart_GetMainPortId() == port);
   Dart_Handle list = MakeServiceControlMessage(port);
   Dart_ListSetAt(list, 0,
                  Dart_NewInteger(VM_SERVICE_ISOLATE_SHUTDOWN_MESSAGE_ID));
   return Dart_Post(port_, list);
 }
 
 
+void VmServiceShutdownCallback(void* callback_data) {
+  ASSERT(Dart_CurrentIsolate() != NULL);
+  Dart_EnterScope();
+  VmService::SendIsolateShutdownMessage(Dart_GetMainPortId());
+  Dart_ExitScope();
+}
+
+
+static uint8_t* allocator(uint8_t* ptr, intptr_t old_size, intptr_t new_size) {
+  void* new_ptr = realloc(reinterpret_cast<void*>(ptr), new_size);
+  return reinterpret_cast<uint8_t*>(new_ptr);
+}
+
+
+static void SendServiceMessage(Dart_NativeArguments args) {
+  NativeArguments* arguments = reinterpret_cast<NativeArguments*>(args);
+  Isolate* isolate = arguments->isolate();
+  StackZone zone(isolate);
+  HANDLESCOPE(isolate);
+  GET_NON_NULL_NATIVE_ARGUMENT(Instance, sp, arguments->NativeArgAt(0));
+  GET_NON_NULL_NATIVE_ARGUMENT(Instance, rp, arguments->NativeArgAt(1));
+  GET_NON_NULL_NATIVE_ARGUMENT(Instance, message, arguments->NativeArgAt(2));
+
+  // Extract SendPort port id.
+  const Object& sp_id_obj = Object::Handle(DartLibraryCalls::PortGetId(sp));
+  if (sp_id_obj.IsError()) {
+    Exceptions::PropagateError(Error::Cast(sp_id_obj));
+  }
+  ASSERT(sp_id_obj.IsSmi() || sp_id_obj.IsMint());

[siva, 2013/07/19 17:41:16]

Why do you need the assert? the call AsInt64Value() will barf out with an
UNREACHABLE if the value turns out to be a BIG INT.

[Cutch, 2013/07/19 18:15:02]

Done.

+  Integer& id = Integer::Handle();
+  id ^= sp_id_obj.raw();
+  Dart_Port sp_id = static_cast<Dart_Port>(id.AsInt64Value());
+
+  // Extract ReceivePort port id.
+  const Object& rp_id_obj = Object::Handle(DartLibraryCalls::PortGetId(rp));
+  if (rp_id_obj.IsError()) {
+    Exceptions::PropagateError(Error::Cast(rp_id_obj));
+  }
+  ASSERT(rp_id_obj.IsSmi() || rp_id_obj.IsMint());
+  id ^= rp_id_obj.raw();
+  Dart_Port rp_id = static_cast<Dart_Port>(id.AsInt64Value());
+
+  // Both are valid ports.
+  ASSERT(sp_id != ILLEGAL_PORT);
+  ASSERT(rp_id != ILLEGAL_PORT);
+
+  // Serialize message.
+  uint8_t* data = NULL;
+  MessageWriter writer(&data, &allocator);
+  writer.WriteMessage(message);
+
+  // TODO(turnidge): Throw an exception when the return value is false?
+  PortMap::PostMessage(new Message(sp_id, rp_id, data, writer.BytesWritten(),
+                                   Message::kOOBPriority,
+                                   Message::kServiceType));
+}
+
+
+struct VmServiceNativeEntry {
+  const char* name;
+  int num_arguments;
+  Dart_NativeFunction function;
+};
+
+
+static VmServiceNativeEntry _VmServiceNativeEntries[] = {
+  {"SendServiceMessage", 3, SendServiceMessage}
+};
+
+
+static Dart_NativeFunction VmServiceNativeResolver(Dart_Handle name,
+                                                   int num_arguments) {
+  const Object& obj = Object::Handle(Api::UnwrapHandle(name));
+  if (!obj.IsString()) {
+    return NULL;
+  }
+  const char* function_name = obj.ToCString();
+  ASSERT(function_name != NULL);
+  intptr_t n =
+      sizeof(_VmServiceNativeEntries) / sizeof(_VmServiceNativeEntries[0]);
+  for (intptr_t i = 0; i < n; i++) {
+    VmServiceNativeEntry entry = _VmServiceNativeEntries[i];
+    if (!strcmp(function_name, entry.name) &&
+        (num_arguments == entry.num_arguments)) {
+      return entry.function;
+    }
+  }

[siva, 2013/07/19 17:41:16]

Do you think there will be more than 1 native entry to be resolved here?

We could just simplify this to just check for "SendServideMessage"
and return SendServiceMessage without the for loop.

[Cutch, 2013/07/19 18:15:02]

It's possible.

+  return NULL;
+}
+
 }  // namespace bin
 }  // namespace dart