| OLD | NEW |
| 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 var isolate$current = null; | 5 var isolate$current = null; |
| 6 var isolate$rootIsolate = null; // Will only be set in the main worker. | 6 var isolate$rootIsolate = null; // Will only be set in the main worker. |
| 7 var isolate$inits = []; | 7 var isolate$inits = []; |
| 8 var isolate$globalThis = this; | 8 var isolate$globalThis = this; |
| 9 | 9 |
| 10 var isolate$inWorker = | 10 var isolate$inWorker = |
| (...skipping 18 matching lines...) Expand all Loading... |
| 29 // isolate$useWorkerSerializationProtocol = true; | 29 // isolate$useWorkerSerializationProtocol = true; |
| 30 | 30 |
| 31 | 31 |
| 32 // ------- SendPort ------- | 32 // ------- SendPort ------- |
| 33 | 33 |
| 34 function isolate$receiveMessage(port, isolate, | 34 function isolate$receiveMessage(port, isolate, |
| 35 serializedMessage, serializedReplyTo) { | 35 serializedMessage, serializedReplyTo) { |
| 36 isolate$IsolateEvent.enqueue(isolate, function() { | 36 isolate$IsolateEvent.enqueue(isolate, function() { |
| 37 var message = isolate$deserializeMessage(serializedMessage); | 37 var message = isolate$deserializeMessage(serializedMessage); |
| 38 var replyTo = isolate$deserializeMessage(serializedReplyTo); | 38 var replyTo = isolate$deserializeMessage(serializedReplyTo); |
| 39 port._callback(message, replyTo); | 39 if (port._callback) port._callback(message, replyTo); |
| 40 }); | 40 }); |
| 41 } | 41 } |
| 42 | 42 |
| 43 // -------- Registry --------- | 43 // -------- Registry --------- |
| 44 function isolate$Registry() { | 44 function isolate$Registry() { |
| 45 this.map = {}; | 45 this.map = {}; |
| 46 this.count = 0; | 46 this.count = 0; |
| 47 } | 47 } |
| 48 | 48 |
| 49 isolate$Registry.prototype.register = function(id, val) { | 49 isolate$Registry.prototype.register = function(id, val) { |
| (...skipping 433 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 483 function isolate$deserializeMessage(message_) { | 483 function isolate$deserializeMessage(message_) { |
| 484 if (isolate$useWorkers || isolate$useWorkerSerializationProtocol) { | 484 if (isolate$useWorkers || isolate$useWorkerSerializationProtocol) { |
| 485 return _IsolateJsUtil._deserializeMessage(message_); | 485 return _IsolateJsUtil._deserializeMessage(message_); |
| 486 } else { | 486 } else { |
| 487 // Nothing more to do. | 487 // Nothing more to do. |
| 488 return message_; | 488 return message_; |
| 489 } | 489 } |
| 490 } | 490 } |
| 491 | 491 |
| 492 function _IsolateJsUtil() {} | 492 function _IsolateJsUtil() {} |
| OLD | NEW |