|
1 | 1 | 'use strict';
|
2 |
| -var common = require('../common'); |
3 |
| -var assert = require('assert'); |
4 |
| -var cluster = require('cluster'); |
5 |
| -var net = require('net'); |
| 2 | +const common = require('../common'); |
| 3 | +const assert = require('assert'); |
| 4 | +const cluster = require('cluster'); |
| 5 | +const net = require('net'); |
6 | 6 |
|
7 | 7 | if (cluster.isMaster) {
|
8 | 8 | // Master opens and binds the socket and shares it with the worker.
|
9 | 9 | cluster.schedulingPolicy = cluster.SCHED_NONE;
|
10 | 10 | // Hog the TCP port so that when the worker tries to bind, it'll fail.
|
11 |
| - net.createServer(common.fail).listen(common.PORT, function() { |
12 |
| - var server = this; |
13 |
| - var worker = cluster.fork(); |
14 |
| - worker.on('exit', common.mustCall(function(exitCode) { |
| 11 | + const server = net.createServer(common.fail); |
| 12 | + |
| 13 | + server.listen(common.PORT, common.mustCall(() => { |
| 14 | + const worker = cluster.fork(); |
| 15 | + worker.on('exit', common.mustCall((exitCode) => { |
15 | 16 | assert.strictEqual(exitCode, 0);
|
16 | 17 | server.close();
|
17 | 18 | }));
|
18 |
| - }); |
| 19 | + })); |
19 | 20 | } else {
|
20 |
| - var s = net.createServer(common.fail); |
| 21 | + const s = net.createServer(common.fail); |
21 | 22 | s.listen(common.PORT, common.fail.bind(null, 'listen should have failed'));
|
22 |
| - s.on('error', common.mustCall(function(err) { |
| 23 | + s.on('error', common.mustCall((err) => { |
23 | 24 | assert.strictEqual(err.code, 'EADDRINUSE');
|
24 | 25 | process.disconnect();
|
25 | 26 | }));
|
|
0 commit comments