本文整理了Java中org.apache.commons.exec.Executor.setWatchdog()
方法的一些代码示例,展示了Executor.setWatchdog()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Executor.setWatchdog()
方法的具体详情如下:
包路径:org.apache.commons.exec.Executor
类名称:Executor
方法名:setWatchdog
[英]Set the watchdog used to kill of processes running, typically, too long time.
[中]设置用于终止进程运行(通常运行时间过长)的看门狗。
代码示例来源:origin: openhab/openhab1-addons
executor.setWatchdog(watchdog);
代码示例来源:origin: com.datastax.cassandra/cassandra-driver-core
ExecuteStreamHandler streamHandler = new PumpStreamHandler(outStream, errStream);
executor.setStreamHandler(streamHandler);
executor.setWatchdog(watchDog);
int retValue = executor.execute(cli, ENVIRONMENT_MAP);
if (retValue != 0) {
代码示例来源:origin: ru.yandex.qatools.camelot/camelot-utils
/**
* Create {@link org.apache.commons.exec.Executor} with infinite timeout watchdog
*
* @return created executor
*/
public static Executor createExecutor() {
ExecuteWatchdog watchdog = new ExecuteWatchdog(INFINITE_TIMEOUT);
Executor executor = new DefaultExecutor();
executor.setExitValue(1);
executor.setWatchdog(watchdog);
return executor;
}
代码示例来源:origin: alexholmes/hdfs-file-slurper
executor.setWatchdog(watchdog);
代码示例来源:origin: nidi3/graphviz-java
public void execute(CommandLine cmd, @Nullable File workingDirectory) throws InterruptedException, IOException {
LOG.info("executing command {}", cmd.toString());
final ExecuteWatchdog watchdog = new ExecuteWatchdog(60 * 1000);
final Executor executor = new org.apache.commons.exec.DefaultExecutor();
executor.setWatchdog(watchdog);
if (workingDirectory != null) {
executor.setWorkingDirectory(workingDirectory);
}
LOG.debug("workdir: {}", executor.getWorkingDirectory());
final DefaultExecuteResultHandler resultHandler = new DefaultExecuteResultHandler();
final ByteArrayOutputStream out = new ByteArrayOutputStream();
final ByteArrayOutputStream err = new ByteArrayOutputStream();
executor.setStreamHandler(new PumpStreamHandler(out, err));
executor.execute(cmd, resultHandler);
resultHandler.waitFor();
final int exitCode = resultHandler.getExitValue();
if (out.size() > 0) {
LOG.info(out.toString());
}
if (exitCode != 0) {
throw new IOException(err.size() == 0 ? "command '" + cmd + "' didn't succeed" : err.toString());
}
}
}
代码示例来源:origin: com.addc.mojo/addc-mojo
/**
* Get an Executor that will run in the given directory with a watchdog set
* for the timeout.
*
* @param workDir
* The working directory for the process
* @return An executor.
*/
protected Executor getExecutor(File workDir) {
Executor executor= new DefaultExecutor();
executor.setWorkingDirectory(workDir);
if (timeout > 0) {
ExecuteWatchdog watchdog= new ExecuteWatchdog(timeout);
executor.setWatchdog(watchdog);
}
return executor;
}
代码示例来源:origin: gov.nasa.jpl.imce/gov.nasa.jpl.magicdraw.projectUsageIntegrityChecker
executor.setWatchdog(watchdog);
executor.setWorkingDirectory(pugTemp);
executor.execute(cmdLine, resultHandler);
代码示例来源:origin: spinnaker/halyard
executor.setWatchdog(watchdog);
try {
executor.execute(commandLine, env, resultHandler);
代码示例来源:origin: org.eclipse.smarthome.io/org.eclipse.smarthome.io.net
executor.setWatchdog(watchdog);
代码示例来源:origin: openhab/openhab-core
executor.setWatchdog(watchdog);
代码示例来源:origin: com.dell.cpsd.component/component-common-core
executor.setProcessDestroyer(new ShutdownHookProcessDestroyer());
ExecuteWatchdog watchDog = new ExecuteWatchdog(watchdogTimeout);
executor.setWatchdog(watchDog);
if (StringUtils.isBlank(standardInText))
代码示例来源:origin: net.jangaroo/jangaroo-maven-plugin
private static void internalExecute(CommandLine cmdLine, OutputStream outputStream, File workingDirectory) throws IOException {
Executor executor = getExecutor();
ExecuteWatchdog watchdog = getExecuteWatchdog();
executor.setWatchdog(watchdog);
if (workingDirectory != null) {
executor.setWorkingDirectory(workingDirectory);
}
// set allowed exit values (0 is actually the default)
executor.setExitValue(0);
PumpStreamHandler psh = new PumpStreamHandler(outputStream);
executor.setStreamHandler(psh);
executor.execute(cmdLine);
if (watchdog.killedProcess()) {
throw new ExecuteException(String.format("Watchdog killed Sencha Cmd process after %s ms.", MAX_EXECUTION_TIME), 0);
}
}
代码示例来源:origin: openhab/openhab-core
executor.setWatchdog(watchdog);
代码示例来源:origin: com.datastax.dse/dse-java-driver-core
ExecuteStreamHandler streamHandler = new PumpStreamHandler(outStream, errStream);
executor.setStreamHandler(streamHandler);
executor.setWatchdog(watchDog);
int retValue = executor.execute(cli, ENVIRONMENT_MAP);
if (retValue != 0) {
代码示例来源:origin: locationtech/geowave
executor.setWatchdog(watchdog);
executor.execute(cmdLine, resultHandler);
代码示例来源:origin: gov.nasa.jpl.imce/gov.nasa.jpl.magicdraw.projectUsageIntegrityChecker
executor.setWatchdog(watchdog);
executor.setWorkingDirectory(pugTemp);
executor.execute(cmdLine, resultHandler);
代码示例来源:origin: com.hurence.logisland/logisland-agent
executor.setWatchdog(watchdog);
代码示例来源:origin: apache/bigtop
Executor executor = new DefaultExecutor();
executor.setExitValue(1);
executor.setWatchdog(watchdog);
executor.setStreamHandler(streamHandler);
try {
代码示例来源:origin: danielflower/app-runner
private static Executor createExecutor(LineConsumer consoleLogHandler, CommandLine command, File projectRoot, ExecuteWatchdog watchDog) {
Executor executor = new DefaultExecutor();
executor.setWorkingDirectory(projectRoot);
executor.setWatchdog(watchDog);
executor.setStreamHandler(new PumpStreamHandler(new WriterOutputStream(new WriterToOutputBridge(consoleLogHandler))));
consoleLogHandler.consumeLine(fullPath(executor.getWorkingDirectory()) + "> " + String.join(" ", command.toStrings()) + LINE_SEPARATOR);
return executor;
}
代码示例来源:origin: georocket/georocket
executor.setWatchdog(new ExecuteWatchdog(ExecuteWatchdog.INFINITE_TIMEOUT));
内容来源于网络,如有侵权,请联系作者删除!