[agent][executor]- bug - 3
This commit is contained in:
@@ -131,6 +131,12 @@ public class CommandExecutor {
|
|||||||
octopusMessage
|
octopusMessage
|
||||||
));
|
));
|
||||||
|
|
||||||
|
// 缓存 命令处理日志
|
||||||
|
commandExecLogCache.cacheLog(
|
||||||
|
streamKey,
|
||||||
|
process
|
||||||
|
);
|
||||||
|
|
||||||
// 等待1秒钟, 使得有时间进行后端任务的完成
|
// 等待1秒钟, 使得有时间进行后端任务的完成
|
||||||
TimeUnit.SECONDS.sleep(1);
|
TimeUnit.SECONDS.sleep(1);
|
||||||
|
|
||||||
@@ -182,6 +188,8 @@ public class CommandExecutor {
|
|||||||
throw new RuntimeException(e);
|
throw new RuntimeException(e);
|
||||||
} finally {
|
} finally {
|
||||||
|
|
||||||
|
System.out.println("process isAlive = " + process.isAlive());
|
||||||
|
|
||||||
// 对线程进行debug
|
// 对线程进行debug
|
||||||
commandExecLogCache.debugProcessStreams(process);
|
commandExecLogCache.debugProcessStreams(process);
|
||||||
|
|
||||||
@@ -214,12 +222,6 @@ public class CommandExecutor {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 缓存 命令处理日志
|
|
||||||
commandExecLogCache.cacheLog(
|
|
||||||
streamKey,
|
|
||||||
process
|
|
||||||
);
|
|
||||||
|
|
||||||
// 日志操作,如果需要显示回传,需要将日志发送回相应的
|
// 日志操作,如果需要显示回传,需要将日志发送回相应的
|
||||||
/*collectCommandLogAndRepeat(
|
/*collectCommandLogAndRepeat(
|
||||||
streamKey,
|
streamKey,
|
||||||
|
|||||||
Reference in New Issue
Block a user