-
Notifications
You must be signed in to change notification settings - Fork 159
/
debug.js
95 lines (78 loc) · 2.01 KB
/
debug.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
/*!
* Cluster - debug
* Copyright (c) 2010 LearnBoost <dev@learnboost.com>
* MIT Licensed
*/
/**
* Logger.
*/
var log = {
info: function(str){
console.error(' info \033[90m- %s\033[0m', str);
},
warning: function(str){
console.error(' \033[33mwarning\033[0m \033[90m- %s\033[0m', str);
},
error: function(str){
console.error(' \033[31merror\033[0m \033[90m- %s\033[0m', str);
}
};
/**
* Enable verbose debugging output.
*
* @return {Function}
* @api public
*/
module.exports = function(){
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 is waiting on connections to be closed
master.on('worker waiting', function(worker, connections){
log.warning('worker ' + worker.id + ' waiting on ' + connections + ' connections');
});
// connection
master.on('worker connected', function(worker){
log.info('worker ' + worker.id + ' connected');
});
// worker
master.on('worker', function(worker){
log.info('worker ' + worker.id + ' spawned');
});
// listening
master.on('listening', function(){
log.info('listening for connections');
});
// broadcasting
master.on('broadcast', function(cmd, args){
log.info('broadcast ' + cmd);
});
// sending PONG
master.on('pong', function(worker){
log.info('received PING from ' + worker.id);
});
// restart requested
master.on('restart', function(){
log.info('restart requested');
});
}
};