diff options
author | Santiago Gimeno <santiago.gimeno@gmail.com> | 2016-05-25 23:14:41 +0200 |
---|---|---|
committer | Santiago Gimeno <santiago.gimeno@gmail.com> | 2016-05-27 18:43:09 +0200 |
commit | 0c294362502684b9273e7e7c7039ec7028471014 (patch) | |
tree | 2683ec68840113e1b9ee4027ed56ece9e4b97039 /test/parallel/test-cluster-server-restart-rr.js | |
parent | e916218ba5fd5a0e9cf104ecd3cd5e9db1f325fc (diff) | |
download | node-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.js | 37 |
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(); + }); + })); + }); + } + })); +} |