Mercurial > dive4elements > river
comparison artifacts/src/main/java/org/dive4elements/river/wsplgen/JobObserver.java @ 8202:e4606eae8ea5
sed src/**/*.java 's/logger/log/g'
| author | Sascha L. Teichmann <teichmann@intevation.de> |
|---|---|
| date | Fri, 05 Sep 2014 12:58:17 +0200 |
| parents | af13ceeba52a |
| children | 0a5239a1e46e |
comparison
equal
deleted
inserted
replaced
| 8201:4b8c5a08de04 | 8202:e4606eae8ea5 |
|---|---|
| 21 import org.dive4elements.river.artifacts.model.map.WSPLGENJob; | 21 import org.dive4elements.river.artifacts.model.map.WSPLGENJob; |
| 22 | 22 |
| 23 | 23 |
| 24 public class JobObserver extends Thread { | 24 public class JobObserver extends Thread { |
| 25 | 25 |
| 26 private static Logger logger = Logger.getLogger(JobObserver.class); | 26 private static Logger log = Logger.getLogger(JobObserver.class); |
| 27 | 27 |
| 28 | 28 |
| 29 public static final String WSPLGEN_ENCODING = | 29 public static final String WSPLGEN_ENCODING = |
| 30 "ISO-8859-1"; | 30 "ISO-8859-1"; |
| 31 | 31 |
| 72 this.in = in; | 72 this.in = in; |
| 73 } | 73 } |
| 74 | 74 |
| 75 | 75 |
| 76 public void run() { | 76 public void run() { |
| 77 logger.debug("Start observation..."); | 77 log.debug("Start observation..."); |
| 78 prepareRegexes(); | 78 prepareRegexes(); |
| 79 | 79 |
| 80 try { | 80 try { |
| 81 BufferedReader reader = | 81 BufferedReader reader = |
| 82 new BufferedReader( | 82 new BufferedReader( |
| 84 | 84 |
| 85 String line = null; | 85 String line = null; |
| 86 | 86 |
| 87 while ((line = reader.readLine()) != null) { | 87 while ((line = reader.readLine()) != null) { |
| 88 if (copy) { | 88 if (copy) { |
| 89 logger.debug(line); | 89 log.debug(line); |
| 90 } | 90 } |
| 91 | 91 |
| 92 update(line); | 92 update(line); |
| 93 } | 93 } |
| 94 } | 94 } |
| 95 catch (IOException ioe) { | 95 catch (IOException ioe) { |
| 96 logger.warn("Observation canceled: " + ioe.getMessage()); | 96 log.warn("Observation canceled: " + ioe.getMessage()); |
| 97 } | 97 } |
| 98 } | 98 } |
| 99 | 99 |
| 100 | 100 |
| 101 protected void update(String log) { | 101 protected void update(String s) { |
| 102 for (int num = patterns.length, i = 0; i < num; i++) { | 102 for (int num = patterns.length, i = 0; i < num; i++) { |
| 103 Matcher m = patterns[i].matcher(log); | 103 Matcher m = patterns[i].matcher(s); |
| 104 | 104 |
| 105 if (m.matches()) { | 105 if (m.matches()) { |
| 106 job.getCallContext().addBackgroundMessage( | 106 job.getCallContext().addBackgroundMessage( |
| 107 new CalculationMessage(num, i+1, log)); | 107 new CalculationMessage(num, i+1, s)); |
| 108 | 108 |
| 109 logger.info("Finished step " + (i+1) + " / " + num); | 109 log.info("Finished step " + (i+1) + " / " + num); |
| 110 } | 110 } |
| 111 } | 111 } |
| 112 } | 112 } |
| 113 } | 113 } |
| 114 // vim:set ts=4 sw=4 si et sta sts=5 fenc=utf-8 : | 114 // vim:set ts=4 sw=4 si et sta sts=5 fenc=utf-8 : |