| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent b3fccc2 commit cec5e36
1 file changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -3,30 +3,25 @@ | |||
| 3 | 3 | // verifies that, when a child process is forked, the cluster.worker | |
| 4 | 4 | // object can receive messages as expected | |
| 5 | 5 | ||
| 6 | - require('../common'); | ||
| 7 | - var assert = require('assert'); | ||
| 8 | - var cluster = require('cluster'); | ||
| 9 | - var msg = 'foo'; | ||
| 6 | + const common = require('../common'); | ||
| 7 | + const assert = require('assert'); | ||
| 8 | + const cluster = require('cluster'); | ||
| 9 | + const msg = 'foo'; | ||
| 10 | 10 | ||
| 11 | 11 | if (cluster.isMaster) { | |
| 12 | - var worker = cluster.fork(); | ||
| 13 | - var timer = setTimeout(function() { | ||
| 14 | - assert(false, 'message not received'); | ||
| 15 | - }, 5000); | ||
| 12 | + const worker = cluster.fork(); | ||
| 16 | 13 | ||
| 17 | - timer.unref(); | ||
| 18 | - | ||
| 19 | - worker.on('message', function(message) { | ||
| 20 | - assert(message, 'did not receive expected message'); | ||
| 14 | + worker.on('message', common.mustCall((message) => { | ||
| 15 | + assert.strictEqual(message, true, 'did not receive expected message'); | ||
| 21 | 16 | worker.disconnect(); | |
| 22 | - }); | ||
| 17 | + })); | ||
| 23 | 18 | ||
| 24 | - worker.on('online', function() { | ||
| 19 | + worker.on('online', () => { | ||
| 25 | 20 | worker.send(msg); | |
| 26 | 21 | }); | |
| 27 | 22 | } else { | |
| 28 | 23 | // GH #7998 | |
| 29 | - cluster.worker.on('message', function(message) { | ||
| 24 | + cluster.worker.on('message', (message) => { | ||
| 30 | 25 | process.send(message === msg); | |
| 31 | 26 | }); | |
| 32 | 27 | } | |
| Back | FazBrowse Home | New Git URL |
0 commit comments