summaryrefslogtreecommitdiff
path: root/test/parallel/test-cluster-server-restart-rr.js
diff options
context:
space:
mode:
Diffstat (limited to 'test/parallel/test-cluster-server-restart-rr.js')
-rw-r--r--test/parallel/test-cluster-server-restart-rr.js37
1 files changed, 37 insertions, 0 deletions
diff --git a/test/parallel/test-cluster-server-restart-rr.js b/test/parallel/test-cluster-server-restart-rr.js
new file mode 100644
index 0000000000..724a77b71a
--- /dev/null
+++ b/test/parallel/test-cluster-server-restart-rr.js
@@ -0,0 +1,37 @@
+'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, 'worker2 did not exit normally');
+ assert.strictEqual(signal, null, 'worker2 did not exit normally');
+ worker1.disconnect();
+ });
+ }));
+
+ worker1.on('exit', common.mustCall((code, signal) => {
+ assert.strictEqual(code, 0, 'worker1 did not exit normally');
+ assert.strictEqual(signal, null, 'worker1 did not exit normally');
+ }));
+} else {
+ const net = require('net');
+ const server = net.createServer();
+ server.listen(common.PORT, common.mustCall(() => {
+ if (cluster.worker.id === 2) {
+ server.close(() => {
+ server.listen(common.PORT, common.mustCall(() => {
+ server.close(() => {
+ process.disconnect();
+ });
+ }));
+ });
+ }
+ }));
+}