Revert "fix: when reload/restart is called, listeners of stdio should be removed."

This reverts commit b94b659a1323eb7321642893f4f24f3bdbbb3301.
This commit is contained in:
Tjatse 2014-11-17 19:17:51 +08:00
parent b94b659a13
commit e90c18f486
2 changed files with 8 additions and 10 deletions

View File

@ -151,8 +151,8 @@ module.exports = function ForkMode(God) {
if (pm2_env.log_date_format)
log_data = moment().format(pm2_env.log_date_format) + ': ' + log_data;
stds.err.write && stds.err.write(log_data);
stds.std && stds.std.write && stds.std.write(log_data);
stds.err.write(log_data);
stds.std && stds.std.write(log_data);
God.bus.emit('log:err', {
process : Common.formatCLU(cspr),
@ -169,8 +169,8 @@ module.exports = function ForkMode(God) {
if (pm2_env.log_date_format)
log_data = moment().format(pm2_env.log_date_format) + ': ' + log_data;
stds.out.write && stds.out.write(log_data);
stds.std && stds.std.write && stds.std.write(log_data);
stds.out.write(log_data);
stds.std && stds.std.write(log_data);
God.bus.emit('log:out', {
process : Common.formatCLU(cspr),
@ -217,8 +217,6 @@ module.exports = function ForkMode(God) {
stds[k].close();
stds[k] = stds[k]._file;
}
cspr.stdout.removeAllListeners();
cspr.stderr.removeAllListeners();
startLogging(cb);
};

View File

@ -170,8 +170,8 @@ function exec(script, stds) {
var log_data = string.toString();
if (process.env.log_date_format && moment)
log_data = moment().format(process.env.log_date_format) + ': ' + log_data;
stds.err.write && stds.err.write(log_data);
stds.std && stds.std.write && stds.std.write(log_data);
stds.err.write(log_data);
stds.std && stds.std.write(log_data);
process.send({
type : 'log:err',
data : string
@ -185,8 +185,8 @@ function exec(script, stds) {
var log_data = string.toString();
if (process.env.log_date_format && moment)
log_data = moment().format(process.env.log_date_format) + ': ' + log_data;
stds.out.write && stds.out.write(log_data);
stds.std && stds.std.write && stds.std.write(log_data);
stds.out.write(log_data);
stds.std && stds.std.write(log_data);
process.send({
type : 'log:out',
data : string