Try multiple ports

This commit is contained in:
Tim Schaub
2015-07-09 10:49:24 -06:00
parent 7780d77ade
commit 4549d2f7a8
2 changed files with 42 additions and 9 deletions

View File

@@ -40,6 +40,36 @@ var createServer = exports.createServer = function(callback) {
}); });
}; };
/**
* Try listening for incoming connections on a range of ports.
* @param {number} min Minimum port to try.
* @param {number} max Maximum port to try.
* @param {http.Server} server The server.
* @param {function(Error)} callback Callback called with any error.
*/
function listen(min, max, server, callback) {
function _listen(port) {
server.once('error', function(err) {
if (err.code === 'EADDRINUSE') {
log.warn(name, 'Port %d in use, trying next one', port);
++port;
if (port < max) {
_listen(port);
} else {
callback(new Error('Could not find an open port'));
}
} else {
callback(err);
}
});
server.listen(port);
}
server.once('listening', function() {
callback(null);
});
_listen(min);
}
/** /**
* If running this module directly start the server. * If running this module directly start the server.
*/ */
@@ -47,8 +77,8 @@ if (require.main === module) {
var options = nomnom.options({ var options = nomnom.options({
port: { port: {
abbr: 'p', abbr: 'p',
default: 3001, default: 3000,
help: 'Port for incoming connections', help: 'Port for incoming connections (will try additional ports if used)',
metavar: 'PORT' metavar: 'PORT'
}, },
loglevel: { loglevel: {
@@ -70,13 +100,13 @@ if (require.main === module) {
log.error(name, err.message); log.error(name, err.message);
process.exit(1); process.exit(1);
} }
server.listen(options.port, function() { listen(options.port, options.port + 4, server, function(err) {
if (err) {
log.error(name, 'Server failed to start: ' + err.message);
process.exit(1);
}
log.info(name, 'Debug server running http://localhost:' + log.info(name, 'Debug server running http://localhost:' +
options.port + '/loader.js (Ctrl+C to stop)'); server.address().port + '/loader.js (Ctrl+C to stop)');
});
server.on('error', function(err) {
log.error(name, 'Server failed to start: ' + err.message);
process.exit(1);
}); });
}); });

View File

@@ -31,8 +31,11 @@ function listen(min, max, server, callback) {
callback(err); callback(err);
} }
}); });
server.listen(port, '127.0.0.1', callback); server.listen(port, '127.0.0.1');
} }
server.once('listening', function() {
callback(null);
});
_listen(min); _listen(min);
} }