Display the daemon output along the log when diagnosing a daemon failure

This commit is contained in:
Guillaume Nodet
2020-10-27 10:52:12 +01:00
parent a805c07a31
commit c6b27261db
3 changed files with 31 additions and 22 deletions

View File

@@ -237,7 +237,7 @@ public class DaemonConnector {
throw new DaemonException.InterruptedException(e); throw new DaemonException.InterruptedException(e);
} }
} while (System.currentTimeMillis() - start < DEFAULT_CONNECT_TIMEOUT); } while (System.currentTimeMillis() - start < DEFAULT_CONNECT_TIMEOUT);
DaemonDiagnostics diag = new DaemonDiagnostics(daemon, layout.daemonLog(daemon)); DaemonDiagnostics diag = new DaemonDiagnostics(daemon, layout.daemonLog(daemon), layout.daemonOutLog(daemon));
throw new DaemonException.ConnectException("Timeout waiting to connect to the Maven daemon.\n" + diag.describe()); throw new DaemonException.ConnectException("Timeout waiting to connect to the Maven daemon.\n" + diag.describe());
} }
@@ -272,7 +272,7 @@ public class DaemonConnector {
command = String.join(" ", args); command = String.join(" ", args);
LOGGER.debug("Starting daemon process: uid = {}, workingDir = {}, daemonArgs: {}", uid, workingDir, command); LOGGER.debug("Starting daemon process: uid = {}, workingDir = {}, daemonArgs: {}", uid, workingDir, command);
ProcessBuilder.Redirect redirect = ProcessBuilder.Redirect.appendTo(layout.daemonLog(uid + ".out").toFile()); ProcessBuilder.Redirect redirect = ProcessBuilder.Redirect.appendTo(layout.daemonOutLog(uid).toFile());
new ProcessBuilder() new ProcessBuilder()
.directory(workingDir.toFile()) .directory(workingDir.toFile())
.command(args) .command(args)
@@ -297,7 +297,7 @@ public class DaemonConnector {
try { try {
return connectToDaemon(daemonInfo, new CleanupOnStaleAddress(daemonInfo), newDaemon); return connectToDaemon(daemonInfo, new CleanupOnStaleAddress(daemonInfo), newDaemon);
} catch (DaemonException.ConnectException e) { } catch (DaemonException.ConnectException e) {
DaemonDiagnostics diag = new DaemonDiagnostics(daemon, layout.daemonLog(daemon)); DaemonDiagnostics diag = new DaemonDiagnostics(daemon, layout.daemonLog(daemon), layout.daemonOutLog(daemon));
throw new DaemonException.ConnectException("Could not connect to the Maven daemon.\n" + diag.describe(), e); throw new DaemonException.ConnectException("Could not connect to the Maven daemon.\n" + diag.describe(), e);
} }
} }

View File

@@ -18,6 +18,7 @@ package org.jboss.fuse.mvnd.common;
import java.io.BufferedReader; import java.io.BufferedReader;
import java.io.IOException; import java.io.IOException;
import java.nio.file.Files; import java.nio.file.Files;
import java.nio.file.NoSuchFileException;
import java.nio.file.Path; import java.nio.file.Path;
import java.util.ArrayDeque; import java.util.ArrayDeque;
import java.util.ArrayList; import java.util.ArrayList;
@@ -35,10 +36,12 @@ public class DaemonDiagnostics {
private final String uid; private final String uid;
private final Path daemonLog; private final Path daemonLog;
private final Path daemonOutLog;
public DaemonDiagnostics(String uid, Path daemonLog) { public DaemonDiagnostics(String uid, Path daemonLog, Path daemonOutLog) {
this.uid = uid; this.uid = uid;
this.daemonLog = daemonLog; this.daemonLog = daemonLog;
this.daemonOutLog = daemonOutLog;
} }
@Override @Override
@@ -46,27 +49,40 @@ public class DaemonDiagnostics {
return "{" return "{"
+ "uid=" + uid + "uid=" + uid
+ ", daemonLog=" + daemonLog + ", daemonLog=" + daemonLog
+ ", daemonOutLog=" + daemonOutLog
+ '}'; + '}';
} }
private String tailDaemonLog() { public String describe() {
StringBuilder sb = new StringBuilder();
sb.append("Daemon uid: ").append(uid).append("\n");
tail(sb, "log file", daemonLog);
tail(sb, "output", daemonOutLog);
return sb.toString();
}
static void tail(StringBuilder sb, String name, Path log) {
try { try {
String tail = tail(daemonLog, TAIL_SIZE); String tail = tail(log);
return formatTail(tail); sb.append(" ").append(name).append(": ").append(log).append("\n");
sb.append("----- Last " + TAIL_SIZE + " lines from daemon ").append(name).append(" - ").append(log).append(" -----\n");
sb.append(tail);
sb.append("----- End of the daemon ").append(name).append(" -----\n");
} catch (NoSuchFileException e) {
sb.append(" no ").append(name).append(" at: ").append(log).append("\n");
} catch (IOException e) { } catch (IOException e) {
return "Unable to read from the daemon log file: " + daemonLog + ", because of: " + e.getCause(); sb.append(" unable to read from the daemon ").append(name).append(": ").append(log).append(", because of: ").append(e);
} }
} }
/** /**
* @param path to read from tail * @param path to read from tail
* @param maxLines max lines to read
* @return tail content * @return tail content
* @throws IOException when reading failed * @throws IOException when reading failed
*/ */
static String tail(Path path, int maxLines) throws IOException { static String tail(Path path) throws IOException {
try (BufferedReader r = Files.newBufferedReader(path)) { try (BufferedReader r = Files.newBufferedReader(path)) {
return String.join("\n", r.lines().collect(lastN(maxLines))); return String.join("\n", r.lines().collect(lastN(TAIL_SIZE))) + "\n";
} }
} }
@@ -83,15 +99,4 @@ public class DaemonDiagnostics {
}, ArrayList::new); }, ArrayList::new);
} }
private String formatTail(String tail) {
return "----- Last " + TAIL_SIZE + " lines from daemon log file - " + daemonLog + " -----\n"
+ tail
+ "----- End of the daemon log -----\n";
}
public String describe() {
return "Daemon uid: " + uid + "\n"
+ " log file: " + daemonLog + "\n"
+ tailDaemonLog();
}
} }

View File

@@ -56,6 +56,10 @@ public class Layout {
return mavenHome.resolve("daemon/daemon-" + daemon + ".log"); return mavenHome.resolve("daemon/daemon-" + daemon + ".log");
} }
public Path daemonOutLog(String daemon) {
return mavenHome.resolve("daemon/daemon-" + daemon + ".out.log");
}
public Path multiModuleProjectDirectory() { public Path multiModuleProjectDirectory() {
return multiModuleProjectDirectory; return multiModuleProjectDirectory;
} }