org.apache.commons.exec.Executor.setWatchdog()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(5.5k)|赞(0)|评价(0)|浏览(136)

本文整理了Java中org.apache.commons.exec.Executor.setWatchdog()方法的一些代码示例,展示了Executor.setWatchdog()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Executor.setWatchdog()方法的具体详情如下:
包路径:org.apache.commons.exec.Executor
类名称:Executor
方法名:setWatchdog

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));

相关文章