|
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 | } |
0 commit comments