summaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/worker-farm/lib/child/index.js
diff options
context:
space:
mode:
Diffstat (limited to 'deps/npm/node_modules/worker-farm/lib/child/index.js')
-rw-r--r--deps/npm/node_modules/worker-farm/lib/child/index.js52
1 files changed, 52 insertions, 0 deletions
diff --git a/deps/npm/node_modules/worker-farm/lib/child/index.js b/deps/npm/node_modules/worker-farm/lib/child/index.js
new file mode 100644
index 0000000000..f91e08433a
--- /dev/null
+++ b/deps/npm/node_modules/worker-farm/lib/child/index.js
@@ -0,0 +1,52 @@
+'use strict'
+
+let $module
+
+/*
+ let contextProto = this.context;
+ while (contextProto = Object.getPrototypeOf(contextProto)) {
+ completionGroups.push(Object.getOwnPropertyNames(contextProto));
+ }
+*/
+
+
+function handle (data) {
+ let idx = data.idx
+ , child = data.child
+ , method = data.method
+ , args = data.args
+ , callback = function () {
+ let _args = Array.prototype.slice.call(arguments)
+ if (_args[0] instanceof Error) {
+ let e = _args[0]
+ _args[0] = {
+ '$error' : '$error'
+ , 'type' : e.constructor.name
+ , 'message' : e.message
+ , 'stack' : e.stack
+ }
+ Object.keys(e).forEach(function(key) {
+ _args[0][key] = e[key]
+ })
+ }
+ process.send({ idx: idx, child: child, args: _args })
+ }
+ , exec
+
+ if (method == null && typeof $module == 'function')
+ exec = $module
+ else if (typeof $module[method] == 'function')
+ exec = $module[method]
+
+ if (!exec)
+ return console.error('NO SUCH METHOD:', method)
+
+ exec.apply(null, args.concat([ callback ]))
+}
+
+
+process.on('message', function (data) {
+ if (!$module) return $module = require(data.module)
+ if (data == 'die') return process.exit(0)
+ handle(data)
+})