+11
-3
@@ -153,6 +153,14 @@ var cp = require('child_process'); | ||
| killChild(); | ||
| errMsg = errMsg && errMsg + ''; | ||
| err = typeof err === 'string' ? err : (err && err.stack); | ||
| errMsg = err || errMsg || 'unknown'; | ||
| try { | ||
| process.emit('pforkError', { | ||
| script: options.script, | ||
| value: options.value, | ||
| message: errMsg | ||
| }); | ||
| } catch (e) {} | ||
| process.nextTick(function() { | ||
| errMsg = errMsg && errMsg + ''; | ||
| err = typeof err === 'string' ? err : (err && err.stack); | ||
| callbackHandler(err || errMsg || 'unknown'); | ||
| callbackHandler(errMsg); | ||
| }); | ||
@@ -159,0 +167,0 @@ } |
+7
-3
@@ -53,10 +53,14 @@ var assert = require('assert'); | ||
| process.on('uncaughtException', function (e) { | ||
| function handleError(e) { | ||
| var data = e ? (e.stack || e.message || String(e)) : 'unhandledRejection'; | ||
| processSend(JSON.stringify({ | ||
| type: ERROR, | ||
| data: e.stack | ||
| data: data | ||
| })); | ||
| setTimeout(errorHandler, HEARTBEAT_TIMEOUT); | ||
| }); | ||
| } | ||
| process.on('unhandledRejection', handleError); | ||
| process.on('uncaughtException', handleError); | ||
| var execScript = require(script); | ||
@@ -63,0 +67,0 @@ assert(typeof execScript == 'function', script + ' not a function'); |
+1
-1
| { | ||
| "name": "pfork", | ||
| "description": "fork process", | ||
| "version": "0.5.1", | ||
| "version": "0.5.2", | ||
| "main": "lib/index.js", | ||
@@ -6,0 +6,0 @@ "author": "avenwu <avenwu@vip.qq.com>", |
12890
2.56%388
2.92%