- Implement Isolate.pause and Isolate.resume.

runtime/lib/isolate_patch.dart

 // 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.
 
 import "dart:collection" show HashMap;
 
 patch class ReceivePort {
   /* patch */ factory ReceivePort() = _ReceivePortImpl;
 
   /* patch */ factory ReceivePort.fromRawReceivePort(RawReceivePort rawPort) =
       _ReceivePortImpl.fromRawReceivePort;
 }
 
 patch class Capability {
-  /* patch */ factory Capability() {
-    throw new UnimplementedError();
-  }
+  /* patch */ factory Capability() = _CapabilityImpl;

[Lasse Reichstein Nielsen, 2014/07/02 08:11:55]

Could you make the patch constructor native:
  /*patch*/ factory Capability() native "Capability_factory";
and avoid the _CapabilityImpl class?

[Ivan Posva, 2014/07/03 12:51:16]

Since I will need to implement hash code and equality, I prefer not to patch the
interface class.

 }
 
-class _CapabilityImpl {
+class _CapabilityImpl implements Capability {
   factory _CapabilityImpl() native "CapabilityImpl_factory";
 }
 
 patch class RawReceivePort {
   /**
    * Opens a long-lived port for receiving messages.
    *
    * A [RawReceivePort] is low level and does not work with [Zone]s. It
    * can not be paused. The data-handler must be set before the first
    * event is received.
@@ skipping 193 matching lines @@
 
   Isolate._self.handler = isolateStartHandler;
 }
 
 patch class Isolate {
   /* patch */ static Future<Isolate> spawn(
       void entryPoint(message), var message, { bool paused: false }) {
     // `paused` isn't handled yet.
     try {
       // The VM will invoke [_startIsolate] with entryPoint as argument.
-      SendPort controlPort = _spawnFunction(entryPoint);
+      List spawnData = _spawnFunction(entryPoint);
+      assert(spawnData.length == 3);
+      SendPort controlPort = spawnData[0];
       RawReceivePort readyPort = new RawReceivePort();
       controlPort.send([readyPort.sendPort, message]);
       Completer completer = new Completer<Isolate>.sync();
       readyPort.handler = (readyMessage) {
         assert(readyMessage == 'started');
         readyPort.close();
-        completer.complete(new Isolate(controlPort));
+        completer.complete(new Isolate(controlPort,
+                                       pauseCapability: spawnData[1],
+                                       terminateCapability: spawnData[2]));
       };
       return completer.future;
     } catch (e, st) {
       return new Future<Isolate>.error(e, st);
     };
   }
 
   /* patch */ static Future<Isolate> spawnUri(
       Uri uri, List<String> args, var message, { bool paused: false }) {
     // `paused` isn't handled yet.
     try {
       // The VM will invoke [_startIsolate] and not `main`.
-      SendPort controlPort = _spawnUri(uri.toString());
+      List spawnData = _spawnUri(uri.toString());
+      assert(spawnData.length == 3);
+      SendPort controlPort = spawnData[0];
       RawReceivePort readyPort = new RawReceivePort();
       controlPort.send([readyPort.sendPort, args, message]);
       Completer completer = new Completer<Isolate>.sync();
       readyPort.handler = (readyMessage) {
         assert(readyMessage == 'started');
         readyPort.close();
-        completer.complete(new Isolate(controlPort));
+        completer.complete(new Isolate(controlPort,
+                                       pauseCapability: spawnData[1],
+                                       terminateCapability: spawnData[2]));
       };
       return completer.future;
     } catch (e, st) {
       return new Future<Isolate>.error(e, st);
     };
     return completer.future;
   }
 
   static final RawReceivePort _self = _mainPort;
   static RawReceivePort get _mainPort native "Isolate_mainPort";
 
-  static SendPort _spawnFunction(Function topLevelFunction)
+  // TODO(iposva): Cleanup to have only one definition.
+  // These values need to be kept in sync with the class IsolateMessageHandler
+  // in vm/isolate.cc.
+  static const _PAUSE = 1;
+  static const _RESUME = 2;
+
+  static List _spawnFunction(Function topLevelFunction)
       native "Isolate_spawnFunction";
 
-  static SendPort _spawnUri(String uri) native "Isolate_spawnUri";
+  static List _spawnUri(String uri) native "Isolate_spawnUri";
+
+  static void _sendOOB(port, msg) native "Isolate_sendOOB";
 
   /* patch */ void _pause(Capability resumeCapability) {
-    throw new UnsupportedError("pause");
+    var msg = new List(4)
+        ..[0] = 0  // Make room for OOM message type.
+        ..[1] = _PAUSE
+        ..[2] = pauseCapability
+        ..[3] = resumeCapability;
+    _sendOOB(controlPort, msg);
   }
 
   /* patch */ void resume(Capability resumeCapability) {
-    throw new UnsupportedError("resume");
+    var msg = new List(4)
+        ..[0] = 0  // Make room for OOM message type.
+        ..[1] = _RESUME
+        ..[2] = pauseCapability
+        ..[3] = resumeCapability;
+    _sendOOB(controlPort, msg);
   }
 
   /* patch */ void addOnExitListener(SendPort responsePort) {
     throw new UnsupportedError("addOnExitListener");
   }
 
   /* patch */ void removeOnExitListener(SendPort responsePort) {
     throw new UnsupportedError("removeOnExitListener");
   }
 
@@ skipping 10 matching lines @@
   }
 
   /* patch */ void addErrorListener(SendPort port) {
     throw new UnsupportedError("addErrorListener");
   }
 
   /* patch */ void removeErrorListener(SendPort port) {
     throw new UnsupportedError("removeErrorListener");
   }
 }