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 : |