Added API Dart_PostCMessage for posting a Dart_CMessage structure

runtime/vm/snapshot_test.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 "platform/assert.h"
 #include "vm/bigint_operations.h"
 #include "vm/class_finalizer.h"
 #include "vm/dart_api_impl.h"
 #include "vm/dart_api_state.h"
 #include "vm/snapshot.h"
@@ skipping 33 matching lines @@
 
 static void FreeDeserializedDartMessage(Dart_CMessage* cmessage) {
   for (int i = 0; i < cmessage->allocated_length; i++) {
     free(cmessage->allocated[i]);
   }
   free(cmessage->original_message - Snapshot::kHeaderSize);
   free(cmessage);
 }
 
 
+static void CompareDartCObjects(Dart_CObject* first, Dart_CObject* second) {
+  EXPECT_NE(first, second);
+  EXPECT_EQ(first->type, second->type);
+  switch (first->type) {
+    case Dart_CObject::kNull:
+      // Nothing more to compare.
+      break;
+    case Dart_CObject::kBool:
+      EXPECT_EQ(first->value.as_bool, second->value.as_bool);
+      break;
+    case Dart_CObject::kInt32:
+      EXPECT_EQ(first->value.as_int32, second->value.as_int32);
+      break;
+    case Dart_CObject::kDouble:
+      EXPECT_EQ(first->value.as_double, second->value.as_double);
+      break;
+    case Dart_CObject::kString:
+      EXPECT_STREQ(first->value.as_string, second->value.as_string);
+      break;
+    case Dart_CObject::kArray:
+      EXPECT_EQ(first->value.as_array.length, second->value.as_array.length);
+      for (int i = 0; i < first->value.as_array.length; i++) {
+        CompareDartCObjects(first->value.as_array.values[i],
+                            second->value.as_array.values[i]);
+      }
+      break;
+    default:
+      EXPECT(false);
+  }
+}
+
+
+static void CheckEncodeMessage(Dart_CMessage* cmessage) {
+  // Encode and decode the message.
+  uint8_t* again = Dart_EncodeMessage(cmessage, allocator);
+  // TODO(sgjesse): Get the length of the encoded message instead of
+  // 1000. The length is not currently used for decoding, so a large
+  // value works for testing.
+  Dart_CMessage* new_cmessage =
+      Dart_DecodeMessage(again + Snapshot::kHeaderSize, 1000, &allocator);
+
+  // Check that the two messages are the same.
+  CompareDartCObjects(cmessage->object, new_cmessage->object);
+  FreeDeserializedDartMessage(new_cmessage);
+}
+
 TEST_CASE(SerializeNull) {
   // Write snapshot with object content.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const Object& null_object = Object::Handle();
   writer.WriteObject(null_object.raw());
   writer.FinalizeBuffer();
 
   // Create a snapshot object using the buffer.
   const Snapshot* snapshot = Snapshot::SetupFromBuffer(buffer);
 
   // Read object back from the snapshot.
   SnapshotReader reader(snapshot, Isolate::Current());
   const Object& serialized_object = Object::Handle(reader.ReadObject());
   EXPECT(Equals(null_object, serialized_object));
 
   // Read object back from the snapshot into a C structure.
   Dart_CMessage* cmessage = Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_NOTNULL(cobject);
   EXPECT_EQ(Dart_CObject::kNull, cobject->type);
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeSmi1) {
   // Write snapshot with object content.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const Smi& smi = Smi::Handle(Smi::New(124));
   writer.WriteObject(smi.raw());
   writer.FinalizeBuffer();
 
   // Create a snapshot object using the buffer.
   const Snapshot* snapshot = Snapshot::SetupFromBuffer(buffer);
 
   // Read object back from the snapshot.
   SnapshotReader reader(snapshot, Isolate::Current());
   const Object& serialized_object = Object::Handle(reader.ReadObject());
   EXPECT(Equals(smi, serialized_object));
 
   // Read object back from the snapshot into a C structure.
   Dart_CMessage* cmessage = Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_NOTNULL(cobject);
   EXPECT_EQ(Dart_CObject::kInt32, cobject->type);
   EXPECT_EQ(smi.Value(), cobject->value.as_int32);
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeSmi2) {
   // Write snapshot with object content.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const Smi& smi = Smi::Handle(Smi::New(-1));
   writer.WriteObject(smi.raw());
   writer.FinalizeBuffer();
 
   // Create a snapshot object using the buffer.
   const Snapshot* snapshot = Snapshot::SetupFromBuffer(buffer);
 
   // Read object back from the snapshot.
   SnapshotReader reader(snapshot, Isolate::Current());
   const Object& serialized_object = Object::Handle(reader.ReadObject());
   EXPECT(Equals(smi, serialized_object));
 
   // Read object back from the snapshot into a C structure.
   Dart_CMessage* cmessage = Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_NOTNULL(cobject);
   EXPECT_EQ(Dart_CObject::kInt32, cobject->type);
   EXPECT_EQ(smi.Value(), cobject->value.as_int32);
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeDouble) {
   // Write snapshot with object content.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const Double& dbl = Double::Handle(Double::New(101.29));
   writer.WriteObject(dbl.raw());
   writer.FinalizeBuffer();
 
   // Create a snapshot object using the buffer.
   const Snapshot* snapshot = Snapshot::SetupFromBuffer(buffer);
 
   // Read object back from the snapshot.
   SnapshotReader reader(snapshot, Isolate::Current());
   const Object& serialized_object = Object::Handle(reader.ReadObject());
   EXPECT(Equals(dbl, serialized_object));
 
   // Read object back from the snapshot into a C structure.
   Dart_CMessage* cmessage = Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_NOTNULL(cobject);
   EXPECT_EQ(Dart_CObject::kDouble, cobject->type);
   EXPECT_EQ(dbl.value(), cobject->value.as_double);
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeBool) {
   // Write snapshot with object content.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const Bool& bool1 = Bool::Handle(Bool::True());
   const Bool& bool2 = Bool::Handle(Bool::False());
@@ skipping 24 matching lines @@
   USE(snapshot);
 
   // Read object back from the snapshot into a C structure.
   Dart_CMessage* cmessage = Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_NOTNULL(cobject);
   EXPECT_EQ(Dart_CObject::kBool, cobject->type);
   EXPECT_EQ(true, cobject->value.as_bool);
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeFalse) {
   // Write snapshot with false object.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const Bool& bl = Bool::Handle(Bool::False());
   writer.WriteObject(bl.raw());
   writer.FinalizeBuffer();
 
   // Create a snapshot object using the buffer.
   const Snapshot* snapshot = Snapshot::SetupFromBuffer(buffer);
   USE(snapshot);
 
   // Read object back from the snapshot into a C structure.
   Dart_CMessage* cmessage = Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_NOTNULL(cobject);
   EXPECT_EQ(Dart_CObject::kBool, cobject->type);
   EXPECT_EQ(false, cobject->value.as_bool);
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeBigint) {
   // Write snapshot with object content.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const Bigint& bigint = Bigint::Handle(Bigint::New(0xfffffffffLL));
   writer.WriteObject(bigint.raw());
@@ skipping 90 matching lines @@
   serialized_str ^= reader.ReadObject();
   EXPECT(str.Equals(serialized_str));
 
   // Read object back from the snapshot into a C structure.
   Dart_CMessage* cmessage = Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_EQ(Dart_CObject::kString, cobject->type);
   EXPECT_STREQ(cstr, cobject->value.as_string);
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeArray) {
   // Write snapshot with object content.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const int kArrayLength = 10;
   Array& array = Array::Handle(Array::New(kArrayLength));
@@ skipping 19 matching lines @@
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_EQ(Dart_CObject::kArray, cobject->type);
   EXPECT_EQ(kArrayLength, cobject->value.as_array.length);
   for (int i = 0; i < kArrayLength; i++) {
     Dart_CObject* element = cobject->value.as_array.values[i];
     EXPECT_EQ(Dart_CObject::kInt32, element->type);
     EXPECT_EQ(i, element->value.as_int32);
   }
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeEmptyArray) {
   // Write snapshot with object content.
   uint8_t* buffer;
   SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
   const int kArrayLength = 0;
   Array& array = Array::Handle(Array::New(kArrayLength));
@@ skipping 10 matching lines @@
   EXPECT(array.Equals(serialized_array));
 
   // Read object back from the snapshot into a C structure.
   Dart_CMessage* cmessage = Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_EQ(Dart_CObject::kArray, cobject->type);
   EXPECT_EQ(kArrayLength, cobject->value.as_array.length);
   EXPECT(cobject->value.as_array.values == NULL);
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 TEST_CASE(SerializeScript) {
   const char* kScriptChars =
       "class A {\n"
       "  static bar() { return 42; }\n"
       "  static fly() { return 5; }\n"
       "}\n";
@@ skipping 282 matching lines @@
                                                writer.BytesWritten(),
                                                &allocator);
   Dart_CObject* cobject = cmessage->object;
   EXPECT_EQ(Dart_CObject::kArray, cobject->type);
   EXPECT_EQ(kArrayLength, cobject->value.as_array.length);
   for (int i = 0; i < kArrayLength; i++) {
     Dart_CObject* element = cobject->value.as_array.values[i];
     EXPECT_EQ(Dart_CObject::kInt32, element->type);
     EXPECT_EQ(i + 1, element->value.as_int32);
   }
+  CheckEncodeMessage(cmessage);
   FreeDeserializedDartMessage(cmessage);
 }
 
 
 // Helper function to call a top level Dart function, serialize the
 // result and deserialize the result into a Dart_CObject structure.
 static Dart_CMessage* GetDeserializedDartMessage(Dart_Handle lib,
                                                  const char* dart_function) {
   Dart_Handle result;
   result = Dart_InvokeStatic(lib,
@@ skipping 67 matching lines @@
 
       // Read object back from the snapshot into a C structure.
       Dart_CMessage* cmessage =
           Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                              writer.BytesWritten(),
                              &allocator);
       Dart_CObject* cobject = cmessage->object;
       EXPECT_NOTNULL(cobject);
       EXPECT_EQ(Dart_CObject::kInt32, cobject->type);
       EXPECT_EQ(42, cobject->value.as_int32);
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
     {
       uint8_t* buffer;
       SnapshotWriter writer(Snapshot::kMessage, &buffer, &allocator);
       String& str = String::Handle();
       str ^= Api::UnwrapHandle(string_result);
       writer.WriteObject(str.raw());
       writer.FinalizeBuffer();
 
       // Read object back from the snapshot into a C structure.
       Dart_CMessage* cmessage =
           Dart_DecodeMessage(buffer + Snapshot::kHeaderSize,
                              writer.BytesWritten(),
                              &allocator);
       Dart_CObject* cobject = cmessage->object;
       EXPECT_NOTNULL(cobject);
       EXPECT_EQ(Dart_CObject::kString, cobject->type);
       EXPECT_STREQ("Hello, world!", cobject->value.as_string);
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
   }
   Dart_ExitScope();
   Dart_ShutdownIsolate();
 }
 
 
 UNIT_TEST_CASE(DartGeneratedListMessages) {
   const int kArrayLength = 10;
@@ skipping 24 matching lines @@
   TestCase::CreateTestIsolate();
   Isolate* isolate = Isolate::Current();
   EXPECT(isolate != NULL);
   Dart_EnterScope();
 
   Dart_Handle lib = TestCase::LoadTestScript(kScriptChars, NULL);
   EXPECT_VALID(lib);
 
   {
     DARTSCOPE_NOCHECKS(isolate);
-
     {
       // Generate a list of nulls from Dart code.
       Dart_CMessage* cmessage = GetDeserializedDartMessage(lib, "getList");
       Dart_CObject* value = cmessage->object;
       EXPECT_NOTNULL(value);
       EXPECT_EQ(Dart_CObject::kArray, value->type);
       EXPECT_EQ(kArrayLength, value->value.as_array.length);
       for (int i = 0; i < kArrayLength; i++) {
         EXPECT_EQ(Dart_CObject::kNull, value->value.as_array.values[i]->type);
       }
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
     {
       // Generate a list of ints from Dart code.
       Dart_CMessage* cmessage = GetDeserializedDartMessage(lib, "getIntList");
       Dart_CObject* value = cmessage->object;
       EXPECT_NOTNULL(value);
       EXPECT_EQ(Dart_CObject::kArray, value->type);
       EXPECT_EQ(kArrayLength, value->value.as_array.length);
       for (int i = 0; i < kArrayLength; i++) {
         EXPECT_EQ(Dart_CObject::kInt32, value->value.as_array.values[i]->type);
         EXPECT_EQ(i, value->value.as_array.values[i]->value.as_int32);
       }
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
     {
       // Generate a list of strings from Dart code.
       Dart_CMessage* cmessage =
           GetDeserializedDartMessage(lib, "getStringList");
       Dart_CObject* value = cmessage->object;
       EXPECT_NOTNULL(value);
       EXPECT_EQ(Dart_CObject::kArray, value->type);
       EXPECT_EQ(kArrayLength, value->value.as_array.length);
       for (int i = 0; i < kArrayLength; i++) {
         EXPECT_EQ(Dart_CObject::kString, value->value.as_array.values[i]->type);
         char buffer[3];
         snprintf(buffer, sizeof(buffer), "%d", i);
         EXPECT_STREQ(buffer, value->value.as_array.values[i]->value.as_string);
       }
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
     {
       // Generate a list of objects of different types from Dart code.
       Dart_CMessage* cmessage = GetDeserializedDartMessage(lib, "getMixedList");
       Dart_CObject* value = cmessage->object;
       EXPECT_NOTNULL(value);
       EXPECT_EQ(Dart_CObject::kArray, value->type);
       EXPECT_EQ(kArrayLength, value->value.as_array.length);
 
       EXPECT_EQ(Dart_CObject::kInt32, value->value.as_array.values[0]->type);
       EXPECT_EQ(0, value->value.as_array.values[0]->value.as_int32);
       EXPECT_EQ(Dart_CObject::kString, value->value.as_array.values[1]->type);
       EXPECT_STREQ("1", value->value.as_array.values[1]->value.as_string);
       EXPECT_EQ(Dart_CObject::kDouble, value->value.as_array.values[2]->type);
       EXPECT_EQ(2.2, value->value.as_array.values[2]->value.as_double);
       EXPECT_EQ(Dart_CObject::kBool, value->value.as_array.values[3]->type);
       EXPECT_EQ(true, value->value.as_array.values[3]->value.as_bool);
 
       for (int i = 0; i < kArrayLength; i++) {
         if (i > 3) {
           EXPECT_EQ(Dart_CObject::kNull, value->value.as_array.values[i]->type);
         }
       }
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
   }
   Dart_ExitScope();
   Dart_ShutdownIsolate();
 }
 
 
 UNIT_TEST_CASE(DartGeneratedListMessagesWithBackref) {
   const int kArrayLength = 10;
@@ skipping 44 matching lines @@
       Dart_CObject* object = cmessage->object;
       EXPECT_NOTNULL(object);
       EXPECT_EQ(Dart_CObject::kArray, object->type);
       EXPECT_EQ(kArrayLength, object->value.as_array.length);
       for (int i = 0; i < kArrayLength; i++) {
         Dart_CObject* element = object->value.as_array.values[i];
         EXPECT_EQ(object->value.as_array.values[0], element);
         EXPECT_EQ(Dart_CObject::kString, element->type);
         EXPECT_STREQ("Hello, world!", element->value.as_string);
       }
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
     {
       // Generate a list of doubles from Dart code.
       Dart_CMessage* cmessage =
           GetDeserializedDartMessage(lib, "getDoubleList");
       Dart_CObject* object = cmessage->object;
       EXPECT_NOTNULL(object);
       EXPECT_EQ(Dart_CObject::kArray, object->type);
       EXPECT_EQ(kArrayLength, object->value.as_array.length);
       for (int i = 0; i < kArrayLength; i++) {
         Dart_CObject* element = object->value.as_array.values[i];
         EXPECT_EQ(object->value.as_array.values[0], element);
         EXPECT_EQ(Dart_CObject::kDouble, element->type);
         EXPECT_EQ(3.14, element->value.as_double);
       }
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
     {
       // Generate a list of objects of different types from Dart code.
       Dart_CMessage* cmessage = GetDeserializedDartMessage(lib, "getMixedList");
       Dart_CObject* object = cmessage->object;
       EXPECT_NOTNULL(object);
       EXPECT_EQ(Dart_CObject::kArray, object->type);
       EXPECT_EQ(kArrayLength, object->value.as_array.length);
       for (int i = 0; i < kArrayLength; i++) {
         Dart_CObject* element = object->value.as_array.values[i];
         if ((i % 2) == 0) {
           EXPECT_EQ(object->value.as_array.values[0], element);
           EXPECT_EQ(Dart_CObject::kString, element->type);
           EXPECT_STREQ("A", element->value.as_string);
         } else {
           EXPECT_EQ(object->value.as_array.values[1], element);
           EXPECT_EQ(Dart_CObject::kDouble, element->type);
           EXPECT_STREQ(2.72, element->value.as_double);
         }
       }
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
     {
       // Generate a list of objects of different types from Dart code.
       Dart_CMessage* cmessage =
           GetDeserializedDartMessage(lib, "getSelfRefList");
       Dart_CObject* object = cmessage->object;
       EXPECT_NOTNULL(object);
       EXPECT_EQ(Dart_CObject::kArray, object->type);
       EXPECT_EQ(kArrayLength, object->value.as_array.length);
       for (int i = 0; i < kArrayLength; i++) {
         Dart_CObject* element = object->value.as_array.values[i];
         EXPECT_EQ(Dart_CObject::kArray, element->type);
         EXPECT_EQ(object, element);
       }
+      CheckEncodeMessage(cmessage);
       FreeDeserializedDartMessage(cmessage);
     }
   }
   Dart_ExitScope();
   Dart_ShutdownIsolate();
 }
 
 #endif  // defined(TARGET_ARCH_IA32) || defined(TARGET_ARCH_X64).
 
 }  // namespace dart