-
Notifications
You must be signed in to change notification settings - Fork 28.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
a07c691
commit fab6db9
Showing
62 changed files
with
3,763 additions
and
507 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,210 @@ | ||
| 'use strict'; | ||
|
|
||
| if (!process.features.experimental_workers) { | ||
| throw new Error('Experimental workers are disabled'); | ||
| } | ||
|
|
||
| const util = require('util'); | ||
| const assert = require('assert'); | ||
| const EventEmitter = require('events'); | ||
| const WorkerContextBinding = process.binding('WorkerContext'); | ||
| const JSONStringify = function(value) { | ||
| if (value === undefined) value = null; | ||
| return JSON.stringify(value); | ||
| }; | ||
| const JSONParse = JSON.parse; | ||
| const EMPTY_ARRAY = []; | ||
|
|
||
| const workerContextSymbol = Symbol('workerContext'); | ||
| const installEventsSymbol = Symbol('installEvents'); | ||
| const checkAliveSymbol = Symbol('checkAlive'); | ||
| const initSymbol = WorkerContextBinding.initSymbol; | ||
|
|
||
| const builtinErrorTypes = new Map([ | ||
| Error, SyntaxError, RangeError, URIError, TypeError, EvalError, ReferenceError | ||
| ].map(function(Type) { | ||
| return [Type.name, Type]; | ||
| })); | ||
|
|
||
| const Worker = WorkerContextBinding.JsConstructor; | ||
| util.inherits(Worker, EventEmitter); | ||
|
|
||
| Worker.prototype[initSymbol] = function(entryModulePath, options) { | ||
| if (typeof entryModulePath !== 'string') | ||
| throw new TypeError('entryModulePath must be a string'); | ||
| EventEmitter.call(this); | ||
| options = Object(options); | ||
| var keepAlive = options.keepAlive === undefined ? true : !!options.keepAlive; | ||
| this[workerContextSymbol] = | ||
| new WorkerContextBinding.WorkerContext(entryModulePath, | ||
| {keepAlive: keepAlive}); | ||
| this[installEventsSymbol](); | ||
| }; | ||
|
|
||
| Worker.prototype[installEventsSymbol] = function() { | ||
| const workerObject = this; | ||
| const workerContext = this[workerContextSymbol]; | ||
|
|
||
| const onerror = function(payload) { | ||
| var ErrorConstructor = builtinErrorTypes.get(payload.builtinType); | ||
| if (typeof ErrorConstructor !== 'function') | ||
| ErrorConstructor = Error; | ||
| const error = new ErrorConstructor(payload.message); | ||
| error.stack = payload.stack; | ||
| util._extend(error, payload.additionalProperties); | ||
| workerObject.emit('error', error); | ||
| }; | ||
|
|
||
| workerContext._onexit = function(exitCode) { | ||
| workerObject[workerContextSymbol] = null; | ||
| workerObject.emit('exit', exitCode); | ||
| }; | ||
|
|
||
| workerContext._onmessage = function(payload, messageType) { | ||
| payload = JSONParse(payload); | ||
| switch (messageType) { | ||
| case WorkerContextBinding.USER: | ||
| return workerObject.emit('message', payload); | ||
| case WorkerContextBinding.INTERNAL: | ||
| assert.fail('unreachable'); | ||
| case WorkerContextBinding.EXCEPTION: | ||
| return onerror(payload); | ||
| default: | ||
| assert.fail('unreachable'); | ||
| } | ||
| }; | ||
| }; | ||
|
|
||
| Worker.prototype[checkAliveSymbol] = function() { | ||
| if (!this[workerContextSymbol]) | ||
| throw new RangeError('this worker has been terminated'); | ||
| }; | ||
|
|
||
| Worker.prototype.postMessage = function(payload) { | ||
| this[checkAliveSymbol](); | ||
| this[workerContextSymbol].postMessage(JSONStringify(payload), | ||
| EMPTY_ARRAY, | ||
| WorkerContextBinding.USER); | ||
| }; | ||
|
|
||
| Worker.prototype.terminate = function(callback) { | ||
| this[checkAliveSymbol](); | ||
| var context = this[workerContextSymbol]; | ||
| this[workerContextSymbol] = null; | ||
| if (typeof callback === 'function') { | ||
| this.once('exit', function(exitCode) { | ||
| callback(null, exitCode); | ||
| }); | ||
| } | ||
| context.terminate(); | ||
| }; | ||
|
|
||
| Worker.prototype.ref = function() { | ||
| this[checkAliveSymbol](); | ||
| this[workerContextSymbol].ref(); | ||
| }; | ||
|
|
||
| Worker.prototype.unref = function() { | ||
| this[checkAliveSymbol](); | ||
| this[workerContextSymbol].unref(); | ||
| }; | ||
|
|
||
| if (process.isWorkerInstance) { | ||
| const postMessage = function(payload, transferList, type) { | ||
| if (!Array.isArray(transferList)) | ||
| throw new Error('transferList must be an array'); | ||
|
|
||
| WorkerContextBinding.workerWrapper._postMessage(JSONStringify(payload), | ||
| transferList, | ||
| type); | ||
| }; | ||
| const workerFatalError = function(er) { | ||
| const defaultStack = null; | ||
| const defaultMessage = '[toString() conversion failed]'; | ||
| const defaultBuiltinType = 'Error'; | ||
|
|
||
| var message = defaultMessage; | ||
| var builtinType = defaultBuiltinType; | ||
| var stack = defaultStack; | ||
| var additionalProperties = {}; | ||
|
|
||
| if (er instanceof Error) { | ||
| try { | ||
| builtinType = er.name; | ||
| } catch (ignore) {} | ||
|
|
||
| if (typeof builtinType !== 'string') | ||
| builtinType = defaultBuiltinType; | ||
|
|
||
| try { | ||
| stack = er.stack; | ||
| } catch (ignore) {} | ||
|
|
||
| if (typeof stack !== 'string') | ||
| stack = defaultStack; | ||
|
|
||
| try { | ||
| // Get inherited enumerable properties. | ||
| // .name, .stack and .message are all non-enumerable | ||
| for (var key in er) | ||
| additionalProperties[key] = er[key]; | ||
| // The message delivery must always succeed, otherwise the real cause | ||
| // of this fatal error is masked. | ||
| JSONStringify(additionalProperties); | ||
| } catch (e) { | ||
| additionalProperties = {}; | ||
| } | ||
| } | ||
|
|
||
| try { | ||
| if (er instanceof Error) { | ||
| message = er.message; | ||
| if (typeof message !== 'string') | ||
| message = '' + er; | ||
| } else { | ||
| message = '' + er; | ||
| } | ||
| } catch (e) { | ||
| message = defaultMessage; | ||
| } | ||
|
|
||
| postMessage({ | ||
| message: message, | ||
| stack: stack, | ||
| additionalProperties: additionalProperties, | ||
| builtinType: builtinType | ||
| }, EMPTY_ARRAY, WorkerContextBinding.EXCEPTION); | ||
| }; | ||
|
|
||
| util._extend(Worker, EventEmitter.prototype); | ||
| EventEmitter.call(Worker); | ||
|
|
||
| WorkerContextBinding.workerWrapper._onmessage = | ||
| function(payload, messageType) { | ||
| payload = JSONParse(payload); | ||
| switch (messageType) { | ||
| case WorkerContextBinding.USER: | ||
| return Worker.emit('message', payload); | ||
| case WorkerContextBinding.INTERNAL: | ||
| assert.fail('unreachable'); | ||
| case WorkerContextBinding.EXCEPTION: | ||
| assert.fail('unreachable'); | ||
| default: | ||
| assert.fail('unreachable'); | ||
| } | ||
| }; | ||
|
|
||
| Worker.postMessage = function(payload) { | ||
| postMessage(payload, EMPTY_ARRAY, WorkerContextBinding.USER); | ||
| }; | ||
|
|
||
| Object.defineProperty(Worker, '_workerFatalError', { | ||
| configurable: true, | ||
| writable: false, | ||
| enumerable: false, | ||
| value: workerFatalError | ||
| }); | ||
| } | ||
|
|
||
|
|
||
| module.exports = Worker; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.