Mercurial > dive4elements > river
view flys-artifacts/src/main/java/de/intevation/flys/wsplgen/JobObserver.java @ 4573:b87073a05f9d
flys-client: Patch to render combobox options as clickable links.
The way of passing data arguments to the links and further to
the Artifact feeding service is somewhat hacked and should be
refactored (later...).
author | Christian Lins <christian.lins@intevation.de> |
---|---|
date | Tue, 27 Nov 2012 12:50:10 +0100 |
parents | 453d2d0c4258 |
children |
line wrap: on
line source
package de.intevation.flys.wsplgen; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.util.regex.Matcher; import java.util.regex.Pattern; import org.apache.log4j.Logger; import de.intevation.flys.artifacts.model.CalculationMessage; import de.intevation.flys.artifacts.model.map.WSPLGENJob; public class JobObserver extends Thread { private static Logger logger = Logger.getLogger(JobObserver.class); public static final String WSPLGEN_ENCODING = "ISO-8859-1"; public static final String WSPLGEN_LOG_OUTPUT = System.getProperty("wsplgen.log.output", "false"); public static final String[] STEPS = { ".*<-Auswertung der Kommandozeilen-Parameter beendet.*", ".*->Laden des DGM in Datei '.*' gestartet.*", ".*->Triangulierung der Knoten gestartet.*", ".*->Anpassung der Elemente an Dämme und Gräben gestartet.*", ".*<-WSPLGEN Version .* beendet.*" }; protected WSPLGENJob job; protected InputStream in; protected Pattern[] patterns; protected int len; protected boolean copy; public JobObserver(WSPLGENJob job) { this.job = job; this.len = 0; this.copy = Boolean.parseBoolean(WSPLGEN_LOG_OUTPUT); patterns = new Pattern[STEPS.length]; } protected void prepareRegexes() { for (int num = STEPS.length, i = 0; i < num; i++) { patterns[i] = Pattern.compile(STEPS[i], Pattern.DOTALL); } } public void setInputStream(InputStream in) { this.in = in; } public void run() { logger.debug("Start observation..."); prepareRegexes(); try { BufferedReader reader = new BufferedReader( new InputStreamReader(in, WSPLGEN_ENCODING)); String line = null; while ((line = reader.readLine()) != null) { if (copy) { logger.debug(line); } update(line); } } catch (IOException ioe) { logger.warn("Observation canceled: " + ioe.getMessage()); } } protected void update(String log) { for (int num = patterns.length, i = 0; i < num; i++) { Matcher m = patterns[i].matcher(log); if (m.matches()) { job.getCallContext().addBackgroundMessage( new CalculationMessage(num, i+1, log)); logger.info("Finished step " + (i+1) + " / " + num); } } } } // vim:set ts=4 sw=4 si et sta sts=5 fenc=utf-8 :