125 lines
2.9 KiB
JavaScript
125 lines
2.9 KiB
JavaScript
|
||
/*!
|
||
* Cluster - debug
|
||
* Copyright (c) 2011 LearnBoost <dev@learnboost.com>
|
||
* MIT Licensed
|
||
*/
|
||
|
||
/**
|
||
* Enable verbose debugging output.
|
||
*
|
||
* @return {Function}
|
||
* @api public
|
||
*/
|
||
|
||
module.exports = function(options){
|
||
options = options || {};
|
||
|
||
// strip colors
|
||
|
||
function color(text) {
|
||
if (options.colors === false) return text.replace(/\033\[\d+m/g, '');
|
||
return text
|
||
}
|
||
|
||
// logger
|
||
|
||
var log = {
|
||
debug: function(str){
|
||
console.error(color(' \033[90mdebug - %s\033[0m'), str);
|
||
},
|
||
info: function(str){
|
||
console.error(color(' info \033[90m- %s\033[0m'), str);
|
||
},
|
||
warning: function(str){
|
||
console.error(color(' \033[33mwarning\033[0m \033[90m- %s\033[0m'), str);
|
||
},
|
||
error: function(str){
|
||
console.error(color(' \033[31merror\033[0m \033[90m- %s\033[0m'), str);
|
||
}
|
||
};
|
||
|
||
return function(master){
|
||
|
||
// start
|
||
master.on('start', function(){
|
||
log.info('master started');
|
||
});
|
||
|
||
// closing
|
||
master.on('closing', function(){
|
||
log.info('shutting down');
|
||
});
|
||
|
||
// close
|
||
master.on('close', function(){
|
||
log.info('shutdown complete');
|
||
});
|
||
|
||
// killing workers
|
||
master.on('kill', function(sig){
|
||
log.warning('kill(' + (sig || 'SIGTERM') + ')');
|
||
});
|
||
|
||
// worker died
|
||
master.on('worker killed', function(worker){
|
||
if ('restarting' == master.state) return;
|
||
log.warning('worker ' + worker.id + ' died');
|
||
});
|
||
|
||
// worker exception
|
||
master.on('worker exception', function(worker, err){
|
||
log.error('worker ' + worker.id + ' uncaught exception ' + err.message);
|
||
});
|
||
|
||
// worker is waiting on connections to be closed
|
||
master.on('worker waiting', function(worker, connections){
|
||
log.warning('worker ' + worker.id + ' waiting on ' + connections + ' connections');
|
||
});
|
||
|
||
// worker has timed out
|
||
master.on('worker timeout', function(worker, timeout){
|
||
log.warning('worker ' + worker.id + ' timed out after ' + timeout + 'ms');
|
||
});
|
||
|
||
// connection
|
||
master.on('worker connected', function(worker){
|
||
log.info('worker ' + worker.id + ' connected');
|
||
});
|
||
|
||
// removed
|
||
master.on('worker removed', function(worker){
|
||
log.info('worker ' + worker.id + ' removed');
|
||
});
|
||
|
||
// worker
|
||
master.on('worker', function(worker){
|
||
log.info('worker ' + worker.id + ' spawned');
|
||
});
|
||
|
||
// listening
|
||
master.on('listening', function(){
|
||
log.info('listening for connections');
|
||
});
|
||
|
||
// cyclic or immediate restart
|
||
master.on('cyclic restart', function(){
|
||
log.warning('cyclic restart detected, restarting in ' + master.options['restart timeout'] + 'ms');
|
||
});
|
||
|
||
// restart requested
|
||
master.on('restarting', function(){
|
||
log.info('restart requested');
|
||
});
|
||
|
||
// restart complete
|
||
master.on('restart', function(){
|
||
log.info('restart complete');
|
||
});
|
||
|
||
// exit
|
||
process.on('exit', function(){
|
||
log.debug('exit');
|
||
});
|
||
}
|
||
}; |