Add support for native ports in the vm.

runtime/vm/message.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 "vm/message_queue.h"
+#include "vm/message.h"
 
 namespace dart {
 
+DECLARE_FLAG(bool, trace_isolates);
+
+
+MessageHandler::MessageHandler()
+    : live_ports_(0),
+      queue_(new MessageQueue()) {
+  ASSERT(queue_ != NULL);
+}
+
+
+MessageHandler::~MessageHandler() {
+  delete queue_;
+}
+
+
+const char* MessageHandler::name() const {
+  return "<unnamed>";
+}
+
+
+#if defined(DEBUG)
+void MessageHandler::CheckAccess() {
+  // By default there is no checking.
+}
+#endif
+
+
+void MessageHandler::MessageNotify(Message::Priority priority) {
+  // By default, there is no custom message notification.
+}
+
+
+void MessageHandler::PostMessage(Message* message) {
+  if (FLAG_trace_isolates) {
+    const char* source_name = "<native code>";
+    Isolate* source_isolate = Isolate::Current();
+    if (source_isolate) {
+      source_name = source_isolate->name();
+    }
+    OS::Print("[>] Posting message:\n"
+              "\tsource:     %s\n"
+              "\treply_port: %lld\n"
+              "\tdest:       %s\n"
+              "\tdest_port:  %lld\n",
+              source_name, message->reply_port(), name(), message->dest_port());
+  }
+
+  Message::Priority priority = message->priority();
+  queue()->Enqueue(message);
+  message = NULL;  // Do not access message.  May have been deleted.
+
+  // Invoke any custom message notification.
+  MessageNotify(priority);
+}
+
+
+void MessageHandler::ClosePort(Dart_Port port) {
+  queue()->Flush(port);
+}
+
+
+void MessageHandler::CloseAllPorts() {
+  queue()->FlushAll();
+}
+
+
 MessageQueue::MessageQueue() {
   for (int p = Message::kFirstPriority; p < Message::kNumPriorities; p++) {
     head_[p] = NULL;
     tail_[p] = NULL;
   }
 }
 
 
 MessageQueue::~MessageQueue() {
   // Ensure that all pending messages have been released.
@@ skipping 51 matching lines @@
 #endif  // DEBUG
       return result;
     }
   }
   return NULL;
 }
 
 
 Message* MessageQueue::Dequeue(int64_t millis) {
   ASSERT(millis >= 0);
-  MonitorLocker ml(&monitor_);
+  monitor_.Enter();
 
   Message* result = DequeueNoWaitHoldsLock();
   if (result == NULL) {
     // No message available at any priority.
-    ml.Wait(millis);
+    monitor_.Wait(millis);
     result = DequeueNoWaitHoldsLock();
   }
+
+  monitor_.Exit();
   return result;
 }
 
 
 void MessageQueue::Flush(Dart_Port port) {
-  MonitorLocker ml(&monitor_);
+  monitor_.Enter();

[Søren Gjesse, 2012/01/27 13:33:14]

In runtime/bin/thread.h we have a MonitorLocker which is not a stack resource.
We could move that to runtime/include/thread.h to share it. Of cause the
runtime/vm/thread.h MonitorLocker would have to be renamed then. Maybe its not
worth it.

[siva, 2012/01/28 00:21:05]

We should re-evaluate if MonitorLocker needs to be a stack resource maybe with
suitable asserts (isolate->long_jump_base() == NULL and something while throwing
exceptions to ensure we never throw exceptions from a block which has a
MutexLocker).

On 2012/01/27 13:33:14, Søren Gjesse wrote:

[turnidge, 2012/01/31 20:04:31]

I have partially addressed this by making StackResources work when there is no
currrent isolate.  See below.

[turnidge, 2012/01/31 20:04:31]

I have changed StackResource to function reasonably when there is no current
isolate.

On 2012/01/28 00:21:05, asiva wrote:

   for (int p = Message::kFirstPriority; p < Message::kNumPriorities; p++) {
     Message* cur = head_[p];
     Message* prev = NULL;
     while (cur != NULL) {
       Message* next = cur->next_;
       // If the message matches, then remove it from the queue and delete it.
       if (cur->dest_port() == port) {
         if (prev != NULL) {
           prev->next_ = next;
         } else {
           head_[p] = next;
         }
         delete cur;
       } else {
         // Move prev forward.
         prev = cur;
       }
       // Advance to the next message in the queue.
       cur = next;
     }
     tail_[p] = prev;
   }
+  monitor_.Exit();
 }
 
 
 void MessageQueue::FlushAll() {
   MonitorLocker ml(&monitor_);
   for (int p = Message::kFirstPriority; p < Message::kNumPriorities; p++) {
     Message* cur = head_[p];
     head_[p] = NULL;
     tail_[p] = NULL;
     while (cur != NULL) {
       Message* next = cur->next_;
       delete cur;
       cur = next;
     }
   }
 }
 
 
 }  // namespace dart