/[projects]/dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java
ViewVC logotype

Diff of /dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2259 by torben, Mon Feb 9 13:21:39 2015 UTC revision 2422 by torben, Tue Mar 3 08:14:09 2015 UTC
# Line 2  package dk.daoas.fulddaekning; Line 2  package dk.daoas.fulddaekning;
2    
3  import java.sql.SQLException;  import java.sql.SQLException;
4  import java.util.Queue;  import java.util.Queue;
5    import java.util.concurrent.BrokenBarrierException;
6    import java.util.concurrent.CyclicBarrier;
7  import java.util.logging.Level;  import java.util.logging.Level;
8  import java.util.logging.Logger;  import java.util.logging.Logger;
9    
# Line 17  public class LookupWorker implements Run Line 19  public class LookupWorker implements Run
19                    
20          int workerId;          int workerId;
21          Lookup lookup;          Lookup lookup;
22            CyclicBarrier barrier;
23                    
24          public LookupWorker(int workerId, Lookup lookup) {          public LookupWorker(int workerId, Lookup lookup, CyclicBarrier barrier) {
25                  this.workerId = workerId;                  this.workerId = workerId;
26                  this.lookup = lookup;                  this.lookup = lookup;
27                    this.barrier = barrier;
28                                    
29                  consts = Constants.getInstance();                  consts = Constants.getInstance();
30          }          }
# Line 30  public class LookupWorker implements Run Line 34  public class LookupWorker implements Run
34                  Constants consts = Constants.getInstance();                  Constants consts = Constants.getInstance();
35                                    
36                  Adresse daekkede[] = lookup.getDaekkedeAdresser();                  Adresse daekkede[] = lookup.getDaekkedeAdresser();
37                    Adresse udvidetDaekkede[] = lookup.getUdvidetDaekkedeAdresser();
38                  Queue<Adresse> queue = lookup.getQueue();                  Queue<Adresse> queue = lookup.getQueue();
39                  Database db = lookup.getDb();                  Database db = lookup.getDb();
40                                    
# Line 43  public class LookupWorker implements Run Line 48  public class LookupWorker implements Run
48    
49                          LookupResult result = findBedsteAdresse(qAdresse, daekkede);                          LookupResult result = findBedsteAdresse(qAdresse, daekkede);
50                                                    
51                          if (result.bedsteAdr == null && consts.doExtendedLookup() == true) {//hvis vi ikke fandt en adresse og vi må kigge på udvidet område                          if (result.bedsteAdr == null ) {//hvis vi ikke fandt en adresse og vi må kigge på udvidet område
52                                  logger.info("Extended lookup for " + qAdresse);                                  logger.info("Extended lookup for " + qAdresse);
53                                                                    
54                                  result = findBedsteAdresse(qAdresse, LookupMain.alleDaekkedeAdresser);                                  result = findBedsteAdresse(qAdresse, udvidetDaekkede);
55                          }                          }
56                                                    
57                                                    
# Line 73  public class LookupWorker implements Run Line 78  public class LookupWorker implements Run
78                          }                          }
79    
80                  }                  }
81                                    try {
82                            barrier.await();
83                    } catch (BrokenBarrierException e) {
84                            logger.log(Level.SEVERE, e.getMessage(), e);
85                            System.exit(-1);
86                    } catch(InterruptedException e) {
87                            //Do nothing
88                    }
89          }          }
90                    
91          LookupResult findBedsteAdresse(Adresse qAdresse, Adresse daekkede[]) {          LookupResult findBedsteAdresse(Adresse qAdresse, Adresse daekkede[]) {
Legend:
Removed from v.2259  
changed lines
  Added in v.2422
  ViewVC Help
Powered by ViewVC 1.1.20