ingo@1127: package de.intevation.flys.wsplgen; ingo@1127: ingo@1127: import java.io.BufferedReader; ingo@1127: import java.io.InputStream; ingo@1127: import java.io.InputStreamReader; ingo@1127: import java.io.IOException; ingo@1127: import java.util.regex.Matcher; ingo@1127: import java.util.regex.Pattern; ingo@1127: ingo@1127: import org.apache.log4j.Logger; ingo@1127: ingo@1157: import de.intevation.flys.artifacts.model.CalculationMessage; ingo@1127: import de.intevation.flys.artifacts.model.WSPLGENJob; ingo@1127: ingo@1127: ingo@1127: public class JobObserver extends Thread { ingo@1127: ingo@1127: private static Logger logger = Logger.getLogger(JobObserver.class); ingo@1127: ingo@1127: ingo@1127: public static final String WSPLGEN_ENCODING = ingo@1127: "ISO-8859-1"; ingo@1127: ingo@1127: public static final String WSPLGEN_LOG_OUTPUT = ingo@1127: System.getProperty("wsplgen.log.output", "false"); ingo@1127: ingo@1127: public static final String[] STEPS = { ingo@1127: ".*<-Auswertung der Kommandozeilen-Parameter beendet.*", ingo@1127: ".*->Laden des DGM in Datei '.*' gestartet.*", ingo@1127: ".*->Triangulierung der Knoten gestartet.*", ingo@1127: ".*->Anpassung der Elemente an Dämme und Gräben gestartet.*", ingo@1127: ".*<-WSPLGEN Version .* beendet.*" ingo@1127: }; ingo@1127: ingo@1127: ingo@1127: protected WSPLGENJob job; ingo@1127: ingo@1127: protected InputStream in; ingo@1127: ingo@1127: protected Pattern[] patterns; ingo@1127: ingo@1127: protected int len; ingo@1127: ingo@1127: protected boolean copy; ingo@1127: ingo@1127: ingo@1127: public JobObserver(WSPLGENJob job) { ingo@1127: this.job = job; ingo@1127: this.len = 0; ingo@1127: this.copy = Boolean.parseBoolean(WSPLGEN_LOG_OUTPUT); ingo@1127: ingo@1127: patterns = new Pattern[STEPS.length]; ingo@1127: } ingo@1127: ingo@1127: ingo@1147: protected void prepareRegexes() { ingo@1127: for (int num = STEPS.length, i = 0; i < num; i++) { ingo@1147: patterns[i] = Pattern.compile(STEPS[i], Pattern.DOTALL); ingo@1127: } ingo@1127: } ingo@1127: ingo@1127: ingo@1127: public void setInputStream(InputStream in) { ingo@1127: this.in = in; ingo@1127: } ingo@1127: ingo@1127: ingo@1127: public void run() { ingo@1147: logger.debug("Start observation..."); ingo@1147: prepareRegexes(); ingo@1147: ingo@1127: try { ingo@1127: BufferedReader reader = ingo@1127: new BufferedReader( ingo@1127: new InputStreamReader(in, WSPLGEN_ENCODING)); ingo@1127: ingo@1127: String line = null; ingo@1127: ingo@1127: while ((line = reader.readLine()) != null) { ingo@1127: if (copy) { ingo@1127: logger.debug(line); ingo@1127: } ingo@1127: ingo@1127: update(line); ingo@1127: } ingo@1127: } ingo@1127: catch (IOException ioe) { ingo@1127: logger.warn("Observation canceled: " + ioe.getMessage()); ingo@1127: } ingo@1127: } ingo@1127: ingo@1127: ingo@1127: protected void update(String log) { ingo@1127: for (int num = patterns.length, i = 0; i < num; i++) { ingo@1127: Matcher m = patterns[i].matcher(log); ingo@1127: ingo@1127: if (m.matches()) { ingo@1157: job.getCallContext().addBackgroundMessage( ingo@1157: new CalculationMessage(num, i+1, log)); ingo@1157: ingo@1127: logger.info("Finished step " + (i+1) + " / " + num); ingo@1127: } ingo@1127: } ingo@1127: } ingo@1127: } ingo@1127: // vim:set ts=4 sw=4 si et sta sts=5 fenc=utf-8 :