Add support for native ports in the vm.

runtime/vm/dart_api_impl.cc

 // Copyright (c) 2011, 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 "include/dart_api.h"
 
 #include "vm/bigint_operations.h"
 #include "vm/class_finalizer.h"
 #include "vm/compiler.h"
 #include "vm/dart.h"
 #include "vm/dart_api_impl.h"
 #include "vm/dart_api_state.h"
 #include "vm/dart_entry.h"
 #include "vm/debuginfo.h"
 #include "vm/exceptions.h"
 #include "vm/growable_array.h"
 #include "vm/longjump.h"
-#include "vm/message_queue.h"
+#include "vm/message.h"
 #include "vm/native_entry.h"
+#include "vm/native_message_handler.h"
 #include "vm/object.h"
 #include "vm/object_store.h"
 #include "vm/port.h"
 #include "vm/resolver.h"
 #include "vm/snapshot.h"
 #include "vm/stack_frame.h"
 #include "vm/timer.h"
 #include "vm/verifier.h"
 
 namespace dart {
@@ skipping 639 matching lines @@
 }
 
 
 DART_EXPORT Dart_Handle Dart_HandleMessage() {
   Isolate* isolate = Isolate::Current();
   // Process all OOB messages and at most one normal message.
   Message* message = NULL;
   Message::Priority priority = Message::kNormalPriority;
   do {
     DARTSCOPE(isolate);
-    message = isolate->message_queue()->DequeueNoWait();
+    message = isolate->message_handler()->queue()->DequeueNoWait();
     if (message == NULL) {
       break;
     }
     priority = message->priority();
     if (priority == Message::kOOBPriority) {
       // TODO(turnidge): Out of band messages will not go through the
       // regular message handler.  Instead they will be dispatched to
       // special vm code.  Implement.
       UNIMPLEMENTED();
     }
     const Instance& msg =
         Instance::Handle(DeserializeMessage(message->data()));
     const Object& result = Object::Handle(
         DartLibraryCalls::HandleMessage(
             message->dest_port(), message->reply_port(), msg));
     delete message;
     if (result.IsError()) {
       return Api::NewLocalHandle(result);
     }
     ASSERT(result.IsNull());
   } while (priority >= Message::kOOBPriority);
   return Api::Success();
 }
 
 
 DART_EXPORT bool Dart_HasLivePorts() {
   Isolate* isolate = Isolate::Current();
   ASSERT(isolate);
-  return isolate->live_ports() > 0;
+  return isolate->message_handler()->HasLivePorts();
 }
 
 
 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);
 }
 
 
 DART_EXPORT bool Dart_PostIntArray(Dart_Port port_id,
@@ skipping 17 matching lines @@
   const Object& object = Object::Handle(Api::UnwrapHandle(handle));
   uint8_t* data = NULL;
   SnapshotWriter writer(Snapshot::kMessage, &data, &allocator);
   writer.WriteObject(object.raw());
   writer.FinalizeBuffer();
   return PortMap::PostMessage(new Message(
       port_id, Message::kIllegalPort, data, Message::kNormalPriority));
 }
 
 
+DART_EXPORT Dart_Port Dart_NewNativePort(const char* name,
+                                         Dart_NativeMessageHandler handler,
+                                         bool handle_concurrently) {
+  if (name == NULL) {
+    name = "<UnnamedNativePort>";
+  }
+  if (handler == NULL) {
+    OS::PrintErr("%s expects argument 'handler' to be non-null.", CURRENT_FUNC);
+    return kIllegalPort;
+  }
+  // Start the native port without a current isolate.
+  IsolateSaver saver(Isolate::Current());
+  Isolate::SetCurrent(NULL);
+
+  NativeMessageHandler* nmh = new NativeMessageHandler(name, handler);
+  Dart_Port port_id = PortMap::CreatePort(nmh);
+  nmh->StartWorker();
+  return port_id;
+}
+
+
+DART_EXPORT bool Dart_CloseNativePort(Dart_Port native_port_id) {
+  // Close the native port without a current isolate.
+  IsolateSaver saver(Isolate::Current());
+  Isolate::SetCurrent(NULL);
+
+  // TODO(turnidge): Check that the port is native before trying to close.
+  return PortMap::ClosePort(native_port_id);
+}
+
+
 DART_EXPORT Dart_Handle Dart_NewSendPort(Dart_Port port_id) {
   Isolate* isolate = Isolate::Current();
   DARTSCOPE(isolate);
   const String& class_name = String::Handle(String::NewSymbol("SendPortImpl"));
   const String& function_name = String::Handle(String::NewSymbol("_create"));
   const int kNumArguments = 1;
   const Array& kNoArgumentNames = Array::Handle();
   // TODO(turnidge): Consider adding a helper function to make
   // function resolution by class name and function name more concise.
   const Function& function = Function::Handle(
@@ skipping 1736 matching lines @@
     }
     delete debug_region;
   } else {
     *buffer = NULL;
     *buffer_size = 0;
   }
 }
 
 
 }  // namespace dart