Index: compiler/lib/implementation/isolate_serialization.dart |
diff --git a/compiler/lib/implementation/isolate_serialization.dart b/compiler/lib/implementation/isolate_serialization.dart |
deleted file mode 100644 |
index 0aadcfa2eaf1df5672e32a5232ec1345c6e2f64b..0000000000000000000000000000000000000000 |
--- a/compiler/lib/implementation/isolate_serialization.dart |
+++ /dev/null |
@@ -1,261 +0,0 @@ |
-// 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 MessageTraverser { |
- static bool isPrimitive(x) { |
- return (x === null) || (x is String) || (x is num) || (x is bool); |
- } |
- |
- MessageTraverser(); |
- |
- traverse(var x) { |
- if (isPrimitive(x)) return visitPrimitive(x); |
- _taggedObjects = new List(); |
- var result; |
- try { |
- result = _dispatch(x); |
- } finally { |
- _cleanup(); |
- } |
- return result; |
- } |
- |
- void _cleanup() { |
- int len = _taggedObjects.length; |
- for (int i = 0; i < len; i++) { |
- _clearAttachedInfo(_taggedObjects[i]); |
- } |
- _taggedObjects = null; |
- } |
- |
- void _attachInfo(var o, var info) { |
- _taggedObjects.add(o); |
- _setAttachedInfo(o, info); |
- } |
- |
- _getInfo(var o) { |
- return _getAttachedInfo(o); |
- } |
- |
- _dispatch(var x) { |
- if (isPrimitive(x)) return visitPrimitive(x); |
- if (x is List) return visitList(x); |
- if (x is Map) return visitMap(x); |
- if (x is SendPortImpl) return visitSendPort(x); |
- if (x is ReceivePortImpl) return visitReceivePort(x); |
- if (x is ReceivePortSingleShotImpl) return visitReceivePortSingleShot(x); |
- // TODO(floitsch): make this a real exception. (which one)? |
- throw new Exception("Message serialization: Illegal value $x passed"); |
- } |
- |
- abstract visitPrimitive(x); |
- abstract visitList(List x); |
- abstract visitMap(Map x); |
- abstract visitSendPort(SendPortImpl x); |
- abstract visitReceivePort(ReceivePortImpl x); |
- abstract visitReceivePortSingleShot(ReceivePortSingleShotImpl x); |
- |
- List _taggedObjects; |
- |
- _clearAttachedInfo(var obj) native; |
- _setAttachedInfo(var o, var info) native; |
- _getAttachedInfo(var o) native; |
-} |
- |
-class Copier extends MessageTraverser { |
- Copier() : super(); |
- |
- visitPrimitive(x) => x; |
- |
- List visitList(List list) { |
- List copy = _getInfo(list); |
- if (copy !== null) return copy; |
- |
- int len = list.length; |
- // TODO(floitsch): we loose the generic type of the List. |
- copy = new List(len); |
- _attachInfo(list, copy); |
- for (int i = 0; i < len; i++) { |
- copy[i] = _dispatch(list[i]); |
- } |
- return copy; |
- } |
- |
- Map visitMap(Map map) { |
- Map copy = _getInfo(map); |
- if (copy !== null) return copy; |
- |
- // TODO(floitsch): we loose the generic type of the map. |
- copy = new Map(); |
- _attachInfo(map, copy); |
- map.forEach((key, val) { |
- copy[_dispatch(key)] = _dispatch(val); |
- }); |
- return copy; |
- } |
- |
- SendPort visitSendPort(SendPortImpl port) { |
- return new SendPortImpl(port._workerId, |
- port._isolateId, |
- port._receivePortId); |
- } |
- |
- SendPort visitReceivePort(ReceivePortImpl port) { |
- return port._toNewSendPort(); |
- } |
- |
- SendPort visitReceivePortSingleShot(ReceivePortSingleShotImpl port) { |
- return port._toNewSendPort(); |
- } |
-} |
- |
-class Serializer extends MessageTraverser { |
- Serializer() : super(); |
- |
- visitPrimitive(x) => x; |
- |
- visitList(List list) { |
- int copyId = _getInfo(list); |
- if (copyId !== null) return _makeRef(copyId); |
- |
- int id = _nextFreeRefId++; |
- _attachInfo(list, id); |
- var jsArray = _serializeDartListIntoNewJsArray(list); |
- // TODO(floitsch): we are losing the generic type. |
- return _dartListToJsArrayNoCopy(['list', id, jsArray]); |
- } |
- |
- visitMap(Map map) { |
- int copyId = _getInfo(map); |
- if (copyId !== null) return _makeRef(copyId); |
- |
- int id = _nextFreeRefId++; |
- _attachInfo(map, id); |
- var keys = _serializeDartListIntoNewJsArray(map.getKeys()); |
- var values = _serializeDartListIntoNewJsArray(map.getValues()); |
- // TODO(floitsch): we are losing the generic type. |
- return _dartListToJsArrayNoCopy(['map', id, keys, values]); |
- } |
- |
- visitSendPort(SendPortImpl port) { |
- return _dartListToJsArrayNoCopy(['sendport', |
- port._workerId, |
- port._isolateId, |
- port._receivePortId]); |
- } |
- |
- visitReceivePort(ReceivePortImpl port) { |
- return visitSendPort(port.toSendPort());; |
- } |
- |
- visitReceivePortSingleShot(ReceivePortSingleShotImpl port) { |
- return visitSendPort(port.toSendPort()); |
- } |
- |
- _serializeDartListIntoNewJsArray(List list) { |
- int len = list.length; |
- var jsArray = _newJsArray(len); |
- for (int i = 0; i < len; i++) { |
- _jsArrayIndexSet(jsArray, i, _dispatch(list[i])); |
- } |
- return jsArray; |
- } |
- |
- _makeRef(int id) { |
- return _dartListToJsArrayNoCopy(['ref', id]); |
- } |
- |
- int _nextFreeRefId = 0; |
- |
- static _newJsArray(int len) native; |
- static _jsArrayIndexSet(jsArray, int index, val) native; |
- static _dartListToJsArrayNoCopy(List list) native; |
-} |
- |
-class Deserializer { |
- Deserializer(); |
- |
- static bool isPrimitive(x) { |
- return (x === null) || (x is String) || (x is num) || (x is bool); |
- } |
- |
- deserialize(x) { |
- if (isPrimitive(x)) return x; |
- // TODO(floitsch): this should be new HashMap<int, var|Dynamic>() |
- _deserialized = new HashMap(); |
- return _deserializeHelper(x); |
- } |
- |
- _deserializeHelper(x) { |
- if (isPrimitive(x)) return x; |
- assert(_isJsArray(x)); |
- switch (_jsArrayIndex(x, 0)) { |
- case 'ref': return _deserializeRef(x); |
- case 'list': return _deserializeList(x); |
- case 'map': return _deserializeMap(x); |
- case 'sendport': return _deserializeSendPort(x); |
- // TODO(floitsch): Use real exception (which one?). |
- default: throw "Unexpected serialized object"; |
- } |
- } |
- |
- _deserializeRef(x) { |
- int id = _jsArrayIndex(x, 1); |
- var result = _deserialized[id]; |
- assert(result !== null); |
- return result; |
- } |
- |
- List _deserializeList(x) { |
- int id = _jsArrayIndex(x, 1); |
- var jsArray = _jsArrayIndex(x, 2); |
- assert(_isJsArray(jsArray)); |
- List dartList = _jsArrayToDartListNoCopy(jsArray); |
- _deserialized[id] = dartList; |
- int len = dartList.length; |
- for (int i = 0; i < len; i++) { |
- dartList[i] = _deserializeHelper(dartList[i]); |
- } |
- return dartList; |
- } |
- |
- Map _deserializeMap(x) { |
- Map result = new Map(); |
- int id = _jsArrayIndex(x, 1); |
- _deserialized[id] = result; |
- var keys = _jsArrayIndex(x, 2); |
- var values = _jsArrayIndex(x, 3); |
- assert(_isJsArray(keys)); |
- assert(_isJsArray(values)); |
- int len = _jsArrayLength(keys); |
- assert(len == _jsArrayLength(values)); |
- for (int i = 0; i < len; i++) { |
- var key = _deserializeHelper(_jsArrayIndex(keys, i)); |
- var value = _deserializeHelper(_jsArrayIndex(values, i)); |
- result[key] = value; |
- } |
- return result; |
- } |
- |
- SendPort _deserializeSendPort(x) { |
- int workerId = _jsArrayIndex(x, 1); |
- int isolateId = _jsArrayIndex(x, 2); |
- int receivePortId = _jsArrayIndex(x, 3); |
- return new SendPortImpl(workerId, isolateId, receivePortId); |
- } |
- |
- List _jsArrayToDartListNoCopy(a) { |
- // We rely on the fact that Dart-lists are directly mapped to Js-arrays. |
- // TODO(floitsch): can we do better here? |
- assert(a is List); |
- return a; |
- } |
- |
- // TODO(floitsch): this should by Map<int, var> or Map<int, Dynamic>. |
- Map _deserialized; |
- |
- static bool _isJsArray(x) native; |
- static _jsArrayIndex(x, int index) native; |
- static int _jsArrayLength(x) native; |
-} |