Mercurial > dive4elements > river
view flys-artifacts/src/main/java/de/intevation/flys/wsplgen/WSPLGENCallable.java @ 4488:5041105d2edd
Check if response code from GGInA is 200 OK
Only parse the GGInA response if the status code is 200 OK. This improves the
error message if GGInA is not available and shows the real reason instead of a
JDOM error while parsing the response.
author | Björn Ricks <bjoern.ricks@intevation.de> |
---|---|
date | Wed, 14 Nov 2012 10:36:21 +0100 |
parents | 453d2d0c4258 |
children | b87073a05f9d |
line wrap: on
line source
package de.intevation.flys.wsplgen; import java.io.File; import java.io.IOException; import java.util.concurrent.Callable; import org.apache.log4j.Logger; import de.intevation.artifacts.CallContext; import de.intevation.flys.artifacts.model.map.WSPLGENJob; /** * A Callable that is used to start and observe an external Process for WSPLGEN. * * @author <a href="mailto:ingo.weinzierl@intevation.de">Ingo Weinzierl</a> */ public class WSPLGENCallable implements Callable { 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(WSPLGENCallable.class); private Process process; protected Scheduler scheduler; protected WSPLGENJob job; protected JobObserver logObserver; protected ProblemObserver errorObserver; public WSPLGENCallable(Scheduler scheduler, WSPLGENJob job) { this.scheduler = scheduler; this.job = job; this.logObserver = new JobObserver(job); this.errorObserver = new ProblemObserver(job); } @Override public WSPLGENJob call() { 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); return job; } 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.warn("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(); } job.getCallContext().afterBackground(CallContext.STORE); scheduler.removeJob(getJob().getArtifact().identifier()); 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); } } public void cancelWSPLGEN() { if (process != null) { logger.debug("Cancel running WSPLGEN process."); process.destroy(); } } public WSPLGENJob getJob() { return job; } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf-8 :