Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(458)

Unified Diff: runtime/lib/isolate.dart

Issue 10828410: Unify dart:isolate. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Fix mapping to dart:isolate. Created 8 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « lib/isolate/timer_hook.dart ('k') | runtime/lib/isolate_patch.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: runtime/lib/isolate.dart
diff --git a/runtime/lib/isolate.dart b/runtime/lib/isolate.dart
deleted file mode 100644
index 41c039cbe69b7caa79178f028a8266865dcdec13..0000000000000000000000000000000000000000
--- a/runtime/lib/isolate.dart
+++ /dev/null
@@ -1,130 +0,0 @@
-// 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.
-
-class _ReceivePortFactory {
- factory ReceivePort() {
- return new _ReceivePortImpl();
- }
-}
-
-
-class _ReceivePortImpl implements ReceivePort {
- /*--- public interface ---*/
- factory _ReceivePortImpl() native "ReceivePortImpl_factory";
-
- receive(void onMessage(var message, SendPort replyTo)) {
- _onMessage = onMessage;
- }
-
- close() {
- _portMap.remove(_id);
- _closeInternal(_id);
- }
-
- SendPort toSendPort() {
- return new _SendPortImpl(_id);
- }
-
- /**** Internal implementation details ****/
- // Called from the VM to create a new ReceivePort instance.
- static _ReceivePortImpl _get_or_create(int id) {
- if (_portMap !== null) {
- _ReceivePortImpl port = _portMap[id];
- if (port !== null) {
- return port;
- }
- }
- return new _ReceivePortImpl._internal(id);
- }
- _ReceivePortImpl._internal(int id) : _id = id {
- if (_portMap === null) {
- _portMap = new Map();
- }
- _portMap[id] = this;
- }
-
- // Called from the VM to dispatch to the handler.
- 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;
-}
-
-
-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);
- }
-
- Future call(var message) {
- final completer = new Completer();
- final port = new _ReceivePortImpl();
- send(message, port.toSendPort());
- port.receive((value, ignoreReplyTo) {
- port.close();
- if (value is Exception) {
- completer.completeException(value);
- } else {
- completer.complete(value);
- }
- });
- return completer.future;
- }
-
- bool operator==(var other) {
- 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
- // 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.
- static _sendInternal(int sendId, int replyId, var message)
- native "SendPortImpl_sendInternal_";
-
- final int _id;
-}
-
-_getPortInternal() native "isolate_getPortInternal";
-
-ReceivePort _portInternal;
-
-ReceivePort get _port() {
- if (_portInternal === null) {
- _portInternal = _getPortInternal();
- }
- return _portInternal;
-}
-
-_spawnFunction(void topLevelFunction()) native "isolate_spawnFunction";
-
-_spawnUri(String uri) native "isolate_spawnUri";
« no previous file with comments | « lib/isolate/timer_hook.dart ('k') | runtime/lib/isolate_patch.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698