@@ -189,7 +189,7 @@ forever.startDaemon = function (script, options) {
189
189
options . pidFile = forever . pidFilePath ( options . pidFile || options . uid + '.pid' ) ;
190
190
191
191
var monitor = new forever . Monitor ( script , options ) ;
192
-
192
+
193
193
fs . open ( options . logFile , options . appendLog ? 'a+' : 'w+' , function ( err , fd ) {
194
194
if ( err ) {
195
195
return monitor . emit ( 'error' , err ) ;
@@ -225,53 +225,47 @@ forever.startServer = function () {
225
225
current = getData ( ) ,
226
226
socket = path . join ( forever . config . get ( 'sockPath' ) , 'forever.sock' ) ,
227
227
server ;
228
-
228
+
229
229
function getData ( ) {
230
230
return monitors . map ( function ( m ) { return m . data } ) ;
231
231
}
232
-
232
+
233
233
function formatProc ( proc ) {
234
234
var info = [
235
235
proc . command ,
236
236
proc . file ,
237
237
':' ,
238
238
proc . uid
239
239
] . join ( ' ' ) ;
240
-
240
+
241
241
return '[' + info + ']'
242
242
}
243
-
243
+
244
244
server = net . createServer ( function ( socket ) {
245
245
//
246
246
// Write the specified data and close the socket
247
247
//
248
248
socket . end ( JSON . stringify ( { monitors : getData ( ) } ) ) ;
249
249
} ) ;
250
-
250
+
251
251
portfinder . getSocket ( { path : socket } , function ( err , socket ) {
252
252
if ( err ) {
253
253
//
254
254
// TODO: This is really bad.
255
255
//
256
256
}
257
-
258
- server . on ( 'error' , function ( ) {
257
+
258
+ server . on ( 'error' , function ( ) {
259
259
//
260
260
// TODO: This is really bad.
261
261
//
262
262
} ) ;
263
-
263
+
264
264
server . listen ( socket , function ( ) {
265
265
if ( callback ) {
266
266
callback ( null , server , socket ) ;
267
267
}
268
- } ) ;
269
-
270
- process . title = [
271
- 'forever' ,
272
- current . map ( function ( p ) { return formatProc ( p ) } ) ,
273
- socket
274
- ] . join ( ' ' ) ;
268
+ } ) ;
275
269
} ) ;
276
270
} ;
277
271
@@ -405,14 +399,14 @@ forever.findByScript = function (script, processes) {
405
399
//
406
400
forever . stopAll = function ( format ) {
407
401
var emitter = new events . EventEmitter ( ) ;
408
-
402
+
409
403
getAllProcesses ( function ( processes ) {
410
404
var pids = getAllPids ( processes ) ;
411
405
412
406
if ( format ) {
413
407
processes = forever . format ( format , processes ) ;
414
408
}
415
-
409
+
416
410
if ( pids && processes ) {
417
411
var fPids = pids . map ( function ( pid ) { return pid . foreverPid } ) ,
418
412
cPids = pids . map ( function ( pid ) { return pid . pid } ) ;
@@ -436,7 +430,7 @@ forever.stopAll = function (format) {
436
430
} ) ;
437
431
}
438
432
} ) ;
439
-
433
+
440
434
return emitter ;
441
435
} ;
442
436
@@ -449,14 +443,14 @@ forever.stopAll = function (format) {
449
443
forever . list = function ( format , callback ) {
450
444
getAllProcesses ( function ( processes ) {
451
445
callback ( null , forever . format ( format , processes ) ) ;
452
- } ) ;
446
+ } ) ;
453
447
} ;
454
448
455
449
forever . format = function ( format , procs ) {
456
450
if ( ! procs || procs . length === 0 ) {
457
451
return null ;
458
452
}
459
-
453
+
460
454
if ( format ) {
461
455
var index = 0 , rows = [
462
456
[ ' ' , 'uid' , 'command ' , 'script' , 'forever ' , 'pid' , 'logfile' , 'uptime' ]
@@ -521,14 +515,14 @@ forever.cleanUp = function (cleanLogs, allowManager) {
521
515
//
522
516
// If we are cleaning logs then do so if the process
523
517
// has a logfile.
524
- //
518
+ //
525
519
return fs . unlink ( proc . logFile , function ( ) {
526
520
done ( ) ;
527
521
} ) ;
528
522
}
529
523
530
524
done ( ) ;
531
- } ) ;
525
+ } ) ;
532
526
}
533
527
534
528
function cleanProcess ( proc , done ) {
@@ -682,27 +676,27 @@ function getAllProcesses (callback) {
682
676
if ( sockets . length === 0 ) {
683
677
return callback ( ) ;
684
678
}
685
-
679
+
686
680
function getProcess ( name , next ) {
687
681
var fullPath = path . join ( sockPath , name ) ,
688
682
socket = new net . Socket ( { type : 'unix' } ) ;
689
-
683
+
690
684
socket . on ( 'error' , function ( err ) {
691
685
if ( err . code === 'ECONNREFUSED' ) {
692
686
try { fs . unlinkSync ( fullPath ) }
693
687
catch ( ex ) { }
694
688
return next ( ) ;
695
689
}
696
-
690
+
697
691
next ( err ) ;
698
692
} ) ;
699
-
693
+
700
694
socket . on ( 'data' , function ( data ) {
701
695
var monitors = JSON . parse ( data . toString ( ) ) ;
702
696
results . push . apply ( results , monitors . monitors ) ;
703
697
next ( ) ;
704
698
} ) ;
705
-
699
+
706
700
socket . connect ( fullPath ) ;
707
701
}
708
702
0 commit comments