summaryrefslogtreecommitdiff
path: root/test/parallel/test-cluster-server-restart-rr.js
blob: 63edaf9fac7b8d157ed57bf4f54d9807693bfadd (plain)
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
'use strict';
const common = require('../common');
const assert = require('assert');
const cluster = require('cluster');

cluster.schedulingPolicy = cluster.SCHED_RR;

if (cluster.isMaster) {
  const worker1 = cluster.fork();
  worker1.on('listening', common.mustCall(() => {
    const worker2 = cluster.fork();
    worker2.on('exit', (code, signal) => {
      assert.strictEqual(
        code,
        0,
        `worker${worker2.id} did not exit normally. Exit with code: ${code}`
      );
      assert.strictEqual(
        signal,
        null,
        `worker${worker2.id} did not exit normally. Exit with signal: ${signal}`
      );
      worker1.disconnect();
    });
  }));

  worker1.on('exit', common.mustCall((code, signal) => {
    assert.strictEqual(
      code,
      0,
      `worker${worker1.id} did not exit normally. Exit with code: ${code}`
    );
    assert.strictEqual(
      signal,
      null,
      `worker${worker1.id} did not exit normally. Exit with code: ${signal}`
    );
  }));
} else {
  const net = require('net');
  const server = net.createServer();
  server.listen(0, common.mustCall(() => {
    if (cluster.worker.id === 2) {
      server.close(() => {
        server.listen(0, common.mustCall(() => {
          server.close(() => {
            process.disconnect();
          });
        }));
      });
    }
  }));
}