| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 19b314e commit 6db76da
1 file changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1,36 +1,36 @@ | |||
| 1 | 1 | 'use strict'; | |
| 2 | 2 | // Testing to send an handle twice to the parent process. | |
| 3 | 3 | ||
| 4 | - var common = require('../common'); | ||
| 5 | - var assert = require('assert'); | ||
| 6 | - var cluster = require('cluster'); | ||
| 7 | - var net = require('net'); | ||
| 4 | + const common = require('../common'); | ||
| 5 | + const assert = require('assert'); | ||
| 6 | + const cluster = require('cluster'); | ||
| 7 | + const net = require('net'); | ||
| 8 | 8 | ||
| 9 | - var workers = { | ||
| 9 | + const workers = { | ||
| 10 | 10 | toStart: 1 | |
| 11 | 11 | }; | |
| 12 | 12 | ||
| 13 | 13 | if (cluster.isMaster) { | |
| 14 | - for (var i = 0; i < workers.toStart; ++i) { | ||
| 15 | - var worker = cluster.fork(); | ||
| 16 | - worker.on('exit', function(code, signal) { | ||
| 14 | + for (let i = 0; i < workers.toStart; ++i) { | ||
| 15 | + const worker = cluster.fork(); | ||
| 16 | + worker.on('exit', common.mustCall(function(code, signal) { | ||
| 17 | 17 | assert.strictEqual(code, 0, 'Worker exited with an error code'); | |
| 18 | - assert(!signal, 'Worker exited by a signal'); | ||
| 19 | - }); | ||
| 18 | + assert.strictEqual(signal, null, 'Worker exited by a signal'); | ||
| 19 | + })); | ||
| 20 | 20 | } | |
| 21 | 21 | } else { | |
| 22 | - var server = net.createServer(function(socket) { | ||
| 22 | + const server = net.createServer(function(socket) { | ||
| 23 | 23 | process.send('send-handle-1', socket); | |
| 24 | 24 | process.send('send-handle-2', socket); | |
| 25 | 25 | }); | |
| 26 | 26 | ||
| 27 | 27 | server.listen(common.PORT, function() { | |
| 28 | - var client = net.connect({ host: 'localhost', port: common.PORT }); | ||
| 29 | - client.on('close', function() { cluster.worker.disconnect(); }); | ||
| 28 | + const client = net.connect({ host: 'localhost', port: common.PORT }); | ||
| 29 | + client.on('close', common.mustCall(() => { cluster.worker.disconnect(); })); | ||
| 30 | 30 | setTimeout(function() { client.end(); }, 50); | |
| 31 | 31 | }).on('error', function(e) { | |
| 32 | 32 | console.error(e); | |
| 33 | - assert(false, 'server.listen failed'); | ||
| 33 | + common.fail('server.listen failed'); | ||
| 34 | 34 | cluster.worker.disconnect(); | |
| 35 | 35 | }); | |
| 36 | 36 | } | |
| Back | FazBrowse Home | New Git URL |
0 commit comments