VM: [Kernel] Fix bootstraping when Kernel isolate is used.

runtime/vm/dart_api_impl_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 "bin/builtin.h"
 #include "vm/compiler.h"
 #include "include/dart_api.h"
 #include "include/dart_mirrors_api.h"
 #include "include/dart_native_api.h"
 #include "include/dart_tools_api.h"
@@ skipping 7130 matching lines @@
   url = NewString("lib.dart");
   source = NewString(kLibraryChars);
   Dart_LoadLibrary(url, Dart_Null(), source, 0, 0);
   Dart_FinalizeLoading(false);
 
   result = Dart_Invoke(result, NewString("main"), 0, NULL);
   EXPECT_VALID(result);
 }
 
 
-void NewNativePort_send123(Dart_Port dest_port_id, Dart_CObject* message) {
+void NewNativePort_send123(Dart_Port dest_port_id,
+                           Dart_CObject* message,
+                           void* peer) {
   // Gets a send port message.
   EXPECT_NOTNULL(message);
   EXPECT_EQ(Dart_CObject_kArray, message->type);
   EXPECT_EQ(Dart_CObject_kSendPort, message->value.as_array.values[0]->type);
 
+  // Check peer validity.
+  EXPECT_NOTNULL(peer);
+  EXPECT_EQ(0xDEADBEEF, *static_cast<intptr_t*>(peer));
+  *static_cast<intptr_t*>(peer) = 123;
+
   // Post integer value.
   Dart_CObject* response =
       reinterpret_cast<Dart_CObject*>(Dart_ScopeAllocate(sizeof(Dart_CObject)));
   response->type = Dart_CObject_kInt32;
   response->value.as_int32 = 123;
   Dart_PostCObject(message->value.as_array.values[0]->value.as_send_port.id,
                    response);
 }
 
 
-void NewNativePort_send321(Dart_Port dest_port_id, Dart_CObject* message) {
+void NewNativePort_send321(Dart_Port dest_port_id,
+                           Dart_CObject* message,
+                           void* peer) {
   // Gets a null message.
   EXPECT_NOTNULL(message);
   EXPECT_EQ(Dart_CObject_kArray, message->type);
   EXPECT_EQ(Dart_CObject_kSendPort, message->value.as_array.values[0]->type);
 
+  // Check peer validity.
+  EXPECT_NOTNULL(peer);
+  EXPECT_EQ(0xDEADBEEF, *static_cast<intptr_t*>(peer));
+  *static_cast<intptr_t*>(peer) = 321;
+
   // Post integer value.
   Dart_CObject* response =
       reinterpret_cast<Dart_CObject*>(Dart_ScopeAllocate(sizeof(Dart_CObject)));
   response->type = Dart_CObject_kInt32;
   response->value.as_int32 = 321;
   Dart_PostCObject(message->value.as_array.values[0]->value.as_send_port.id,
                    response);
 }
 
 
 TEST_CASE(IllegalNewSendPort) {
   Dart_Handle error = Dart_NewSendPort(ILLEGAL_PORT);
   EXPECT(Dart_IsError(error));
   EXPECT(Dart_IsApiError(error));
 }
 
 
 TEST_CASE(IllegalPost) {
   Dart_Handle message = Dart_True();
   bool success = Dart_Post(ILLEGAL_PORT, message);
   EXPECT(!success);
 }
 
 
 UNIT_TEST_CASE(NewNativePort) {
   // Create a port with a bogus handler.
-  Dart_Port error_port = Dart_NewNativePort("Foo", NULL, true);
+  Dart_Port error_port = Dart_NewNativePort("Foo", NULL, true, NULL);
   EXPECT_EQ(ILLEGAL_PORT, error_port);
 
+  intptr_t peer1 = 0xDEADBEEF;
   // Create the port w/o a current isolate, just to make sure that works.
   Dart_Port port_id1 =
-      Dart_NewNativePort("Port123", NewNativePort_send123, true);
+      Dart_NewNativePort("Port123", NewNativePort_send123, true, &peer1);
 
   TestIsolateScope __test_isolate__;
   const char* kScriptChars =
       "import 'dart:isolate';\n"
       "void callPort(SendPort port) {\n"
       "  var receivePort = new RawReceivePort();\n"
       "  var replyPort = receivePort.sendPort;\n"
       "  port.send([replyPort]);\n"
       "  receivePort.handler = (message) {\n"
       "    receivePort.close();\n"
       "    throw new Exception(message);\n"
       "  };\n"
       "}\n";
   Dart_Handle lib = TestCase::LoadTestScript(kScriptChars, NULL);
   Dart_EnterScope();
 
   // Create a port w/ a current isolate, to make sure that works too.
+  intptr_t peer2 = 0xDEADBEEF;
   Dart_Port port_id2 =
-      Dart_NewNativePort("Port321", NewNativePort_send321, true);
+      Dart_NewNativePort("Port321", NewNativePort_send321, true, &peer2);
 
   Dart_Handle send_port1 = Dart_NewSendPort(port_id1);
   EXPECT_VALID(send_port1);
   Dart_Handle send_port2 = Dart_NewSendPort(port_id2);
   EXPECT_VALID(send_port2);
 
   // Test first port.
   Dart_Handle dart_args[1];
   dart_args[0] = send_port1;
   Dart_Handle result = Dart_Invoke(lib, NewString("callPort"), 1, dart_args);
   EXPECT_VALID(result);
   result = Dart_RunLoop();
   EXPECT(Dart_IsError(result));
   EXPECT(Dart_ErrorHasException(result));
   EXPECT_SUBSTRING("Exception: 123\n", Dart_GetError(result));
+  EXPECT_EQ(123, peer1);
 
   // result second port.
   dart_args[0] = send_port2;
   result = Dart_Invoke(lib, NewString("callPort"), 1, dart_args);
   EXPECT_VALID(result);
   result = Dart_RunLoop();
   EXPECT(Dart_IsError(result));
   EXPECT(Dart_ErrorHasException(result));
   EXPECT_SUBSTRING("Exception: 321\n", Dart_GetError(result));
+  EXPECT_EQ(321, peer2);
 
   Dart_ExitScope();
 
   // Delete the native ports.
   EXPECT(Dart_CloseNativePort(port_id1));
   EXPECT(Dart_CloseNativePort(port_id2));
 }
 
 
 void NewNativePort_sendInteger123(Dart_Port dest_port_id,
-                                  Dart_CObject* message) {
+                                  Dart_CObject* message,
+                                  void* peer) {
   // Gets a send port message.
   EXPECT_NOTNULL(message);
   EXPECT_EQ(Dart_CObject_kArray, message->type);
   EXPECT_EQ(Dart_CObject_kSendPort, message->value.as_array.values[0]->type);
 
   // Post integer value.
   Dart_PostInteger(message->value.as_array.values[0]->value.as_send_port.id,
                    123);
 }
 
 
 void NewNativePort_sendInteger321(Dart_Port dest_port_id,
-                                  Dart_CObject* message) {
+                                  Dart_CObject* message,
+                                  void* peer) {
   // Gets a null message.
   EXPECT_NOTNULL(message);
   EXPECT_EQ(Dart_CObject_kArray, message->type);
   EXPECT_EQ(Dart_CObject_kSendPort, message->value.as_array.values[0]->type);
 
   // Post integer value.
   Dart_PostInteger(message->value.as_array.values[0]->value.as_send_port.id,
                    321);
 }
 
 
 TEST_CASE(NativePortPostInteger) {
   const char* kScriptChars =
       "import 'dart:isolate';\n"
       "void callPort(SendPort port) {\n"
       "  var receivePort = new RawReceivePort();\n"
       "  var replyPort = receivePort.sendPort;\n"
       "  port.send([replyPort]);\n"
       "  receivePort.handler = (message) {\n"
       "    receivePort.close();\n"
       "    throw new Exception(message);\n"
       "  };\n"
       "}\n";
   Dart_Handle lib = TestCase::LoadTestScript(kScriptChars, NULL);
   Dart_EnterScope();
 
   Dart_Port port_id1 =
-      Dart_NewNativePort("Port123", NewNativePort_sendInteger123, true);
+      Dart_NewNativePort("Port123", NewNativePort_sendInteger123, true, NULL);
   Dart_Port port_id2 =
-      Dart_NewNativePort("Port321", NewNativePort_sendInteger321, true);
+      Dart_NewNativePort("Port321", NewNativePort_sendInteger321, true, NULL);
 
   Dart_Handle send_port1 = Dart_NewSendPort(port_id1);
   EXPECT_VALID(send_port1);
   Dart_Handle send_port2 = Dart_NewSendPort(port_id2);
   EXPECT_VALID(send_port2);
 
   // Test first port.
   Dart_Handle dart_args[1];
   dart_args[0] = send_port1;
   Dart_Handle result = Dart_Invoke(lib, NewString("callPort"), 1, dart_args);
@@ skipping 14 matching lines @@
 
   Dart_ExitScope();
 
   // Delete the native ports.
   EXPECT(Dart_CloseNativePort(port_id1));
   EXPECT(Dart_CloseNativePort(port_id2));
 }
 
 
 void NewNativePort_nativeReceiveNull(Dart_Port dest_port_id,
-                                     Dart_CObject* message) {
+                                     Dart_CObject* message,
+                                     void* peer) {
   EXPECT_NOTNULL(message);
 
   if ((message->type == Dart_CObject_kArray) &&
       (message->value.as_array.values[0]->type == Dart_CObject_kSendPort)) {
     // Post integer value.
     Dart_PostInteger(message->value.as_array.values[0]->value.as_send_port.id,
                      123);
   } else {
     EXPECT_EQ(message->type, Dart_CObject_kNull);
   }
 }
 
 
 TEST_CASE(NativePortReceiveNull) {
   const char* kScriptChars =
       "import 'dart:isolate';\n"
       "void callPort(SendPort port) {\n"
       "  var receivePort = new RawReceivePort();\n"
       "  var replyPort = receivePort.sendPort;\n"
       "  port.send(null);\n"
       "  port.send([replyPort]);\n"
       "  receivePort.handler = (message) {\n"
       "    receivePort.close();\n"
       "    throw new Exception(message);\n"
       "  };\n"
       "}\n";
   Dart_Handle lib = TestCase::LoadTestScript(kScriptChars, NULL);
   Dart_EnterScope();
 
-  Dart_Port port_id1 =
-      Dart_NewNativePort("PortNull", NewNativePort_nativeReceiveNull, true);
+  Dart_Port port_id1 = Dart_NewNativePort(
+      "PortNull", NewNativePort_nativeReceiveNull, true, NULL);
   Dart_Handle send_port1 = Dart_NewSendPort(port_id1);
   EXPECT_VALID(send_port1);
 
   // Test first port.
   Dart_Handle dart_args[1];
   dart_args[0] = send_port1;
   Dart_Handle result = Dart_Invoke(lib, NewString("callPort"), 1, dart_args);
   EXPECT_VALID(result);
   result = Dart_RunLoop();
   EXPECT(Dart_IsError(result));
   EXPECT(Dart_ErrorHasException(result));
   EXPECT_SUBSTRING("Exception: 123\n", Dart_GetError(result));
 
   Dart_ExitScope();
 
   // Delete the native ports.
   EXPECT(Dart_CloseNativePort(port_id1));
 }
 
 
 void NewNativePort_nativeReceiveInteger(Dart_Port dest_port_id,
-                                        Dart_CObject* message) {
+                                        Dart_CObject* message,
+                                        void* peer) {
   EXPECT_NOTNULL(message);
 
   if ((message->type == Dart_CObject_kArray) &&
       (message->value.as_array.values[0]->type == Dart_CObject_kSendPort)) {
     // Post integer value.
     Dart_PostInteger(message->value.as_array.values[0]->value.as_send_port.id,
                      123);
   } else {
     EXPECT_EQ(message->type, Dart_CObject_kInt32);
     EXPECT_EQ(message->value.as_int32, 321);
@@ skipping 10 matching lines @@
       "  port.send(321);\n"
       "  port.send([replyPort]);\n"
       "  receivePort.handler = (message) {\n"
       "    receivePort.close();\n"
       "    throw new Exception(message);\n"
       "  };\n"
       "}\n";
   Dart_Handle lib = TestCase::LoadTestScript(kScriptChars, NULL);
   Dart_EnterScope();
 
-  Dart_Port port_id1 =
-      Dart_NewNativePort("PortNull", NewNativePort_nativeReceiveInteger, true);
+  Dart_Port port_id1 = Dart_NewNativePort(
+      "PortNull", NewNativePort_nativeReceiveInteger, true, NULL);
   Dart_Handle send_port1 = Dart_NewSendPort(port_id1);
   EXPECT_VALID(send_port1);
 
   // Test first port.
   Dart_Handle dart_args[1];
   dart_args[0] = send_port1;
   Dart_Handle result = Dart_Invoke(lib, NewString("callPort"), 1, dart_args);
   EXPECT_VALID(result);
   result = Dart_RunLoop();
   EXPECT(Dart_IsError(result));
@@ skipping 2477 matching lines @@
   EXPECT_VALID(result);
   result = Dart_FinalizeLoading(false);
   EXPECT_VALID(result);
   result = Dart_Invoke(lib, NewString("foozoo"), 0, NULL);
   EXPECT(Dart_IsError(result));
 }
 
 #endif  // !PRODUCT
 
 }  // namespace dart