- Implement Isolate.ping.

runtime/vm/message_handler.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_handler.h"
 
 #include "vm/dart.h"
 #include "vm/lockers.h"
 #include "vm/port.h"
 
@@ skipping 74 matching lines @@
   ASSERT(pool_ == NULL);
   pool_ = pool;
   start_callback_ = start_callback;
   end_callback_ = end_callback;
   callback_data_ = data;
   task_ = new MessageHandlerTask(this);
   pool_->Run(task_);
 }
 
 
-void MessageHandler::PostMessage(Message* message) {
+void MessageHandler::PostMessage(Message* message, bool before_events) {
   MonitorLocker ml(&monitor_);
   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"
               "\tdest:       %s\n"
               "\tdest_port:  %" Pd64 "\n",
               source_name, name(), message->dest_port());
   }
 
   Message::Priority saved_priority = message->priority();
   if (message->IsOOB()) {
-    oob_queue_->Enqueue(message);
+    oob_queue_->Enqueue(message, before_events);
   } else {
-    queue_->Enqueue(message);
+    queue_->Enqueue(message, before_events);
   }
   message = NULL;  // Do not access message.  May have been deleted.
 
   if (pool_ != NULL && task_ == NULL) {
     task_ = new MessageHandlerTask(this);
     pool_->Run(task_);
   }
 
   // Invoke any custom message notification.
   MessageNotify(saved_priority);
@@ skipping 181 matching lines @@
 
 void MessageHandler::decrement_live_ports() {
   MonitorLocker ml(&monitor_);
 #if defined(DEBUG)
   CheckAccess();
 #endif
   live_ports_--;
 }
 
 }  // namespace dart