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

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

Issue 1145283002: Use short array syntax in method signatures (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 7 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
OLDNEW
1 var _isolate_helper = dart.defineLibrary(_isolate_helper, {}); 1 var _isolate_helper = dart.defineLibrary(_isolate_helper, {});
2 var core = dart.import(core); 2 var core = dart.import(core);
3 var _native_typed_data = dart.import(_native_typed_data); 3 var _native_typed_data = dart.import(_native_typed_data);
4 var _interceptors = dart.lazyImport(_interceptors); 4 var _interceptors = dart.lazyImport(_interceptors);
5 var _js_helper = dart.lazyImport(_js_helper); 5 var _js_helper = dart.lazyImport(_js_helper);
6 var isolate = dart.import(isolate); 6 var isolate = dart.import(isolate);
7 var _foreign_helper = dart.import(_foreign_helper); 7 var _foreign_helper = dart.import(_foreign_helper);
8 var _js_embedded_names = dart.import(_js_embedded_names); 8 var _js_embedded_names = dart.import(_js_embedded_names);
9 var collection = dart.import(collection); 9 var collection = dart.import(collection);
10 var async = dart.import(async); 10 var async = dart.import(async);
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after
159 serializeDartObject(x) { 159 serializeDartObject(x) {
160 let classExtractor = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embedded_n ames.CLASS_ID_EXTRACTOR); 160 let classExtractor = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embedded_n ames.CLASS_ID_EXTRACTOR);
161 let fieldsExtractor = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embedded_ names.CLASS_FIELDS_EXTRACTOR); 161 let fieldsExtractor = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embedded_ names.CLASS_FIELDS_EXTRACTOR);
162 let classId = classExtractor(x); 162 let classId = classExtractor(x);
163 let fields = dart.as(fieldsExtractor(x), core.List); 163 let fields = dart.as(fieldsExtractor(x), core.List);
164 return ['dart', classId, this.serializeArrayInPlace(dart.as(fields, _inter ceptors.JSArray))]; 164 return ['dart', classId, this.serializeArrayInPlace(dart.as(fields, _inter ceptors.JSArray))];
165 } 165 }
166 } 166 }
167 dart.setSignature(_Serializer, { 167 dart.setSignature(_Serializer, {
168 methods: () => ({ 168 methods: () => ({
169 serialize: dart.functionType(dart.dynamic, [dart.dynamic]), 169 serialize: [dart.dynamic, [dart.dynamic]],
170 unsupported: dart.functionType(dart.void, [dart.dynamic], [core.String]), 170 unsupported: [dart.void, [dart.dynamic], [core.String]],
171 makeRef: dart.functionType(dart.dynamic, [core.int]), 171 makeRef: [dart.dynamic, [core.int]],
172 isPrimitive: dart.functionType(core.bool, [dart.dynamic]), 172 isPrimitive: [core.bool, [dart.dynamic]],
173 serializePrimitive: dart.functionType(dart.dynamic, [dart.dynamic]), 173 serializePrimitive: [dart.dynamic, [dart.dynamic]],
174 serializeByteBuffer: dart.functionType(dart.dynamic, [_native_typed_data.N ativeByteBuffer]), 174 serializeByteBuffer: [dart.dynamic, [_native_typed_data.NativeByteBuffer]] ,
175 serializeTypedData: dart.functionType(dart.dynamic, [_native_typed_data.Na tiveTypedData]), 175 serializeTypedData: [dart.dynamic, [_native_typed_data.NativeTypedData]],
176 serializeJSIndexable: dart.functionType(dart.dynamic, [_interceptors.JSInd exable]), 176 serializeJSIndexable: [dart.dynamic, [_interceptors.JSIndexable]],
177 serializeArray: dart.functionType(dart.dynamic, [_interceptors.JSArray]), 177 serializeArray: [dart.dynamic, [_interceptors.JSArray]],
178 serializeArrayInPlace: dart.functionType(dart.dynamic, [_interceptors.JSAr ray]), 178 serializeArrayInPlace: [dart.dynamic, [_interceptors.JSArray]],
179 serializeMap: dart.functionType(dart.dynamic, [core.Map]), 179 serializeMap: [dart.dynamic, [core.Map]],
180 serializeJSObject: dart.functionType(dart.dynamic, [_interceptors.JSObject ]), 180 serializeJSObject: [dart.dynamic, [_interceptors.JSObject]],
181 serializeWorkerSendPort: dart.functionType(dart.dynamic, [_WorkerSendPort] ), 181 serializeWorkerSendPort: [dart.dynamic, [_WorkerSendPort]],
182 serializeJsSendPort: dart.functionType(dart.dynamic, [_NativeJsSendPort]), 182 serializeJsSendPort: [dart.dynamic, [_NativeJsSendPort]],
183 serializeCapability: dart.functionType(dart.dynamic, [CapabilityImpl]), 183 serializeCapability: [dart.dynamic, [CapabilityImpl]],
184 serializeClosure: dart.functionType(dart.dynamic, [_js_helper.Closure]), 184 serializeClosure: [dart.dynamic, [_js_helper.Closure]],
185 serializeDartObject: dart.functionType(dart.dynamic, [dart.dynamic]) 185 serializeDartObject: [dart.dynamic, [dart.dynamic]]
186 }) 186 })
187 }); 187 });
188 let _adjustSendPorts = Symbol('_adjustSendPorts'); 188 let _adjustSendPorts = Symbol('_adjustSendPorts');
189 class _Deserializer extends core.Object { 189 class _Deserializer extends core.Object {
190 _Deserializer(opts) { 190 _Deserializer(opts) {
191 let adjustSendPorts = opts && 'adjustSendPorts' in opts ? opts.adjustSendP orts : true; 191 let adjustSendPorts = opts && 'adjustSendPorts' in opts ? opts.adjustSendP orts : true;
192 this.deserializedObjects = new core.List(); 192 this.deserializedObjects = new core.List();
193 this[_adjustSendPorts] = dart.as(adjustSendPorts, core.bool); 193 this[_adjustSendPorts] = dart.as(adjustSendPorts, core.bool);
194 } 194 }
195 deserialize(x) { 195 deserialize(x) {
(...skipping 176 matching lines...) Expand 10 before | Expand all | Expand 10 after
372 let instanceFromClassId = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embed ded_names.INSTANCE_FROM_CLASS_ID); 372 let instanceFromClassId = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embed ded_names.INSTANCE_FROM_CLASS_ID);
373 let initializeObject = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embedded _names.INITIALIZE_EMPTY_INSTANCE); 373 let initializeObject = _foreign_helper.JS_EMBEDDED_GLOBAL('', _js_embedded _names.INITIALIZE_EMPTY_INSTANCE);
374 let emptyInstance = instanceFromClassId(classId); 374 let emptyInstance = instanceFromClassId(classId);
375 this.deserializedObjects[core.$add](emptyInstance); 375 this.deserializedObjects[core.$add](emptyInstance);
376 this.deserializeArrayInPlace(dart.as(fields, _interceptors.JSArray)); 376 this.deserializeArrayInPlace(dart.as(fields, _interceptors.JSArray));
377 return initializeObject(classId, emptyInstance, fields); 377 return initializeObject(classId, emptyInstance, fields);
378 } 378 }
379 } 379 }
380 dart.setSignature(_Deserializer, { 380 dart.setSignature(_Deserializer, {
381 methods: () => ({ 381 methods: () => ({
382 deserialize: dart.functionType(dart.dynamic, [dart.dynamic]), 382 deserialize: [dart.dynamic, [dart.dynamic]],
383 isPrimitive: dart.functionType(core.bool, [dart.dynamic]), 383 isPrimitive: [core.bool, [dart.dynamic]],
384 deserializePrimitive: dart.functionType(dart.dynamic, [dart.dynamic]), 384 deserializePrimitive: [dart.dynamic, [dart.dynamic]],
385 deserializeRef: dart.functionType(dart.dynamic, [dart.dynamic]), 385 deserializeRef: [dart.dynamic, [dart.dynamic]],
386 deserializeByteBuffer: dart.functionType(_native_typed_data.NativeByteBuff er, [dart.dynamic]), 386 deserializeByteBuffer: [_native_typed_data.NativeByteBuffer, [dart.dynamic ]],
387 deserializeTypedData: dart.functionType(_native_typed_data.NativeTypedData , [dart.dynamic]), 387 deserializeTypedData: [_native_typed_data.NativeTypedData, [dart.dynamic]] ,
388 deserializeArrayInPlace: dart.functionType(core.List, [_interceptors.JSArr ay]), 388 deserializeArrayInPlace: [core.List, [_interceptors.JSArray]],
389 deserializeFixed: dart.functionType(core.List, [dart.dynamic]), 389 deserializeFixed: [core.List, [dart.dynamic]],
390 deserializeExtendable: dart.functionType(core.List, [dart.dynamic]), 390 deserializeExtendable: [core.List, [dart.dynamic]],
391 deserializeMutable: dart.functionType(core.List, [dart.dynamic]), 391 deserializeMutable: [core.List, [dart.dynamic]],
392 deserializeConst: dart.functionType(core.List, [dart.dynamic]), 392 deserializeConst: [core.List, [dart.dynamic]],
393 deserializeMap: dart.functionType(core.Map, [dart.dynamic]), 393 deserializeMap: [core.Map, [dart.dynamic]],
394 deserializeSendPort: dart.functionType(isolate.SendPort, [dart.dynamic]), 394 deserializeSendPort: [isolate.SendPort, [dart.dynamic]],
395 deserializeRawSendPort: dart.functionType(isolate.SendPort, [dart.dynamic] ), 395 deserializeRawSendPort: [isolate.SendPort, [dart.dynamic]],
396 deserializeJSObject: dart.functionType(dart.dynamic, [dart.dynamic]), 396 deserializeJSObject: [dart.dynamic, [dart.dynamic]],
397 deserializeClosure: dart.functionType(core.Function, [dart.dynamic]), 397 deserializeClosure: [core.Function, [dart.dynamic]],
398 deserializeDartObject: dart.functionType(dart.dynamic, [dart.dynamic]) 398 deserializeDartObject: [dart.dynamic, [dart.dynamic]]
399 }) 399 })
400 }); 400 });
401 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn amic, [dart.dynamic])); 401 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn amic, [dart.dynamic]));
402 function _callInIsolate(isolate, func) { 402 function _callInIsolate(isolate, func) {
403 let result = isolate.eval(func); 403 let result = isolate.eval(func);
404 exports._globalState.topEventLoop.run(); 404 exports._globalState.topEventLoop.run();
405 return result; 405 return result;
406 } 406 }
407 dart.fn(_callInIsolate, () => dart.functionType(dart.dynamic, [_IsolateContext , core.Function])); 407 dart.fn(_callInIsolate, () => dart.functionType(dart.dynamic, [_IsolateContext , core.Function]));
408 let _activeJsAsyncCount = Symbol('_activeJsAsyncCount'); 408 let _activeJsAsyncCount = Symbol('_activeJsAsyncCount');
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after
517 return _serializeMessage(dart.map({command: "print", msg: object})); 517 return _serializeMessage(dart.map({command: "print", msg: object}));
518 } 518 }
519 maybeCloseWorker() { 519 maybeCloseWorker() {
520 if (dart.notNull(this.isWorker) && dart.notNull(this.isolates.isEmpty) && this.topEventLoop[_activeJsAsyncCount] == 0) { 520 if (dart.notNull(this.isWorker) && dart.notNull(this.isolates.isEmpty) && this.topEventLoop[_activeJsAsyncCount] == 0) {
521 this.mainManager.postMessage(_serializeMessage(dart.map({command: 'close '}))); 521 this.mainManager.postMessage(_serializeMessage(dart.map({command: 'close '})));
522 } 522 }
523 } 523 }
524 } 524 }
525 dart.setSignature(_Manager, { 525 dart.setSignature(_Manager, {
526 methods: () => ({ 526 methods: () => ({
527 [_nativeDetectEnvironment]: dart.functionType(dart.void, []), 527 [_nativeDetectEnvironment]: [dart.void, []],
528 [_nativeInitWorkerMessageHandler]: dart.functionType(dart.void, []), 528 [_nativeInitWorkerMessageHandler]: [dart.void, []],
529 maybeCloseWorker: dart.functionType(dart.void, []) 529 maybeCloseWorker: [dart.void, []]
530 }), 530 }),
531 statics: () => ({_serializePrintMessage: dart.functionType(dart.dynamic, [da rt.dynamic])}), 531 statics: () => ({_serializePrintMessage: [dart.dynamic, [dart.dynamic]]}),
532 names: ['_serializePrintMessage'] 532 names: ['_serializePrintMessage']
533 }); 533 });
534 let _scheduledControlEvents = Symbol('_scheduledControlEvents'); 534 let _scheduledControlEvents = Symbol('_scheduledControlEvents');
535 let _isExecutingEvent = Symbol('_isExecutingEvent'); 535 let _isExecutingEvent = Symbol('_isExecutingEvent');
536 let _updateGlobalState = Symbol('_updateGlobalState'); 536 let _updateGlobalState = Symbol('_updateGlobalState');
537 let _setGlobals = Symbol('_setGlobals'); 537 let _setGlobals = Symbol('_setGlobals');
538 let _addRegistration = Symbol('_addRegistration'); 538 let _addRegistration = Symbol('_addRegistration');
539 let _close = Symbol('_close'); 539 let _close = Symbol('_close');
540 class _IsolateContext extends core.Object { 540 class _IsolateContext extends core.Object {
541 _IsolateContext() { 541 _IsolateContext() {
(...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after
790 } 790 }
791 unregister(portId) { 791 unregister(portId) {
792 this.ports.remove(portId); 792 this.ports.remove(portId);
793 this.weakPorts.remove(portId); 793 this.weakPorts.remove(portId);
794 this[_updateGlobalState](); 794 this[_updateGlobalState]();
795 } 795 }
796 } 796 }
797 _IsolateContext[dart.implements] = () => [_foreign_helper.IsolateContext]; 797 _IsolateContext[dart.implements] = () => [_foreign_helper.IsolateContext];
798 dart.setSignature(_IsolateContext, { 798 dart.setSignature(_IsolateContext, {
799 methods: () => ({ 799 methods: () => ({
800 addPause: dart.functionType(dart.void, [isolate.Capability, isolate.Capabi lity]), 800 addPause: [dart.void, [isolate.Capability, isolate.Capability]],
801 removePause: dart.functionType(dart.void, [isolate.Capability]), 801 removePause: [dart.void, [isolate.Capability]],
802 addDoneListener: dart.functionType(dart.void, [isolate.SendPort]), 802 addDoneListener: [dart.void, [isolate.SendPort]],
803 removeDoneListener: dart.functionType(dart.void, [isolate.SendPort]), 803 removeDoneListener: [dart.void, [isolate.SendPort]],
804 setErrorsFatal: dart.functionType(dart.void, [isolate.Capability, core.boo l]), 804 setErrorsFatal: [dart.void, [isolate.Capability, core.bool]],
805 handlePing: dart.functionType(dart.void, [isolate.SendPort, core.int]), 805 handlePing: [dart.void, [isolate.SendPort, core.int]],
806 handleKill: dart.functionType(dart.void, [isolate.Capability, core.int]), 806 handleKill: [dart.void, [isolate.Capability, core.int]],
807 addErrorListener: dart.functionType(dart.void, [isolate.SendPort]), 807 addErrorListener: [dart.void, [isolate.SendPort]],
808 removeErrorListener: dart.functionType(dart.void, [isolate.SendPort]), 808 removeErrorListener: [dart.void, [isolate.SendPort]],
809 handleUncaughtError: dart.functionType(dart.void, [dart.dynamic, core.Stac kTrace]), 809 handleUncaughtError: [dart.void, [dart.dynamic, core.StackTrace]],
810 eval: dart.functionType(dart.dynamic, [core.Function]), 810 eval: [dart.dynamic, [core.Function]],
811 [_setGlobals]: dart.functionType(dart.void, []), 811 [_setGlobals]: [dart.void, []],
812 handleControlMessage: dart.functionType(dart.void, [dart.dynamic]), 812 handleControlMessage: [dart.void, [dart.dynamic]],
813 lookup: dart.functionType(RawReceivePortImpl, [core.int]), 813 lookup: [RawReceivePortImpl, [core.int]],
814 [_addRegistration]: dart.functionType(dart.void, [core.int, RawReceivePort Impl]), 814 [_addRegistration]: [dart.void, [core.int, RawReceivePortImpl]],
815 register: dart.functionType(dart.void, [core.int, RawReceivePortImpl]), 815 register: [dart.void, [core.int, RawReceivePortImpl]],
816 registerWeak: dart.functionType(dart.void, [core.int, RawReceivePortImpl]) , 816 registerWeak: [dart.void, [core.int, RawReceivePortImpl]],
817 [_updateGlobalState]: dart.functionType(dart.void, []), 817 [_updateGlobalState]: [dart.void, []],
818 kill: dart.functionType(dart.void, []), 818 kill: [dart.void, []],
819 unregister: dart.functionType(dart.void, [core.int]) 819 unregister: [dart.void, [core.int]]
820 }) 820 })
821 }); 821 });
822 let _runHelper = Symbol('_runHelper'); 822 let _runHelper = Symbol('_runHelper');
823 class _EventLoop extends core.Object { 823 class _EventLoop extends core.Object {
824 _EventLoop() { 824 _EventLoop() {
825 this.events = new (collection.Queue$(_IsolateEvent))(); 825 this.events = new (collection.Queue$(_IsolateEvent))();
826 this[_activeJsAsyncCount] = 0; 826 this[_activeJsAsyncCount] = 0;
827 } 827 }
828 enqueue(isolate, fn, msg) { 828 enqueue(isolate, fn, msg) {
829 this.events.addLast(new _IsolateEvent(dart.as(isolate, _IsolateContext), d art.as(fn, core.Function), dart.as(msg, core.String))); 829 this.events.addLast(new _IsolateEvent(dart.as(isolate, _IsolateContext), d art.as(fn, core.Function), dart.as(msg, core.String)));
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
874 } catch (e) { 874 } catch (e) {
875 let trace = dart.stackTrace(e); 875 let trace = dart.stackTrace(e);
876 exports._globalState.mainManager.postMessage(_serializeMessage(dart.ma p({command: 'error', msg: `${e}\n${trace}`}))); 876 exports._globalState.mainManager.postMessage(_serializeMessage(dart.ma p({command: 'error', msg: `${e}\n${trace}`})));
877 } 877 }
878 878
879 } 879 }
880 } 880 }
881 } 881 }
882 dart.setSignature(_EventLoop, { 882 dart.setSignature(_EventLoop, {
883 methods: () => ({ 883 methods: () => ({
884 enqueue: dart.functionType(dart.void, [dart.dynamic, dart.dynamic, dart.dy namic]), 884 enqueue: [dart.void, [dart.dynamic, dart.dynamic, dart.dynamic]],
885 prequeue: dart.functionType(dart.void, [_IsolateEvent]), 885 prequeue: [dart.void, [_IsolateEvent]],
886 dequeue: dart.functionType(_IsolateEvent, []), 886 dequeue: [_IsolateEvent, []],
887 checkOpenReceivePortsFromCommandLine: dart.functionType(dart.void, []), 887 checkOpenReceivePortsFromCommandLine: [dart.void, []],
888 runIteration: dart.functionType(core.bool, []), 888 runIteration: [core.bool, []],
889 [_runHelper]: dart.functionType(dart.void, []), 889 [_runHelper]: [dart.void, []],
890 run: dart.functionType(dart.void, []) 890 run: [dart.void, []]
891 }) 891 })
892 }); 892 });
893 class _IsolateEvent extends core.Object { 893 class _IsolateEvent extends core.Object {
894 _IsolateEvent(isolate, fn, message) { 894 _IsolateEvent(isolate, fn, message) {
895 this.isolate = isolate; 895 this.isolate = isolate;
896 this.fn = fn; 896 this.fn = fn;
897 this.message = message; 897 this.message = message;
898 } 898 }
899 process() { 899 process() {
900 if (this.isolate.isPaused) { 900 if (this.isolate.isPaused) {
901 this.isolate.delayedEvents[core.$add](this); 901 this.isolate.delayedEvents[core.$add](this);
902 return; 902 return;
903 } 903 }
904 this.isolate.eval(this.fn); 904 this.isolate.eval(this.fn);
905 } 905 }
906 } 906 }
907 dart.setSignature(_IsolateEvent, { 907 dart.setSignature(_IsolateEvent, {
908 methods: () => ({process: dart.functionType(dart.void, [])}) 908 methods: () => ({process: [dart.void, []]})
909 }); 909 });
910 class _MainManagerStub extends core.Object { 910 class _MainManagerStub extends core.Object {
911 postMessage(msg) { 911 postMessage(msg) {
912 _js_helper.requiresPreamble(); 912 _js_helper.requiresPreamble();
913 self.postMessage(msg); 913 self.postMessage(msg);
914 } 914 }
915 } 915 }
916 dart.setSignature(_MainManagerStub, { 916 dart.setSignature(_MainManagerStub, {
917 methods: () => ({postMessage: dart.functionType(dart.void, [dart.dynamic])}) 917 methods: () => ({postMessage: [dart.void, [dart.dynamic]]})
918 }); 918 });
919 let _SPAWNED_SIGNAL = "spawned"; 919 let _SPAWNED_SIGNAL = "spawned";
920 let _SPAWN_FAILED_SIGNAL = "spawn failed"; 920 let _SPAWN_FAILED_SIGNAL = "spawn failed";
921 dart.copyProperties(exports, { 921 dart.copyProperties(exports, {
922 get globalWindow() { 922 get globalWindow() {
923 _js_helper.requiresPreamble(); 923 _js_helper.requiresPreamble();
924 return self.window; 924 return self.window;
925 }, 925 },
926 get globalWorker() { 926 get globalWorker() {
927 _js_helper.requiresPreamble(); 927 _js_helper.requiresPreamble();
(...skipping 271 matching lines...) Expand 10 before | Expand all | Expand 10 after
1199 message = `Error spawning worker for ${uri}`; 1199 message = `Error spawning worker for ${uri}`;
1200 } else { 1200 } else {
1201 message = `Error spawning worker for ${uri} (${message})`; 1201 message = `Error spawning worker for ${uri} (${message})`;
1202 } 1202 }
1203 onError(message); 1203 onError(message);
1204 return true; 1204 return true;
1205 } 1205 }
1206 } 1206 }
1207 dart.setSignature(IsolateNatives, { 1207 dart.setSignature(IsolateNatives, {
1208 statics: () => ({ 1208 statics: () => ({
1209 computeThisScript: dart.functionType(core.String, []), 1209 computeThisScript: [core.String, []],
1210 computeThisScriptJsshell: dart.functionType(core.String, []), 1210 computeThisScriptJsshell: [core.String, []],
1211 computeThisScriptD8: dart.functionType(core.String, []), 1211 computeThisScriptD8: [core.String, []],
1212 computeThisScriptFromTrace: dart.functionType(core.String, []), 1212 computeThisScriptFromTrace: [core.String, []],
1213 _getEventData: dart.functionType(dart.dynamic, [dart.dynamic]), 1213 _getEventData: [dart.dynamic, [dart.dynamic]],
1214 _processWorkerMessage: dart.functionType(dart.void, [dart.dynamic, dart.dy namic]), 1214 _processWorkerMessage: [dart.void, [dart.dynamic, dart.dynamic]],
1215 handleSpawnWorkerRequest: dart.functionType(dart.dynamic, [dart.dynamic]), 1215 handleSpawnWorkerRequest: [dart.dynamic, [dart.dynamic]],
1216 _log: dart.functionType(dart.dynamic, [dart.dynamic]), 1216 _log: [dart.dynamic, [dart.dynamic]],
1217 _consoleLog: dart.functionType(dart.void, [dart.dynamic]), 1217 _consoleLog: [dart.void, [dart.dynamic]],
1218 _getJSFunctionFromName: dart.functionType(dart.dynamic, [core.String]), 1218 _getJSFunctionFromName: [dart.dynamic, [core.String]],
1219 _getJSFunctionName: dart.functionType(core.String, [core.Function]), 1219 _getJSFunctionName: [core.String, [core.Function]],
1220 _allocate: dart.functionType(dart.dynamic, [dart.dynamic]), 1220 _allocate: [dart.dynamic, [dart.dynamic]],
1221 spawnFunction: dart.functionType(async.Future$(core.List), [dart.functionT ype(dart.void, [dart.dynamic]), dart.dynamic, core.bool]), 1221 spawnFunction: [async.Future$(core.List), [dart.functionType(dart.void, [d art.dynamic]), dart.dynamic, core.bool]],
1222 spawnUri: dart.functionType(async.Future$(core.List), [core.Uri, core.List $(core.String), dart.dynamic, core.bool]), 1222 spawnUri: [async.Future$(core.List), [core.Uri, core.List$(core.String), d art.dynamic, core.bool]],
1223 spawn: dart.functionType(async.Future$(core.List), [core.String, core.Stri ng, core.List$(core.String), dart.dynamic, core.bool, core.bool, core.bool]), 1223 spawn: [async.Future$(core.List), [core.String, core.String, core.List$(co re.String), dart.dynamic, core.bool, core.bool, core.bool]],
1224 _startWorker: dart.functionType(dart.void, [core.String, core.String, core .List$(core.String), dart.dynamic, core.bool, core.bool, isolate.SendPort, dart. functionType(dart.void, [core.String])]), 1224 _startWorker: [dart.void, [core.String, core.String, core.List$(core.Strin g), dart.dynamic, core.bool, core.bool, isolate.SendPort, dart.functionType(dart .void, [core.String])]],
1225 _startNonWorker: dart.functionType(dart.void, [core.String, core.String, c ore.List$(core.String), dart.dynamic, core.bool, core.bool, isolate.SendPort]), 1225 _startNonWorker: [dart.void, [core.String, core.String, core.List$(core.St ring), dart.dynamic, core.bool, core.bool, isolate.SendPort]],
1226 _startIsolate: dart.functionType(dart.void, [core.Function, core.List$(cor e.String), dart.dynamic, core.bool, core.bool, isolate.SendPort]), 1226 _startIsolate: [dart.void, [core.Function, core.List$(core.String), dart.d ynamic, core.bool, core.bool, isolate.SendPort]],
1227 _spawnWorker: dart.functionType(dart.void, [dart.dynamic, core.String, cor e.List$(core.String), dart.dynamic, core.bool, core.bool, isolate.SendPort, dart .functionType(dart.void, [core.String])]), 1227 _spawnWorker: [dart.void, [dart.dynamic, core.String, core.List$(core.Stri ng), dart.dynamic, core.bool, core.bool, isolate.SendPort, dart.functionType(dar t.void, [core.String])]],
1228 workerOnError: dart.functionType(core.bool, [dart.dynamic, core.String, da rt.functionType(dart.void, [core.String])]) 1228 workerOnError: [core.bool, [dart.dynamic, core.String, dart.functionType(d art.void, [core.String])]]
1229 }), 1229 }),
1230 names: ['computeThisScript', 'computeThisScriptJsshell', 'computeThisScriptD 8', 'computeThisScriptFromTrace', '_getEventData', '_processWorkerMessage', 'han dleSpawnWorkerRequest', '_log', '_consoleLog', '_getJSFunctionFromName', '_getJS FunctionName', '_allocate', 'spawnFunction', 'spawnUri', 'spawn', '_startWorker' , '_startNonWorker', '_startIsolate', '_spawnWorker', 'workerOnError'] 1230 names: ['computeThisScript', 'computeThisScriptJsshell', 'computeThisScriptD 8', 'computeThisScriptFromTrace', '_getEventData', '_processWorkerMessage', 'han dleSpawnWorkerRequest', '_log', '_consoleLog', '_getJSFunctionFromName', '_getJS FunctionName', '_allocate', 'spawnFunction', 'spawnUri', 'spawn', '_startWorker' , '_startNonWorker', '_startIsolate', '_spawnWorker', 'workerOnError']
1231 }); 1231 });
1232 IsolateNatives.enableSpawnWorker = null; 1232 IsolateNatives.enableSpawnWorker = null;
1233 dart.defineLazyProperties(IsolateNatives, { 1233 dart.defineLazyProperties(IsolateNatives, {
1234 get thisScript() { 1234 get thisScript() {
1235 return IsolateNatives.computeThisScript(); 1235 return IsolateNatives.computeThisScript();
1236 }, 1236 },
1237 set thisScript(_) {}, 1237 set thisScript(_) {},
1238 get workerIds() { 1238 get workerIds() {
1239 return new (core.Expando$(core.int))(); 1239 return new (core.Expando$(core.int))();
1240 } 1240 }
1241 }); 1241 });
1242 let _checkReplyTo = Symbol('_checkReplyTo'); 1242 let _checkReplyTo = Symbol('_checkReplyTo');
1243 class _BaseSendPort extends core.Object { 1243 class _BaseSendPort extends core.Object {
1244 _BaseSendPort(isolateId) { 1244 _BaseSendPort(isolateId) {
1245 this[_isolateId] = isolateId; 1245 this[_isolateId] = isolateId;
1246 } 1246 }
1247 [_checkReplyTo](replyTo) { 1247 [_checkReplyTo](replyTo) {
1248 if (dart.notNull(replyTo != null) && !dart.is(replyTo, _NativeJsSendPort) && !dart.is(replyTo, _WorkerSendPort)) { 1248 if (dart.notNull(replyTo != null) && !dart.is(replyTo, _NativeJsSendPort) && !dart.is(replyTo, _WorkerSendPort)) {
1249 throw new core.Exception("SendPort.send: Illegal replyTo port type"); 1249 throw new core.Exception("SendPort.send: Illegal replyTo port type");
1250 } 1250 }
1251 } 1251 }
1252 } 1252 }
1253 _BaseSendPort[dart.implements] = () => [isolate.SendPort]; 1253 _BaseSendPort[dart.implements] = () => [isolate.SendPort];
1254 dart.setSignature(_BaseSendPort, { 1254 dart.setSignature(_BaseSendPort, {
1255 methods: () => ({[_checkReplyTo]: dart.functionType(dart.void, [isolate.Send Port])}) 1255 methods: () => ({[_checkReplyTo]: [dart.void, [isolate.SendPort]]})
1256 }); 1256 });
1257 let _isClosed = Symbol('_isClosed'); 1257 let _isClosed = Symbol('_isClosed');
1258 let _add = Symbol('_add'); 1258 let _add = Symbol('_add');
1259 class _NativeJsSendPort extends _BaseSendPort { 1259 class _NativeJsSendPort extends _BaseSendPort {
1260 _NativeJsSendPort(receivePort, isolateId) { 1260 _NativeJsSendPort(receivePort, isolateId) {
1261 this[_receivePort] = receivePort; 1261 this[_receivePort] = receivePort;
1262 super._BaseSendPort(isolateId); 1262 super._BaseSendPort(isolateId);
1263 } 1263 }
1264 send(message) { 1264 send(message) {
1265 let isolate = exports._globalState.isolates.get(this[_isolateId]); 1265 let isolate = exports._globalState.isolates.get(this[_isolateId]);
(...skipping 15 matching lines...) Expand all
1281 ['=='](other) { 1281 ['=='](other) {
1282 return dart.is(other, _NativeJsSendPort) && dart.notNull(dart.equals(this[ _receivePort], dart.dload(other, _receivePort))); 1282 return dart.is(other, _NativeJsSendPort) && dart.notNull(dart.equals(this[ _receivePort], dart.dload(other, _receivePort)));
1283 } 1283 }
1284 get hashCode() { 1284 get hashCode() {
1285 return this[_receivePort][_id]; 1285 return this[_receivePort][_id];
1286 } 1286 }
1287 } 1287 }
1288 _NativeJsSendPort[dart.implements] = () => [isolate.SendPort]; 1288 _NativeJsSendPort[dart.implements] = () => [isolate.SendPort];
1289 dart.setSignature(_NativeJsSendPort, { 1289 dart.setSignature(_NativeJsSendPort, {
1290 methods: () => ({ 1290 methods: () => ({
1291 send: dart.functionType(dart.void, [dart.dynamic]), 1291 send: [dart.void, [dart.dynamic]],
1292 '==': dart.functionType(core.bool, [dart.dynamic]) 1292 '==': [core.bool, [dart.dynamic]]
1293 }) 1293 })
1294 }); 1294 });
1295 class _WorkerSendPort extends _BaseSendPort { 1295 class _WorkerSendPort extends _BaseSendPort {
1296 _WorkerSendPort(workerId, isolateId, receivePortId) { 1296 _WorkerSendPort(workerId, isolateId, receivePortId) {
1297 this[_workerId] = workerId; 1297 this[_workerId] = workerId;
1298 this[_receivePortId] = receivePortId; 1298 this[_receivePortId] = receivePortId;
1299 super._BaseSendPort(isolateId); 1299 super._BaseSendPort(isolateId);
1300 } 1300 }
1301 send(message) { 1301 send(message) {
1302 let workerMessage = _serializeMessage(dart.map({command: 'message', port: this, msg: message})); 1302 let workerMessage = _serializeMessage(dart.map({command: 'message', port: this, msg: message}));
1303 if (exports._globalState.isWorker) { 1303 if (exports._globalState.isWorker) {
1304 exports._globalState.mainManager.postMessage(workerMessage); 1304 exports._globalState.mainManager.postMessage(workerMessage);
1305 } else { 1305 } else {
1306 let manager = exports._globalState.managers.get(this[_workerId]); 1306 let manager = exports._globalState.managers.get(this[_workerId]);
1307 if (manager != null) { 1307 if (manager != null) {
1308 manager.postMessage(workerMessage); 1308 manager.postMessage(workerMessage);
1309 } 1309 }
1310 } 1310 }
1311 } 1311 }
1312 ['=='](other) { 1312 ['=='](other) {
1313 return dart.is(other, _WorkerSendPort) && dart.equals(this[_workerId], dar t.dload(other, _workerId)) && dart.equals(this[_isolateId], dart.dload(other, _i solateId)) && dart.equals(this[_receivePortId], dart.dload(other, _receivePortId )); 1313 return dart.is(other, _WorkerSendPort) && dart.equals(this[_workerId], dar t.dload(other, _workerId)) && dart.equals(this[_isolateId], dart.dload(other, _i solateId)) && dart.equals(this[_receivePortId], dart.dload(other, _receivePortId ));
1314 } 1314 }
1315 get hashCode() { 1315 get hashCode() {
1316 return dart.notNull(this[_workerId]) << 16 ^ dart.notNull(this[_isolateId] ) << 8 ^ dart.notNull(this[_receivePortId]); 1316 return dart.notNull(this[_workerId]) << 16 ^ dart.notNull(this[_isolateId] ) << 8 ^ dart.notNull(this[_receivePortId]);
1317 } 1317 }
1318 } 1318 }
1319 _WorkerSendPort[dart.implements] = () => [isolate.SendPort]; 1319 _WorkerSendPort[dart.implements] = () => [isolate.SendPort];
1320 dart.setSignature(_WorkerSendPort, { 1320 dart.setSignature(_WorkerSendPort, {
1321 methods: () => ({ 1321 methods: () => ({
1322 send: dart.functionType(dart.void, [dart.dynamic]), 1322 send: [dart.void, [dart.dynamic]],
1323 '==': dart.functionType(core.bool, [dart.dynamic]) 1323 '==': [core.bool, [dart.dynamic]]
1324 }) 1324 })
1325 }); 1325 });
1326 let _handler = Symbol('_handler'); 1326 let _handler = Symbol('_handler');
1327 class RawReceivePortImpl extends core.Object { 1327 class RawReceivePortImpl extends core.Object {
1328 RawReceivePortImpl(handler) { 1328 RawReceivePortImpl(handler) {
1329 this[_handler] = handler; 1329 this[_handler] = handler;
1330 this[_id] = (() => { 1330 this[_id] = (() => {
1331 let x = RawReceivePortImpl._nextFreeId; 1331 let x = RawReceivePortImpl._nextFreeId;
1332 RawReceivePortImpl._nextFreeId = dart.notNull(x) + 1; 1332 RawReceivePortImpl._nextFreeId = dart.notNull(x) + 1;
1333 return x; 1333 return x;
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after
1371 } 1371 }
1372 get sendPort() { 1372 get sendPort() {
1373 return new _NativeJsSendPort(this, exports._globalState.currentContext.id) ; 1373 return new _NativeJsSendPort(this, exports._globalState.currentContext.id) ;
1374 } 1374 }
1375 } 1375 }
1376 RawReceivePortImpl[dart.implements] = () => [isolate.RawReceivePort]; 1376 RawReceivePortImpl[dart.implements] = () => [isolate.RawReceivePort];
1377 dart.defineNamedConstructor(RawReceivePortImpl, 'weak'); 1377 dart.defineNamedConstructor(RawReceivePortImpl, 'weak');
1378 dart.defineNamedConstructor(RawReceivePortImpl, '_controlPort'); 1378 dart.defineNamedConstructor(RawReceivePortImpl, '_controlPort');
1379 dart.setSignature(RawReceivePortImpl, { 1379 dart.setSignature(RawReceivePortImpl, {
1380 methods: () => ({ 1380 methods: () => ({
1381 [_close]: dart.functionType(dart.void, []), 1381 [_close]: [dart.void, []],
1382 close: dart.functionType(dart.void, []), 1382 close: [dart.void, []],
1383 [_add]: dart.functionType(dart.void, [dart.dynamic]) 1383 [_add]: [dart.void, [dart.dynamic]]
1384 }) 1384 })
1385 }); 1385 });
1386 RawReceivePortImpl._nextFreeId = 1; 1386 RawReceivePortImpl._nextFreeId = 1;
1387 let _rawPort = Symbol('_rawPort'); 1387 let _rawPort = Symbol('_rawPort');
1388 let _controller = Symbol('_controller'); 1388 let _controller = Symbol('_controller');
1389 class ReceivePortImpl extends async.Stream { 1389 class ReceivePortImpl extends async.Stream {
1390 ReceivePortImpl() { 1390 ReceivePortImpl() {
1391 this.fromRawReceivePort(new RawReceivePortImpl(null)); 1391 this.fromRawReceivePort(new RawReceivePortImpl(null));
1392 } 1392 }
1393 weak() { 1393 weak() {
(...skipping 18 matching lines...) Expand all
1412 } 1412 }
1413 get sendPort() { 1413 get sendPort() {
1414 return this[_rawPort].sendPort; 1414 return this[_rawPort].sendPort;
1415 } 1415 }
1416 } 1416 }
1417 ReceivePortImpl[dart.implements] = () => [isolate.ReceivePort]; 1417 ReceivePortImpl[dart.implements] = () => [isolate.ReceivePort];
1418 dart.defineNamedConstructor(ReceivePortImpl, 'weak'); 1418 dart.defineNamedConstructor(ReceivePortImpl, 'weak');
1419 dart.defineNamedConstructor(ReceivePortImpl, 'fromRawReceivePort'); 1419 dart.defineNamedConstructor(ReceivePortImpl, 'fromRawReceivePort');
1420 dart.setSignature(ReceivePortImpl, { 1420 dart.setSignature(ReceivePortImpl, {
1421 methods: () => ({ 1421 methods: () => ({
1422 listen: dart.functionType(async.StreamSubscription, [dart.functionType(dar t.void, [dart.dynamic])], {nErro: core.Function, nDon: dart.functionType(dart.vo id, []), ancelOnErro: core.bool}), 1422 listen: [async.StreamSubscription, [dart.functionType(dart.void, [dart.dyn amic])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnE rro: core.bool}],
1423 close: dart.functionType(dart.void, []) 1423 close: [dart.void, []]
1424 }) 1424 })
1425 }); 1425 });
1426 let _once = Symbol('_once'); 1426 let _once = Symbol('_once');
1427 let _inEventLoop = Symbol('_inEventLoop'); 1427 let _inEventLoop = Symbol('_inEventLoop');
1428 let _handle = Symbol('_handle'); 1428 let _handle = Symbol('_handle');
1429 class TimerImpl extends core.Object { 1429 class TimerImpl extends core.Object {
1430 TimerImpl(milliseconds, callback) { 1430 TimerImpl(milliseconds, callback) {
1431 this[_once] = true; 1431 this[_once] = true;
1432 this[_inEventLoop] = false; 1432 this[_inEventLoop] = false;
1433 this[_handle] = null; 1433 this[_handle] = null;
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after
1485 throw new core.UnsupportedError("Canceling a timer."); 1485 throw new core.UnsupportedError("Canceling a timer.");
1486 } 1486 }
1487 } 1487 }
1488 get isActive() { 1488 get isActive() {
1489 return this[_handle] != null; 1489 return this[_handle] != null;
1490 } 1490 }
1491 } 1491 }
1492 TimerImpl[dart.implements] = () => [async.Timer]; 1492 TimerImpl[dart.implements] = () => [async.Timer];
1493 dart.defineNamedConstructor(TimerImpl, 'periodic'); 1493 dart.defineNamedConstructor(TimerImpl, 'periodic');
1494 dart.setSignature(TimerImpl, { 1494 dart.setSignature(TimerImpl, {
1495 methods: () => ({cancel: dart.functionType(dart.void, [])}) 1495 methods: () => ({cancel: [dart.void, []]})
1496 }); 1496 });
1497 function hasTimer() { 1497 function hasTimer() {
1498 _js_helper.requiresPreamble(); 1498 _js_helper.requiresPreamble();
1499 return self.setTimeout != null; 1499 return self.setTimeout != null;
1500 } 1500 }
1501 dart.fn(hasTimer, core.bool, []); 1501 dart.fn(hasTimer, core.bool, []);
1502 class CapabilityImpl extends core.Object { 1502 class CapabilityImpl extends core.Object {
1503 CapabilityImpl() { 1503 CapabilityImpl() {
1504 this._internal(_js_helper.random64()); 1504 this._internal(_js_helper.random64());
1505 } 1505 }
(...skipping 16 matching lines...) Expand all
1522 return true; 1522 return true;
1523 if (dart.is(other, CapabilityImpl)) { 1523 if (dart.is(other, CapabilityImpl)) {
1524 return core.identical(this[_id], other[_id]); 1524 return core.identical(this[_id], other[_id]);
1525 } 1525 }
1526 return false; 1526 return false;
1527 } 1527 }
1528 } 1528 }
1529 CapabilityImpl[dart.implements] = () => [isolate.Capability]; 1529 CapabilityImpl[dart.implements] = () => [isolate.Capability];
1530 dart.defineNamedConstructor(CapabilityImpl, '_internal'); 1530 dart.defineNamedConstructor(CapabilityImpl, '_internal');
1531 dart.setSignature(CapabilityImpl, { 1531 dart.setSignature(CapabilityImpl, {
1532 methods: () => ({'==': dart.functionType(core.bool, [core.Object])}) 1532 methods: () => ({'==': [core.bool, [core.Object]]})
1533 }); 1533 });
1534 // Exports: 1534 // Exports:
1535 exports.enterJsAsync = enterJsAsync; 1535 exports.enterJsAsync = enterJsAsync;
1536 exports.leaveJsAsync = leaveJsAsync; 1536 exports.leaveJsAsync = leaveJsAsync;
1537 exports.isWorker = isWorker; 1537 exports.isWorker = isWorker;
1538 exports.startRootIsolate = startRootIsolate; 1538 exports.startRootIsolate = startRootIsolate;
1539 exports.IsolateNatives = IsolateNatives; 1539 exports.IsolateNatives = IsolateNatives;
1540 exports.RawReceivePortImpl = RawReceivePortImpl; 1540 exports.RawReceivePortImpl = RawReceivePortImpl;
1541 exports.ReceivePortImpl = ReceivePortImpl; 1541 exports.ReceivePortImpl = ReceivePortImpl;
1542 exports.TimerImpl = TimerImpl; 1542 exports.TimerImpl = TimerImpl;
1543 exports.hasTimer = hasTimer; 1543 exports.hasTimer = hasTimer;
1544 exports.CapabilityImpl = CapabilityImpl; 1544 exports.CapabilityImpl = CapabilityImpl;
1545 })(_isolate_helper, core, _native_typed_data, _interceptors, _js_helper, isolate , _foreign_helper, _js_embedded_names, collection, async); 1545 })(_isolate_helper, core, _native_typed_data, _interceptors, _js_helper, isolate , _foreign_helper, _js_embedded_names, collection, async);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698