in src/main/java/com/googlesource/gerrit/plugins/hooks/HookTask.java [85:139]
public HookResult runHook() {
HookResult result = null;
String name = getName();
try (Timer1.Context<String> timer = args.metrics.start(name)) {
args.metrics.count(name);
List<String> argv = new ArrayList<>(1 + args.get().size());
argv.add(hook.toAbsolutePath().toString());
argv.addAll(args.get());
ProcessBuilder pb = new ProcessBuilder(argv);
pb.redirectErrorStream(true);
Map<String, String> env = pb.environment();
env.put("GERRIT_SITE", sitePath.toAbsolutePath().toString());
if (projectName != null) {
try (Repository git = args.gitManager.openRepository(Project.nameKey(projectName))) {
pb.directory(git.getDirectory());
env.put("GIT_DIR", git.getDirectory().getAbsolutePath());
}
}
ps = pb.start();
ps.getOutputStream().close();
String out = new String(ByteStreams.toByteArray(ps.getInputStream()), UTF_8);
ps.waitFor();
result = new HookResult(ps.exitValue(), out);
} catch (InterruptedException iex) {
// InterruptedException - timeout or cancel
args.metrics.timeout(name);
logger.atSevere().log("hook[%s] timed out: %s", name, iex.getMessage());
} catch (Throwable err) {
args.metrics.error(name);
logger.atSevere().withCause(err).log("Error running hook %s", hook.toAbsolutePath());
}
if (result != null) {
int exitValue = result.getExitValue();
if (exitValue != 0) {
logger.atSevere().log("hook[%s] exited with error status: %d", name, exitValue);
}
if (logger.atFine().isEnabled()) {
try (BufferedReader br = new BufferedReader(new StringReader(result.getOutput()))) {
br.lines()
.filter(s -> !s.isEmpty())
.forEach(line -> logger.atFine().log("hook[%s] output: %s", name, line));
} catch (IOException iox) {
logger.atSevere().withCause(iox).log("Error writing hook [%s] output", name);
}
}
}
return result;
}