Mercurial > dive4elements > river
view flys-artifacts/src/main/java/de/intevation/flys/wsplgen/JobExecutor.java @ 1663:4fbd43061315
Show proper labels for selected differences.
flys-artifacts/trunk@2866 c6561f87-3c4e-4783-a992-168aeb5c3f6f
author | Felix Wolfsteller <felix.wolfsteller@intevation.de> |
---|---|
date | Fri, 30 Sep 2011 05:31:34 +0000 |
parents | aaf8d32f85bd |
children | ef2300b450bf |
line wrap: on
line source
package de.intevation.flys.wsplgen; import java.io.IOException; import java.io.File; import org.apache.log4j.Logger; import de.intevation.artifacts.CallContext; import de.intevation.flys.artifacts.model.WSPLGENJob; import de.intevation.flys.utils.MapfileGenerator; public class JobExecutor { public static final String WSPLGEN_PARAMETER_FILE = "wsplgen.par"; public static final String WSPLGEN_BIN_PATH = System.getProperty("wsplgen.bin.path"); private Logger logger = Logger.getLogger(JobExecutor.class); private Process process; protected WSPLGENJob job; protected JobObserver logObserver; protected ProblemObserver errorObserver; public JobExecutor(WSPLGENJob job) { this.job = job; this.logObserver = new JobObserver(job); this.errorObserver = new ProblemObserver(job); } public void execute() { File dir = job.getWorkingDir(); File parameter = new File(dir, WSPLGEN_PARAMETER_FILE); String[] args = new String[] { WSPLGEN_BIN_PATH, "-PAR=\"" + parameter.getAbsolutePath() + "\"" }; execute(args, dir); } protected void execute(String[] args, File dir) { logger.info("Start JobExecutor for artifact: " + dir.getName()); String errorMsg = null; try { synchronized (this) { process = Runtime.getRuntime().exec(args, null, dir); logObserver.setInputStream(process.getInputStream()); errorObserver.setInputStream(process.getErrorStream()); logObserver.start(); errorObserver.start(); try { process.waitFor(); } catch (InterruptedException ie) { logger.error("WSPLGEN job interrupted: " + ie.getMessage()); } try { logObserver.join(); errorObserver.join(); } catch (InterruptedException iee) { /* do nothing */ } logger.info("WSPLGEN exit value: " + process.exitValue()); logger.info( "WSPLGEN throw " + errorObserver.numErrors() + " errors."); logger.info( "WSPLGEN throw " + errorObserver.numWarnings() + " warnings."); if (process.exitValue() < 2 && errorObserver.numErrors() == 0) { FacetCreator fc = job.getFacetCreator(); fc.createWSPLGENFacet(); fc.finish(); MapfileGenerator.getInstance().update(); } job.getCallContext().afterBackground(CallContext.STORE); return; } } catch (SecurityException se) { logger.error(se); } catch (IOException ioe) { logger.error(ioe); } catch (NullPointerException npe) { logger.error(npe, npe); } catch (IndexOutOfBoundsException ioobe) { logger.error(ioobe, ioobe); } } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf-8 :