summaryrefslogtreecommitdiff
path: root/test/parallel/test-cluster-server-restart-rr.js
diff options
context:
space:
mode:
authorSantiago Gimeno <santiago.gimeno@gmail.com>2016-05-25 23:14:41 +0200
committerSantiago Gimeno <santiago.gimeno@gmail.com>2016-05-27 18:43:09 +0200
commit0c294362502684b9273e7e7c7039ec7028471014 (patch)
tree2683ec68840113e1b9ee4027ed56ece9e4b97039 /test/parallel/test-cluster-server-restart-rr.js
parente916218ba5fd5a0e9cf104ecd3cd5e9db1f325fc (diff)
downloadnode-new-0c294362502684b9273e7e7c7039ec7028471014.tar.gz
cluster: reset handle index on close
It allows reopening a server after it has been closed. Fixes: https://github.com/nodejs/node/issues/6693 PR-URL: https://github.com/nodejs/node/pull/6981 Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl> Reviewed-By: Colin Ihrig <cjihrig@gmail.com> Reviewed-By: Ron Korving <ron@ronkorving.nl> Reviewed-By: James M Snell <jasnell@gmail.com>
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();
+ });
+ }));
+ });
+ }
+ }));
+}