|
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