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

runtime/lib/isolate.dart

 // 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.
 
 class ReceivePortFactory {
   factory ReceivePort() {
     return new ReceivePortImpl();
   }
 
   factory ReceivePort.singleShot() {
     return new ReceivePortSingleShotImpl();
   }
 }
 
 
 class ReceivePortImpl implements ReceivePort {
   /*--- public interface ---*/
   factory ReceivePortImpl() native "ReceivePortImpl_factory";
 
   receive(void onMessage(var message, SendPort replyTo)) {
+    _numLivePorts++;

[siva, 2011/11/24 00:52:31]

If I call receive multiple times on the same receive port then will I end up
with my numLivePorts being off.
e.g:
port.receive(handler1);
port.receive(handler2);
port.receive(null);

Maybe you should increment only if _onMessage is null and decrement if
_onMessage is set to null

[turnidge, 2011/11/29 01:01:31]

I redid the change so that isolate.dart doesn't need to change.  Instead I keep
track of the live ports on the C++ side.  I have also changed the definition of
"live" from "has a non-null handler" to "has a ReceivePort created for it".  I
did this because of an offline discussion about what the meaning of "null" for a
handler should be.

     _onMessage = onMessage;
   }
 
   close() {
     _portMap.remove(_id);
     _closeInternal(_id);
+    _numLivePorts--;
   }
 
   SendPort toSendPort() {
     return new SendPortImpl(_id);
   }
 
   /**** Internal implementation details ****/
   // Called from the VM to create a new ReceivePort instance.
-  static ReceivePortImpl create_(int id) {
+  static ReceivePortImpl _create(int id) {
     return new ReceivePortImpl._internal(id);
   }
   ReceivePortImpl._internal(int id) : _id = id {
     if (_portMap === null) {
       _portMap = new Map();
+      _numLivePorts = 0;
     }
     _portMap[id] = this;
   }
 
+  static int _getNumLivePorts() => _numLivePorts === null ? 0 : _numLivePorts;
+
   // Called from the VM to dispatch to the handler.
-  static void handleMessage_(int id, int replyId, var message) {
+  static void _handleMessage(int id, int replyId, var message) {
     assert(_portMap !== null);
     ReceivePort port = _portMap[id];
     SendPort replyTo = (replyId == 0) ? null : new SendPortImpl(replyId);
     (port._onMessage)(message, replyTo);
   }
 
   // Call into the VM to close the VM maintained mappings.
   static _closeInternal(int id) native "ReceivePortImpl_closeInternal";
 
   final int _id;
   var _onMessage;
 
   // id to ReceivePort mapping.
   static Map _portMap;
+
+  // The number of ReceivePorts which have called receive.
+  static int _numLivePorts;
 }
 
 
 class ReceivePortSingleShotImpl implements ReceivePort {
 
   ReceivePortSingleShotImpl() : _port = new ReceivePortImpl() { }
 
   void receive(void callback(var message, SendPort replyTo)) {
     _port.receive((var message, SendPort replyTo) {
       _port.close();
@@ skipping 41 matching lines @@
     return (other is SendPortImpl) && _id == other._id;
   }
 
   int hashCode() {
     return _id;
   }
 
   /*--- private implementation ---*/
   const SendPortImpl(int id) : _id = id;
 
-  // SendPortImpl.create_ is called from the VM when a new SendPort instance is
+  // SendPortImpl._create is called from the VM when a new SendPort instance is
   // needed by the VM code.
-  static SendPort create_(int id) {
+  static SendPort _create(int id) {
     return new SendPortImpl(id);
   }
 
   // Forward the implementation of sending messages to the VM. Only port ids
   // are being handed to the VM.
   static _sendInternal(int sendId, int replyId, var message)
       native "SendPortImpl_sendInternal_";
 
   final int _id;
 }
 
 
 class IsolateNatives {
   static Future<SendPort> spawn(Isolate isolate, bool isLight) {
     Completer<SendPort> completer = new Completer<SendPort>();
     SendPort port = _start(isolate, isLight);
     completer.complete(port);
     return completer.future;
   }
 
   // Starts a new isolate calling the run method on a new instance of the
   // remote class's type.
   // Returns the send port which is passed to the newly created isolate.
   // This method is being dispatched to from the public core library code.
   static SendPort _start(Isolate isolate, bool light)
       native "IsolateNatives_start";
 }