Revision 212eb8a5 lib/child_process.js
| lib/child_process.js | ||
|---|---|---|
| 305 | 305 |
return socketList; |
| 306 | 306 |
} |
| 307 | 307 |
|
| 308 |
var INTERNAL_PREFIX = 'NODE_'; |
|
| 308 | 309 |
function handleMessage(target, message, handle) {
|
| 309 |
//Filter out internal messages |
|
| 310 |
//if cmd property begin with "_NODE" |
|
| 310 |
var eventName = 'message'; |
|
| 311 | 311 |
if (message !== null && |
| 312 | 312 |
typeof message === 'object' && |
| 313 | 313 |
typeof message.cmd === 'string' && |
| 314 |
message.cmd.indexOf('NODE_') === 0) {
|
|
| 315 |
target.emit('internalMessage', message, handle);
|
|
| 316 |
} |
|
| 317 |
//Non-internal message |
|
| 318 |
else {
|
|
| 319 |
target.emit('message', message, handle);
|
|
| 314 |
message.cmd.length > INTERNAL_PREFIX.length && |
|
| 315 |
message.cmd.slice(0, INTERNAL_PREFIX.length) === INTERNAL_PREFIX) {
|
|
| 316 |
eventName = 'internalMessage'; |
|
| 320 | 317 |
} |
| 318 |
target.emit(eventName, message, handle); |
|
| 321 | 319 |
} |
| 322 | 320 |
|
| 323 | 321 |
function setupChannel(target, channel) {
|
Also available in: Unified diff