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

Unified Diff: lib/runtime/dart/_isolate_helper.js

Issue 1030063004: more care around generated names, fixes #60 #82 and #97 (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 9 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
Index: lib/runtime/dart/_isolate_helper.js
diff --git a/lib/runtime/dart/_isolate_helper.js b/lib/runtime/dart/_isolate_helper.js
index 629c83adc6b026dbf24b969722d37d8c6943f8da..6eff072f837935baf5ae69914b1630c9ad1e3a24 100644
--- a/lib/runtime/dart/_isolate_helper.js
+++ b/lib/runtime/dart/_isolate_helper.js
@@ -22,8 +22,8 @@ var _isolate_helper;
let _receivePort = Symbol('_receivePort');
let _id = Symbol('_id');
class _Serializer extends core.Object {
- _Serializer(opt$) {
- let serializeSendPorts = opt$ && 'serializeSendPorts' in opt$ ? opt$.serializeSendPorts : true;
+ _Serializer(opts) {
+ let serializeSendPorts = opts && 'serializeSendPorts' in opts ? opts.serializeSendPorts : true;
this.serializedObjectIds = new core.Map.identity();
this[_serializeSendPorts] = dart.as(serializeSendPorts, core.bool);
}
@@ -157,8 +157,8 @@ var _isolate_helper;
}
let _adjustSendPorts = Symbol('_adjustSendPorts');
class _Deserializer extends core.Object {
- _Deserializer(opt$) {
- let adjustSendPorts = opt$ && 'adjustSendPorts' in opt$ ? opt$.adjustSendPorts : true;
+ _Deserializer(opts) {
+ let adjustSendPorts = opts && 'adjustSendPorts' in opts ? opts.adjustSendPorts : true;
this.deserializedObjects = new core.List();
this[_adjustSendPorts] = dart.as(adjustSendPorts, core.bool);
}
@@ -320,8 +320,8 @@ var _isolate_helper;
}
}
// Function _callInIsolate: (_IsolateContext, Function) → dynamic
- function _callInIsolate(isolate, function) {
- let result = isolate.eval(function);
+ function _callInIsolate(isolate, function$0) {
+ let result = isolate.eval(function$0);
exports._globalState.topEventLoop.run();
return result;
}
@@ -380,8 +380,8 @@ var _isolate_helper;
});
let _nativeDetectEnvironment = Symbol('_nativeDetectEnvironment');
let _nativeInitWorkerMessageHandler = Symbol('_nativeInitWorkerMessageHandler');
- let _processWorkerMessage = Symbol('_processWorkerMessage');
- let _serializePrintMessage = Symbol('_serializePrintMessage');
+ let _processWorkerMessage$ = Symbol('_processWorkerMessage');
+ let _serializePrintMessage$ = Symbol('_serializePrintMessage');
class _Manager extends core.Object {
get useWorkers() {
return this.supportsWorkers;
@@ -417,12 +417,12 @@ var _isolate_helper;
this.fromCommandLine = !dart.notNull(isWindowDefined) && !dart.notNull(this.isWorker);
}
[_nativeInitWorkerMessageHandler]() {
- let function = function(f, a) {
+ let function$0 = function(f, a) {
return function(e) {
f(a, e);
};
- }(_foreign_helper.DART_CLOSURE_TO_JS(IsolateNatives[_processWorkerMessage]), this.mainManager);
- self.onmessage = function;
+ }(_foreign_helper.DART_CLOSURE_TO_JS(IsolateNatives[_processWorkerMessage$]), this.mainManager);
+ self.onmessage = function$0;
self.dartPrint = self.dartPrint || function(serialize) {
return function(object) {
if (self.console && self.console.log) {
@@ -433,7 +433,7 @@ var _isolate_helper;
};
}(_foreign_helper.DART_CLOSURE_TO_JS(_serializePrintMessage));
}
- static [_serializePrintMessage](object) {
+ static [_serializePrintMessage$](object) {
return _serializeMessage(dart.map({command: "print", msg: object}));
}
maybeCloseWorker() {
@@ -449,7 +449,7 @@ var _isolate_helper;
let _addRegistration = Symbol('_addRegistration');
class _IsolateContext extends core.Object {
_IsolateContext() {
- this.id = (($tmp) => exports._globalState.nextIsolateId = dart.notNull($tmp) + 1, $tmp).bind(this)(exports._globalState.nextIsolateId);
+ this.id = ((x) => exports._globalState.nextIsolateId = dart.notNull(x$) + 1, x$).bind(this)(exports._globalState.nextIsolateId);
this.ports = new core.Map();
this.weakPorts = new core.Set();
this.isolateStatics = _foreign_helper.JS_CREATE_ISOLATE();
@@ -778,16 +778,16 @@ var _isolate_helper;
return !!self.postMessage;
}
});
- let _getEventData = Symbol('_getEventData');
- let _log = Symbol('_log');
- let _consoleLog = Symbol('_consoleLog');
- let _getJSFunctionFromName = Symbol('_getJSFunctionFromName');
- let _getJSFunctionName = Symbol('_getJSFunctionName');
+ let _getEventData$ = Symbol('_getEventData');
+ let _log$ = Symbol('_log');
+ let _consoleLog$ = Symbol('_consoleLog');
+ let _getJSFunctionFromName$ = Symbol('_getJSFunctionFromName');
+ let _getJSFunctionName$ = Symbol('_getJSFunctionName');
let _allocate = Symbol('_allocate');
- let _startWorker = Symbol('_startWorker');
- let _startNonWorker = Symbol('_startNonWorker');
- let _startIsolate = Symbol('_startIsolate');
- let _spawnWorker = Symbol('_spawnWorker');
+ let _startWorker$ = Symbol('_startWorker');
+ let _startNonWorker$ = Symbol('_startNonWorker');
+ let _startIsolate$ = Symbol('_startIsolate');
+ let _spawnWorker$ = Symbol('_spawnWorker');
class IsolateNatives extends core.Object {
static computeThisScript() {
let currentScript = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embedded_names.CURRENT_SCRIPT);
@@ -833,10 +833,10 @@ var _isolate_helper;
return matches[1];
throw new core.UnsupportedError(`Cannot extract URI from "${stack}"`);
}
- static [_getEventData](e) {
+ static [_getEventData$](e) {
return e.data;
}
- static [_processWorkerMessage](sender, e) {
+ static [_processWorkerMessage$](sender, e) {
let msg = _deserializeMessage(_getEventData(e));
switch (dart.dindex(msg, 'command')) {
case 'start':
@@ -895,7 +895,7 @@ var _isolate_helper;
}
});
}
- static [_log](msg) {
+ static [_log$](msg) {
if (exports._globalState.isWorker) {
exports._globalState.mainManager.postMessage(_serializeMessage(dart.map({command: 'log', msg: msg})));
} else {
@@ -908,15 +908,15 @@ var _isolate_helper;
}
}
- static [_consoleLog](msg) {
+ static [_consoleLog$](msg) {
_js_helper.requiresPreamble();
self.console.log(msg);
}
- static [_getJSFunctionFromName](functionName) {
+ static [_getJSFunctionFromName$](functionName) {
let globalFunctionsContainer = _foreign_helper.JS_EMBEDDED_GLOBAL("", _js_embedded_names.GLOBAL_FUNCTIONS);
return globalFunctionsContainer[functionName]();
}
- static [_getJSFunctionName](f) {
+ static [_getJSFunctionName$](f) {
return dart.as(dart.is(f, _js_helper.Closure) ? f.$name : null, core.String);
}
static [_allocate](ctor) {
@@ -959,7 +959,7 @@ var _isolate_helper;
}
return completer.future;
}
- static [_startWorker](functionName, uri, args, message, isSpawnUri, startPaused, replyPort, onError) {
+ static [_startWorker$](functionName, uri, args, message, isSpawnUri, startPaused, replyPort, onError) {
if (args !== null)
args = new core.List.from(args);
if (exports._globalState.isWorker) {
@@ -968,7 +968,7 @@ var _isolate_helper;
_spawnWorker(functionName, uri, args, message, isSpawnUri, startPaused, replyPort, onError);
}
}
- static [_startNonWorker](functionName, uri, args, message, isSpawnUri, startPaused, replyPort) {
+ static [_startNonWorker$](functionName, uri, args, message, isSpawnUri, startPaused, replyPort) {
if (uri !== null) {
throw new core.UnsupportedError("Currently spawnUri is not supported without web workers.");
}
@@ -984,7 +984,7 @@ var _isolate_helper;
let context = dart.as(_foreign_helper.JS_CURRENT_ISOLATE_CONTEXT(), _IsolateContext);
return new isolate.Isolate(context.controlPort.sendPort, {pauseCapability: context.pauseCapability, terminateCapability: context.terminateCapability});
}
- static [_startIsolate](topLevel, args, message, isSpawnUri, startPaused, replyTo) {
+ static [_startIsolate$](topLevel, args, message, isSpawnUri, startPaused, replyTo) {
let context = dart.as(_foreign_helper.JS_CURRENT_ISOLATE_CONTEXT(), _IsolateContext);
_js_helper.Primitives.initializeStatics(context.id);
replyTo.send(new List.from([_SPAWNED_SIGNAL, context.controlPort.sendPort, context.pauseCapability, context.terminateCapability]));
@@ -1008,7 +1008,7 @@ var _isolate_helper;
runStartFunction();
}
}
- static [_spawnWorker](functionName, uri, args, message, isSpawnUri, startPaused, replyPort, onError) {
+ static [_spawnWorker$](functionName, uri, args, message, isSpawnUri, startPaused, replyPort, onError) {
if (uri === null)
uri = thisScript;
let worker = new Worker(uri);
@@ -1025,7 +1025,7 @@ var _isolate_helper;
};
}(_foreign_helper.DART_CLOSURE_TO_JS(_processWorkerMessage), worker);
worker.onmessage = processWorkerMessageTrampoline;
- let workerId = (($tmp) => exports._globalState.nextManagerId = dart.notNull($tmp) + 1, $tmp).bind(this)(exports._globalState.nextManagerId);
+ let workerId = ((x) => exports._globalState.nextManagerId = dart.notNull(x$) + 1, x$).bind(this)(exports._globalState.nextManagerId);
workerIds.set(worker, workerId);
exports._globalState.managers.set(workerId, worker);
worker.postMessage(_serializeMessage(dart.map({command: 'start', id: workerId, replyTo: _serializeMessage(replyPort), args: args, msg: _serializeMessage(message), isSpawnUri: isSpawnUri, startPaused: startPaused, functionName: functionName})));
@@ -1054,8 +1054,8 @@ var _isolate_helper;
});
let _checkReplyTo = Symbol('_checkReplyTo');
class _BaseSendPort extends core.Object {
- _BaseSendPort($_isolateId) {
- this[_isolateId] = $_isolateId;
+ _BaseSendPort(isolateId$) {
+ this[_isolateId] = isolateId$;
}
[_checkReplyTo](replyTo) {
if (dart.notNull(replyTo !== null) && dart.notNull(!dart.is(replyTo, _NativeJsSendPort)) && dart.notNull(!dart.is(replyTo, _WorkerSendPort))) {
@@ -1065,8 +1065,8 @@ var _isolate_helper;
}
let _isClosed = Symbol('_isClosed');
class _NativeJsSendPort extends _BaseSendPort {
- _NativeJsSendPort($_receivePort, isolateId) {
- this[_receivePort] = $_receivePort;
+ _NativeJsSendPort(receivePort$, isolateId) {
+ this[_receivePort] = receivePort$;
super._BaseSendPort(isolateId);
}
send(message) {
@@ -1094,9 +1094,9 @@ var _isolate_helper;
}
}
class _WorkerSendPort extends _BaseSendPort {
- _WorkerSendPort($_workerId, isolateId, $_receivePortId) {
- this[_workerId] = $_workerId;
- this[_receivePortId] = $_receivePortId;
+ _WorkerSendPort(workerId$, isolateId, receivePortId$) {
+ this[_workerId] = workerId$;
+ this[_receivePortId] = receivePortId$;
super._BaseSendPort(isolateId);
}
send(message) {
@@ -1121,15 +1121,15 @@ var _isolate_helper;
let _close = Symbol('_close');
let _add = Symbol('_add');
class RawReceivePortImpl extends core.Object {
- RawReceivePortImpl($_handler) {
- this[_handler] = $_handler;
- this[_id] = (($tmp) => _nextFreeId = dart.notNull($tmp) + 1, $tmp)(_nextFreeId);
+ RawReceivePortImpl(handler) {
+ this[_handler] = handler;
+ this[_id] = ((x) => _nextFreeId = dart.notNull(x$) + 1, x$)(_nextFreeId);
this[_isClosed] = false;
exports._globalState.currentContext.register(this[_id], this);
}
- RawReceivePortImpl$weak($_handler) {
- this[_handler] = $_handler;
- this[_id] = (($tmp) => _nextFreeId = dart.notNull($tmp) + 1, $tmp)(_nextFreeId);
+ RawReceivePortImpl$weak(handler) {
+ this[_handler] = handler;
+ this[_id] = ((x) => _nextFreeId = dart.notNull(x$) + 1, x$)(_nextFreeId);
this[_isClosed] = false;
exports._globalState.currentContext.registerWeak(this[_id], this);
}
@@ -1173,17 +1173,17 @@ var _isolate_helper;
ReceivePortImpl$weak() {
this.ReceivePortImpl$fromRawReceivePort(new RawReceivePortImpl.weak(null));
}
- ReceivePortImpl$fromRawReceivePort($_rawPort) {
- this[_rawPort] = $_rawPort;
+ ReceivePortImpl$fromRawReceivePort(rawPort) {
+ this[_rawPort] = rawPort;
this[_controller] = null;
super.Stream();
this[_controller] = new async.StreamController({onCancel: this.close, sync: true});
this[_rawPort].handler = this[_controller].add;
}
- listen(onData, opt$) {
- let onError = opt$ && 'onError' in opt$ ? opt$.onError : null;
- let onDone = opt$ && 'onDone' in opt$ ? opt$.onDone : null;
- let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError : null;
+ listen(onData, opts) {
+ let onError = opts && 'onError' in opts ? opts.onError : null;
+ let onDone = opts && 'onDone' in opts ? opts.onDone : null;
+ let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
return this[_controller].stream.listen(onData, {onError: onError, onDone: onDone, cancelOnError: cancelOnError});
}
close() {
@@ -1272,8 +1272,8 @@ var _isolate_helper;
CapabilityImpl() {
this.CapabilityImpl$_internal(_js_helper.random64());
}
- CapabilityImpl$_internal($_id) {
- this[_id] = $_id;
+ CapabilityImpl$_internal(id) {
+ this[_id] = id;
}
get hashCode() {
let hash = this[_id];

Powered by Google App Engine
This is Rietveld 408576698