Version 0.8.10.4

dart/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.
 
 patch class ReceivePort {
   /* patch */ factory ReceivePort() = _ReceivePortImpl;
 
   /* patch */ factory ReceivePort.fromRawReceivePort(RawReceivePort rawPort) =
       _ReceivePortImpl.fromRawReceivePort;
 }
@@ skipping 92 matching lines @@
   final int _id;
   Function _handler;
 
   // id to RawReceivePort mapping.
   static final Map _portMap = new HashMap();
 }
 
 
 class _SendPortImpl implements SendPort {
   /*--- public interface ---*/
-  void send(var message, [SendPort replyTo = null]) {
-    this._sendNow(message, replyTo);
-  }
-
-  void _sendNow(var message, SendPort replyTo) {
-    int replyId = (replyTo == null) ? 0 : replyTo._id;
-    _sendInternal(_id, replyId, message);
+  void send(var message) {
+    _sendInternal(_id, 0, message);
   }
 
   bool operator==(var other) {
     return (other is _SendPortImpl) && _id == other._id;
   }
 
   int get hashCode {
     const int MASK = 0x3FFFFFFF;
     int hash = _id;
     hash = (hash + ((hash & (MASK >> 10)) << 10)) & MASK;
     hash ^= (hash >> 6);
     hash = (hash + ((hash & (MASK >> 3)) << 3)) & MASK;
     hash ^= (hash >> 11);
     hash = (hash + ((hash & (MASK >> 15)) << 15)) & MASK;
     return hash;
   }
 
   /*--- private implementation ---*/
   const _SendPortImpl(int id) : _id = id;
 
   // _SendPortImpl._create is called from the VM when a new SendPort instance is
   // needed by the VM code.
   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.
+  // TODO(14731): Remove replyId argument.
   static _sendInternal(int sendId, int replyId, var message)
       native "SendPortImpl_sendInternal_";
 
   final int _id;
 }
 
 typedef _MainFunction();
 typedef _MainFunctionArgs(args);
 typedef _MainFunctionArgsMessage(args, message);
 
@@ skipping 13 matching lines @@
     // initial startup message has been received.
   }
 
   isolateStartHandler(message) {
     // We received the initial startup message. Ignore all further messages and
     // close the port which kept this isolate alive.
     Isolate._self.handler = ignoreHandler;
     keepAlivePort.close();
 
     SendPort replyTo = message[0];
-    // TODO(floitsch): don't send ok-message if we can't find the entry point.
-    replyTo.send("started");
+    if (replyTo != null) {
+      // TODO(floitsch): don't send ok-message if we can't find the entry point.
+      replyTo.send("started");
+    }
     if (isSpawnUri) {
       assert(message.length == 3);
       List<String> args = message[1];
       var isolateMessage = message[2];
       if (entryPoint is _MainFunctionArgsMessage) {
         entryPoint(args, isolateMessage);
       } else if (entryPoint is _MainFunctionArgs) {
         entryPoint(args);
       } else {
         entryPoint();
@@ skipping 50 matching lines @@
   }
 
   static final RawReceivePort _self = _mainPort;
   static RawReceivePort get _mainPort native "Isolate_mainPort";
 
   static SendPort _spawnFunction(Function topLevelFunction)
       native "Isolate_spawnFunction";
 
   static SendPort _spawnUri(String uri) native "Isolate_spawnUri";
 }