Adds a special case for sending an int over a port with the native API.

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/object.h"
 #include "vm/object_store.h"
@@ skipping 114 matching lines @@
   Message::Priority saved_priority;
   bool task_running = true;
   {
     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"
-                "\tlen:        %" Pd "\n"
-                "\tsource:     %s\n"
-                "\tdest:       %s\n"
-                "\tdest_port:  %" Pd64 "\n",
-                message->len(), source_name, name(), message->dest_port());
+      if (message->type() == Message::kDataType) {
+        OS::Print("[>] Posting data message:\n"
+                  "\tlen:        %" Pd "\n"
+                  "\tsource:     %s\n"
+                  "\tdest:       %s\n"
+                  "\tdest_port:  %" Pd64 "\n",
+                  message->len(), source_name, name(), message->dest_port());
+      } else {
+        ASSERT(message->type() == Message::kIntegerType);
+        OS::Print("[>] Posting integer message:\n"
+                  "\tvalue:      %" Pd "\n"
+                  "\tsource:     %s\n"
+                  "\tdest:       %s\n"
+                  "\tdest_port:  %" Pd64 "\n",
+                  message->integer(), source_name, name(),
+                  message->dest_port());
+      }
     }
 
     saved_priority = message->priority();
     if (message->IsOOB()) {
       oob_queue_->Enqueue(message, before_events);
     } else {
       queue_->Enqueue(message, before_events);
     }
     message = NULL;  // Do not access message.  May have been deleted.
 
@@ skipping 31 matching lines @@
 
   // If isolate() returns NULL StartIsolateScope does nothing.
   StartIsolateScope start_isolate(isolate());
 
   MessageStatus max_status = kOK;
   Message::Priority min_priority = ((allow_normal_messages && !paused())
                                     ? Message::kNormalPriority
                                     : Message::kOOBPriority);
   Message* message = DequeueMessage(min_priority);
   while (message != NULL) {
-    intptr_t message_len = message->len();
     if (FLAG_trace_isolates) {
-      OS::Print("[<] Handling message:\n"
-                "\tlen:        %" Pd "\n"
-                "\thandler:    %s\n"
-                "\tport:       %" Pd64 "\n",
-                message_len, name(), message->dest_port());
+      if (message->type() == Message::kDataType) {
+        OS::Print("[<] Handling data message:\n"
+                  "\tlen:        %" Pd "\n"
+                  "\thandler:    %s\n"
+                  "\tport:       %" Pd64 "\n",
+                  message->len(), name(), message->dest_port());
+      } else {
+        ASSERT(message->type() == Message::kIntegerType);
+        OS::Print("[<] Handling integer message:\n"
+                  "\tvalue:      %" Pd "\n"
+                  "\thandler:    %s\n"
+                  "\tport:       %" Pd64 "\n",
+                  message->integer(), name(), message->dest_port());
+      }
     }
 
     // Release the monitor_ temporarily while we handle the message.
     // The monitor was acquired in MessageHandler::TaskCallback().
     monitor_.Exit();
     Message::Priority saved_priority = message->priority();
     Dart_Port saved_dest_port = message->dest_port();
     MessageStatus status = HandleMessage(message);
     if (status > max_status) {
       max_status = status;
     }
     message = NULL;  // May be deleted by now.
     monitor_.Enter();
     if (FLAG_trace_isolates) {
-      OS::Print("[.] Message handled (%s):\n"
-                "\tlen:        %" Pd "\n"
-                "\thandler:    %s\n"
-                "\tport:       %" Pd64 "\n",
-                MessageStatusString(status),
-                message_len, name(), saved_dest_port);
+      if (message->type() == Message::kDataType) {
+        OS::Print("[.] Data message handled (%s):\n"
+                  "\tlen:        %" Pd "\n"
+                  "\thandler:    %s\n"
+                  "\tport:       %" Pd64 "\n",
+                  MessageStatusString(status),
+                  message->len(), name(), saved_dest_port);
+      } else {
+        ASSERT(message->type() == Message::kIntegerType);
+        OS::Print("[.] Integer message handled (%s):\n"
+                  "\tvalue:      %" Pd "\n"
+                  "\thandler:    %s\n"
+                  "\tport:       %" Pd64 "\n",
+                  MessageStatusString(status),
+                  message->integer(), name(), saved_dest_port);
+      }
     }
     // If we are shutting down, do not process any more messages.
     if (status == kShutdown) {
       ClearOOBQueue();
       break;
     }
 
     // Some callers want to process only one normal message and then quit. At
     // the same time it is OK to process multiple OOB messages.
     if ((saved_priority == Message::kNormalPriority) &&
@@ skipping 242 matching lines @@
 
 
 void MessageHandler::AcquireQueues(AcquiredQueues* acquired_queues) {
   ASSERT(acquired_queues != NULL);
   // No double dipping.
   ASSERT(acquired_queues->handler_ == NULL);
   acquired_queues->Reset(this);
 }
 
 }  // namespace dart