1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
// Flags: --inspect=0
'use strict';
const common = require('../common');
const assert = require('assert');
// With the current behavior of Node.js (at least as late as 8.1.0), this
// test fails with the following error:
// `AssertionError [ERR_ASSERTION]: worker 2 failed to bind port`
// Ideally, there would be a way for the user to opt out of sequential port
// assignment.
//
// Refs: https://github.com/nodejs/node/issues/13343
// This following check should be replaced by common.skipIfInspectorDisabled()
// if moved out of the known_issues directory.
if (!process.features.inspector) {
// When the V8 inspector is disabled, using either --without-inspector or
// --without-ssl, this test will not fail which it is expected to do.
// The following fail will allow this test to be skipped by failing it.
assert.fail('skipping as V8 inspector is disabled');
}
const cluster = require('cluster');
const net = require('net');
const ports = [process.debugPort];
const clashPort = process.debugPort + 2;
function serialFork() {
return new Promise((res) => {
const worker = cluster.fork();
worker.on('error', (err) => assert.fail(err));
// no common.mustCall since 1 out of 3 should fail
worker.on('online', () => {
worker.on('message', common.mustCall((message) => {
ports.push(message.debugPort);
}));
});
worker.on('exit', common.mustCall((code, signal) => {
assert.strictEqual(signal, null);
// worker 2 should fail because of port clash with `server`
if (code === 12) {
return assert.fail(`worker ${worker.id} failed to bind port`);
}
assert.strictEqual(code, 0);
}));
worker.on('disconnect', common.mustCall(res));
});
}
if (cluster.isMaster) {
cluster.on('online', common.mustCall((worker) => worker.send('dbgport'), 2));
// block one of the ports with a listening socket
const server = net.createServer();
server.listen(clashPort, common.localhostIPv4, common.mustCall(() => {
// try to fork 3 workers No.2 should fail
Promise.all([serialFork(), serialFork(), serialFork()])
.then(common.mustNotCall())
.catch((err) => console.error(err));
}));
server.unref();
} else {
const sentinel = common.mustCall();
process.on('message', (message) => {
if (message !== 'dbgport') return;
process.send({ debugPort: process.debugPort });
sentinel();
process.disconnect();
});
}
|
