Port async file operations to be using native ports instead or an isolate

runtime/vm/dart_api_message.cc

 // Copyright (c) 2012, 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/dart_api_message.h"
 #include "vm/object.h"
 #include "vm/object_store.h"
 
 namespace dart {
 
@@ skipping 164 matching lines @@
 
   ASSERT((class_header & kSmiTagMask) != 0);
   class_id = LookupInternalClass(class_header);
   switch (class_id) {
     case Object::kClassClass: {
       return NULL;
     }
     case Object::kTypeArgumentsClass: {
       // TODO(sjesse): Remove this when message serialization format is
       // updated (currently length is leaked).
-      AddBackwardReference(object_id, NULL);
+      Dart_CObject* value = &type_arguments_marker;
+      AddBackwardReference(object_id, value);
       Dart_CObject* length = ReadObject();
       ASSERT(length->type == Dart_CObject::kInt32);
       for (int i = 0; i < length->value.as_int32; i++) {
         Dart_CObject* type = ReadObject();
-        if (type != &dynamic_type_marker) return NULL;
+        if (type != &dynamic_type_marker) {
+          return NULL;
+        }
       }
-      return &type_arguments_marker;
+      return value;
     }
     case ObjectStore::kArrayClass: {
       intptr_t len = ReadSmiValue();
       Dart_CObject* value = AllocateDartCObjectArray(len);
       AddBackwardReference(object_id, value);
       // Skip type arguments.
       // TODO(sjesse): Remove this when message serialization format is
       // updated (currently type_arguments is leaked).
       Dart_CObject* type_arguments = ReadObject();
       if (type_arguments != &type_arguments_marker &&
@@ skipping 105 matching lines @@
     return ReadIndexedObject(header_value);
   }
   ASSERT(header_type == kInlined);
   return ReadInlinedObject(header_value);
 }
 
 
 Dart_CObject* ApiMessageReader::ReadObject() {
   int64_t value = Read<int64_t>();
   if ((value & kSmiTagMask) == 0) {
-    Dart_CObject* dart_value = AllocateDartCObjectInt32(value >> kSmiTagShift);
-    return dart_value;
+    int64_t untagged_value = value >> kSmiTagShift;
+    if (kMinInt32 <= untagged_value && untagged_value <= kMaxInt32) {
+      return AllocateDartCObjectInt32(untagged_value);
+    } else {
+      return AllocateDartCObjectInt64(untagged_value);
+    }
   }
   ASSERT((value <= kIntptrMax) && (value >= kIntptrMin));
   return ReadObjectImpl(value);
 }
 
 
 void ApiMessageReader::AddBackwardReference(intptr_t id, Dart_CObject* obj) {
   ASSERT((id - kMaxPredefinedObjectIds) == backward_references_.length());
   backward_references_.Add(obj);
 }
@@ skipping 204 matching lines @@
 }
 
 
 void ApiMessageWriter::WriteCMessage(Dart_CObject* object) {
   WriteCObject(object);
   UnmarkAllCObjects(object);
   FinalizeBuffer();
 }
 
 }  // namespace dart