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

Side by Side Diff: lib/runtime/dart/_isolate_helper.js

Issue 1039243002: fix temp used in postfix ops (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 8 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 unified diff | Download patch
« no previous file with comments | « lib/runtime/dart/_internal.js ('k') | lib/runtime/dart/_js_helper.js » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 var _isolate_helper; 1 var _isolate_helper;
2 (function(exports) { 2 (function(exports) {
3 'use strict'; 3 'use strict';
4 // Function _serializeMessage: (dynamic) → dynamic 4 // Function _serializeMessage: (dynamic) → dynamic
5 function _serializeMessage(message) { 5 function _serializeMessage(message) {
6 return new _Serializer().serialize(message); 6 return new _Serializer().serialize(message);
7 } 7 }
8 // Function _deserializeMessage: (dynamic) → dynamic 8 // Function _deserializeMessage: (dynamic) → dynamic
9 function _deserializeMessage(message) { 9 function _deserializeMessage(message) {
10 return new _Deserializer().deserialize(message); 10 return new _Deserializer().deserialize(message);
(...skipping 431 matching lines...) Expand 10 before | Expand all | Expand 10 after
442 } 442 }
443 } 443 }
444 } 444 }
445 let _scheduledControlEvents = Symbol('_scheduledControlEvents'); 445 let _scheduledControlEvents = Symbol('_scheduledControlEvents');
446 let _isExecutingEvent = Symbol('_isExecutingEvent'); 446 let _isExecutingEvent = Symbol('_isExecutingEvent');
447 let _updateGlobalState = Symbol('_updateGlobalState'); 447 let _updateGlobalState = Symbol('_updateGlobalState');
448 let _setGlobals = Symbol('_setGlobals'); 448 let _setGlobals = Symbol('_setGlobals');
449 let _addRegistration = Symbol('_addRegistration'); 449 let _addRegistration = Symbol('_addRegistration');
450 class _IsolateContext extends core.Object { 450 class _IsolateContext extends core.Object {
451 _IsolateContext() { 451 _IsolateContext() {
452 this.id = ((x) => exports._globalState.nextIsolateId = dart.notNull(x$) + 1, x$).bind(this)(exports._globalState.nextIsolateId); 452 this.id = ((x$) => exports._globalState.nextIsolateId = dart.notNull(x$) + 1, x$).bind(this)(exports._globalState.nextIsolateId);
453 this.ports = new core.Map(); 453 this.ports = new core.Map();
454 this.weakPorts = new core.Set(); 454 this.weakPorts = new core.Set();
455 this.isolateStatics = _foreign_helper.JS_CREATE_ISOLATE(); 455 this.isolateStatics = _foreign_helper.JS_CREATE_ISOLATE();
456 this.controlPort = new RawReceivePortImpl._controlPort(); 456 this.controlPort = new RawReceivePortImpl._controlPort();
457 this.pauseCapability = new isolate.Capability(); 457 this.pauseCapability = new isolate.Capability();
458 this.terminateCapability = new isolate.Capability(); 458 this.terminateCapability = new isolate.Capability();
459 this.delayedEvents = dart.as(new List.from([]), core.List$(_IsolateEvent)) ; 459 this.delayedEvents = dart.as(new List.from([]), core.List$(_IsolateEvent)) ;
460 this.pauseTokens = dart.as(new core.Set(), core.Set$(isolate.Capability)); 460 this.pauseTokens = dart.as(new core.Set(), core.Set$(isolate.Capability));
461 this.errorPorts = dart.as(new core.Set(), core.Set$(isolate.SendPort)); 461 this.errorPorts = dart.as(new core.Set(), core.Set$(isolate.SendPort));
462 this.initialized = false; 462 this.initialized = false;
(...skipping 555 matching lines...) Expand 10 before | Expand all | Expand 10 after
1018 }; 1018 };
1019 }(_foreign_helper.DART_CLOSURE_TO_JS(workerOnError), uri, onError); 1019 }(_foreign_helper.DART_CLOSURE_TO_JS(workerOnError), uri, onError);
1020 worker.onerror = onerrorTrampoline; 1020 worker.onerror = onerrorTrampoline;
1021 let processWorkerMessageTrampoline = function(f, a) { 1021 let processWorkerMessageTrampoline = function(f, a) {
1022 return function(e) { 1022 return function(e) {
1023 e.onerror = null; 1023 e.onerror = null;
1024 return f(a, e); 1024 return f(a, e);
1025 }; 1025 };
1026 }(_foreign_helper.DART_CLOSURE_TO_JS(_processWorkerMessage), worker); 1026 }(_foreign_helper.DART_CLOSURE_TO_JS(_processWorkerMessage), worker);
1027 worker.onmessage = processWorkerMessageTrampoline; 1027 worker.onmessage = processWorkerMessageTrampoline;
1028 let workerId = ((x) => exports._globalState.nextManagerId = dart.notNull(x $) + 1, x$).bind(this)(exports._globalState.nextManagerId); 1028 let workerId = ((x$) => exports._globalState.nextManagerId = dart.notNull( x$) + 1, x$).bind(this)(exports._globalState.nextManagerId);
1029 workerIds.set(worker, workerId); 1029 workerIds.set(worker, workerId);
1030 exports._globalState.managers.set(workerId, worker); 1030 exports._globalState.managers.set(workerId, worker);
1031 worker.postMessage(_serializeMessage(dart.map({command: 'start', id: worke rId, replyTo: _serializeMessage(replyPort), args: args, msg: _serializeMessage(m essage), isSpawnUri: isSpawnUri, startPaused: startPaused, functionName: functio nName}))); 1031 worker.postMessage(_serializeMessage(dart.map({command: 'start', id: worke rId, replyTo: _serializeMessage(replyPort), args: args, msg: _serializeMessage(m essage), isSpawnUri: isSpawnUri, startPaused: startPaused, functionName: functio nName})));
1032 } 1032 }
1033 static workerOnError(event, uri, onError) { 1033 static workerOnError(event, uri, onError) {
1034 event.preventDefault(); 1034 event.preventDefault();
1035 let message = dart.as(event.message, core.String); 1035 let message = dart.as(event.message, core.String);
1036 if (message === null) { 1036 if (message === null) {
1037 message = `Error spawning worker for ${uri}`; 1037 message = `Error spawning worker for ${uri}`;
1038 } else { 1038 } else {
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after
1116 get hashCode() { 1116 get hashCode() {
1117 return dart.notNull(this[_workerId]) << 16 ^ dart.notNull(this[_isolateId] ) << 8 ^ dart.notNull(this[_receivePortId]); 1117 return dart.notNull(this[_workerId]) << 16 ^ dart.notNull(this[_isolateId] ) << 8 ^ dart.notNull(this[_receivePortId]);
1118 } 1118 }
1119 } 1119 }
1120 let _handler = Symbol('_handler'); 1120 let _handler = Symbol('_handler');
1121 let _close = Symbol('_close'); 1121 let _close = Symbol('_close');
1122 let _add = Symbol('_add'); 1122 let _add = Symbol('_add');
1123 class RawReceivePortImpl extends core.Object { 1123 class RawReceivePortImpl extends core.Object {
1124 RawReceivePortImpl(handler) { 1124 RawReceivePortImpl(handler) {
1125 this[_handler] = handler; 1125 this[_handler] = handler;
1126 this[_id] = ((x) => _nextFreeId = dart.notNull(x$) + 1, x$)(_nextFreeId); 1126 this[_id] = ((x$) => _nextFreeId = dart.notNull(x$) + 1, x$)(_nextFreeId);
1127 this[_isClosed] = false; 1127 this[_isClosed] = false;
1128 exports._globalState.currentContext.register(this[_id], this); 1128 exports._globalState.currentContext.register(this[_id], this);
1129 } 1129 }
1130 RawReceivePortImpl$weak(handler) { 1130 RawReceivePortImpl$weak(handler) {
1131 this[_handler] = handler; 1131 this[_handler] = handler;
1132 this[_id] = ((x) => _nextFreeId = dart.notNull(x$) + 1, x$)(_nextFreeId); 1132 this[_id] = ((x$) => _nextFreeId = dart.notNull(x$) + 1, x$)(_nextFreeId);
1133 this[_isClosed] = false; 1133 this[_isClosed] = false;
1134 exports._globalState.currentContext.registerWeak(this[_id], this); 1134 exports._globalState.currentContext.registerWeak(this[_id], this);
1135 } 1135 }
1136 RawReceivePortImpl$_controlPort() { 1136 RawReceivePortImpl$_controlPort() {
1137 this[_handler] = null; 1137 this[_handler] = null;
1138 this[_id] = 0; 1138 this[_id] = 0;
1139 this[_isClosed] = false; 1139 this[_isClosed] = false;
1140 } 1140 }
1141 set handler(newHandler) { 1141 set handler(newHandler) {
1142 this[_handler] = newHandler; 1142 this[_handler] = newHandler;
(...skipping 158 matching lines...) Expand 10 before | Expand all | Expand 10 after
1301 exports.leaveJsAsync = leaveJsAsync; 1301 exports.leaveJsAsync = leaveJsAsync;
1302 exports.isWorker = isWorker; 1302 exports.isWorker = isWorker;
1303 exports.startRootIsolate = startRootIsolate; 1303 exports.startRootIsolate = startRootIsolate;
1304 exports.IsolateNatives = IsolateNatives; 1304 exports.IsolateNatives = IsolateNatives;
1305 exports.RawReceivePortImpl = RawReceivePortImpl; 1305 exports.RawReceivePortImpl = RawReceivePortImpl;
1306 exports.ReceivePortImpl = ReceivePortImpl; 1306 exports.ReceivePortImpl = ReceivePortImpl;
1307 exports.TimerImpl = TimerImpl; 1307 exports.TimerImpl = TimerImpl;
1308 exports.hasTimer = hasTimer; 1308 exports.hasTimer = hasTimer;
1309 exports.CapabilityImpl = CapabilityImpl; 1309 exports.CapabilityImpl = CapabilityImpl;
1310 })(_isolate_helper || (_isolate_helper = {})); 1310 })(_isolate_helper || (_isolate_helper = {}));
OLDNEW
« no previous file with comments | « lib/runtime/dart/_internal.js ('k') | lib/runtime/dart/_js_helper.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698