Add a mid-sized integration test for the Dart Embedding Api which

runtime/vm/port_test.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/assert.h"
 #include "vm/message_queue.h"
 #include "vm/os.h"
 #include "vm/port.h"
 #include "vm/unit_test.h"
 
 namespace dart {
 
+// Provides private access to PortMap for testing.
+class PortMapTestPeer {
+ public:
+  static bool IsActivePort(Dart_Port port) {
+    MutexLocker ml(PortMap::mutex_);
+    return (PortMap::FindPort(port) >= 0);
+  }
+
+  static bool IsLivePort(Dart_Port port) {
+    MutexLocker ml(PortMap::mutex_);
+    intptr_t index = PortMap::FindPort(port);
+    if (index < 0) {
+      return false;
+    }
+    return PortMap::map_[index].live;
+  }
+};
+
 
 // Intercept the post message callback and just store a copy of the message.
 static const int kMaxSavedMsg = 80;
 static char saved_msg[kMaxSavedMsg];
 static bool MyPostMessageCallback(Dart_Isolate dest_isolate,
                                   Dart_Port dest_port,
                                   Dart_Port reply_port,
                                   Dart_Message dart_message) {
   const char* msg = reinterpret_cast<char*>(dart_message);
   OS::SNPrint(saved_msg, kMaxSavedMsg, "%s", msg);
@@ skipping 15 matching lines @@
   Dart_SetMessageCallbacks(&MyPostMessageCallback, &MyClosePortCallback);
   saved_port = 0;
   saved_msg[0] = '\0';
 }
 
 
 TEST_CASE(PortMap_CreateAndCloseOnePort) {
   InitPortMapTest();
   intptr_t port = PortMap::CreatePort();
   EXPECT_NE(0, port);
-  EXPECT(PortMap::IsActivePort(port));
+  EXPECT(PortMapTestPeer::IsActivePort(port));
 
   PortMap::ClosePort(port);
-  EXPECT(!PortMap::IsActivePort(port));
+  EXPECT(!PortMapTestPeer::IsActivePort(port));
 
   // Embedder was notified of port closure.
   EXPECT_EQ(port, saved_port);
 }
 
 
 TEST_CASE(PortMap_CreateAndCloseTwoPorts) {
   InitPortMapTest();
   Dart_Port port1 = PortMap::CreatePort();
   Dart_Port port2 = PortMap::CreatePort();
-  EXPECT(PortMap::IsActivePort(port1));
-  EXPECT(PortMap::IsActivePort(port2));
+  EXPECT(PortMapTestPeer::IsActivePort(port1));
+  EXPECT(PortMapTestPeer::IsActivePort(port2));
 
   // Uniqueness.
   EXPECT_NE(port1, port2);
 
   PortMap::ClosePort(port1);
-  EXPECT(!PortMap::IsActivePort(port1));
-  EXPECT(PortMap::IsActivePort(port2));
+  EXPECT(!PortMapTestPeer::IsActivePort(port1));
+  EXPECT(PortMapTestPeer::IsActivePort(port2));
   EXPECT_EQ(port1, saved_port);
 
   PortMap::ClosePort(port2);
-  EXPECT(!PortMap::IsActivePort(port1));
-  EXPECT(!PortMap::IsActivePort(port2));
+  EXPECT(!PortMapTestPeer::IsActivePort(port1));
+  EXPECT(!PortMapTestPeer::IsActivePort(port2));
   EXPECT_EQ(port2, saved_port);
 }
 
 
 TEST_CASE(PortMap_ClosePorts) {
   InitPortMapTest();
   Dart_Port port1 = PortMap::CreatePort();
   Dart_Port port2 = PortMap::CreatePort();
-  EXPECT(PortMap::IsActivePort(port1));
-  EXPECT(PortMap::IsActivePort(port2));
+  EXPECT(PortMapTestPeer::IsActivePort(port1));
+  EXPECT(PortMapTestPeer::IsActivePort(port2));
 
   // Close all ports at once.
   PortMap::ClosePorts();
-  EXPECT(!PortMap::IsActivePort(port1));
-  EXPECT(!PortMap::IsActivePort(port2));
+  EXPECT(!PortMapTestPeer::IsActivePort(port1));
+  EXPECT(!PortMapTestPeer::IsActivePort(port2));
 
   // Embedder is notified to close all ports as well.
   EXPECT_EQ(kCloseAllPorts, saved_port);
 }
 
 
 TEST_CASE(PortMap_CreateManyPorts) {
   InitPortMapTest();
   for (int i = 0; i < 32; i++) {
     Dart_Port port = PortMap::CreatePort();
-    EXPECT(PortMap::IsActivePort(port));
+    EXPECT(PortMapTestPeer::IsActivePort(port));
     PortMap::ClosePort(port);
-    EXPECT(!PortMap::IsActivePort(port));
+    EXPECT(!PortMapTestPeer::IsActivePort(port));
   }
 }
 
 
+TEST_CASE(PortMap_SetLive) {
+  InitPortMapTest();
+  intptr_t port = PortMap::CreatePort();
+  EXPECT_NE(0, port);
+  EXPECT(PortMapTestPeer::IsActivePort(port));
+  EXPECT(!PortMapTestPeer::IsLivePort(port));
+
+  PortMap::SetLive(port);
+  EXPECT(PortMapTestPeer::IsActivePort(port));
+  EXPECT(PortMapTestPeer::IsLivePort(port));
+
+  PortMap::ClosePort(port);
+  EXPECT(!PortMapTestPeer::IsActivePort(port));
+  EXPECT(!PortMapTestPeer::IsLivePort(port));
+
+  // Embedder was notified of port closure.
+  EXPECT_EQ(port, saved_port);
+}
+
+
 TEST_CASE(PortMap_PostMessage) {
   InitPortMapTest();
   Dart_Port port = PortMap::CreatePort();
   EXPECT(PortMap::PostMessage(
       port, 0, reinterpret_cast<Dart_Message>(strdup("msg"))));
 
   // Check that the post message callback was called.
   EXPECT_STREQ("msg", saved_msg);
   PortMap::ClosePorts();
 }
@@ skipping 107 matching lines @@
   // Give the spawned thread enough time to properly exit.
   Monitor* waiter = new Monitor();
   {
     MonitorLocker ml(waiter);
     ml.Wait(20);
   }
   delete waiter;
 }
 
 }  // namespace dart