test: fix test-cluster-eaccess to work on windows
properly create an EADDRINUSE condition rather than simulating one with a plain file PR-URL: https://github.com/node-forward/node/pull/59 Reviewed-By: Bert Belder <bertbelder@gmail.com>
This commit is contained in:
parent
1f79e4f4b4
commit
28c4520bb7
37
test/fixtures/listen-on-socket-and-exit.js
vendored
Normal file
37
test/fixtures/listen-on-socket-and-exit.js
vendored
Normal file
@ -0,0 +1,37 @@
|
|||||||
|
// Copyright Joyent, Inc. and other Node contributors.
|
||||||
|
//
|
||||||
|
// Permission is hereby granted, free of charge, to any person obtaining a
|
||||||
|
// copy of this software and associated documentation files (the
|
||||||
|
// "Software"), to deal in the Software without restriction, including
|
||||||
|
// without limitation the rights to use, copy, modify, merge, publish,
|
||||||
|
// distribute, sublicense, and/or sell copies of the Software, and to permit
|
||||||
|
// persons to whom the Software is furnished to do so, subject to the
|
||||||
|
// following conditions:
|
||||||
|
//
|
||||||
|
// The above copyright notice and this permission notice shall be included
|
||||||
|
// in all copies or substantial portions of the Software.
|
||||||
|
//
|
||||||
|
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
|
||||||
|
// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
||||||
|
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
|
||||||
|
// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
|
||||||
|
// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
|
||||||
|
// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
|
||||||
|
// USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
|
|
||||||
|
// child process that listens on a socket, allows testing of an EADDRINUSE condition
|
||||||
|
|
||||||
|
var common = require('../common');
|
||||||
|
var net = require('net');
|
||||||
|
|
||||||
|
var server = net.createServer().listen(common.PIPE, function() {
|
||||||
|
console.log('child listening');
|
||||||
|
process.send('listening');
|
||||||
|
});
|
||||||
|
|
||||||
|
function onmessage() {
|
||||||
|
console.log('child exiting');
|
||||||
|
server.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
process.once('message', onmessage);
|
@ -19,13 +19,16 @@
|
|||||||
// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
|
// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
|
||||||
// USE OR OTHER DEALINGS IN THE SOFTWARE.
|
// USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
|
|
||||||
|
// test that errors propagated from cluster children are properly received in their master
|
||||||
|
// creates an EADDRINUSE condition by also forking a child process to listen on a socket
|
||||||
|
|
||||||
var common = require('../common');
|
var common = require('../common');
|
||||||
var assert = require('assert');
|
var assert = require('assert');
|
||||||
var cluster = require('cluster');
|
var cluster = require('cluster');
|
||||||
|
var fork = require('child_process').fork;
|
||||||
var fs = require('fs');
|
var fs = require('fs');
|
||||||
var net = require('net');
|
var net = require('net');
|
||||||
|
|
||||||
var socketPath = common.PIPE;
|
|
||||||
|
|
||||||
if (cluster.isMaster) {
|
if (cluster.isMaster) {
|
||||||
var worker = cluster.fork();
|
var worker = cluster.fork();
|
||||||
@ -33,28 +36,32 @@ if (cluster.isMaster) {
|
|||||||
worker.on('message', function(err) {
|
worker.on('message', function(err) {
|
||||||
gotError++;
|
gotError++;
|
||||||
console.log(err);
|
console.log(err);
|
||||||
if (process.platform === 'win32')
|
assert.strictEqual('EADDRINUSE', err.code);
|
||||||
assert.strictEqual('EACCES', err.code);
|
|
||||||
else
|
|
||||||
assert.strictEqual('EADDRINUSE', err.code);
|
|
||||||
worker.disconnect();
|
worker.disconnect();
|
||||||
});
|
});
|
||||||
process.on('exit', function() {
|
process.on('exit', function() {
|
||||||
console.log('master exited');
|
console.log('master exited');
|
||||||
try {
|
try {
|
||||||
fs.unlinkSync(socketPath);
|
fs.unlinkSync(common.PIPE);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
}
|
}
|
||||||
assert.equal(gotError, 1);
|
assert.equal(gotError, 1);
|
||||||
});
|
});
|
||||||
} else {
|
} else {
|
||||||
fs.writeFileSync(socketPath, 'some contents');
|
var cp = fork(common.fixturesDir + '/listen-on-socket-and-exit.js', { stdio: 'inherit' });
|
||||||
|
|
||||||
var server = net.createServer().listen(socketPath, function() {
|
// message from the child indicates it's ready and listening
|
||||||
console.log('here');
|
cp.on('message', function() {
|
||||||
});
|
var server = net.createServer().listen(common.PIPE, function() {
|
||||||
|
console.log('parent listening, should not be!');
|
||||||
|
});
|
||||||
|
|
||||||
server.on('error', function(err) {
|
server.on('error', function(err) {
|
||||||
process.send(err);
|
console.log('parent error, ending');
|
||||||
|
// message to child process tells it to exit
|
||||||
|
cp.send('end');
|
||||||
|
// propagate error to parent
|
||||||
|
process.send(err);
|
||||||
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user