diff --git a/pmd-dcpd/src/net/sourceforge/pmd/dcpd/Chunk.java b/pmd-dcpd/src/net/sourceforge/pmd/dcpd/Batch.java similarity index 83% rename from pmd-dcpd/src/net/sourceforge/pmd/dcpd/Chunk.java rename to pmd-dcpd/src/net/sourceforge/pmd/dcpd/Batch.java index d77548bf3e..9dfbeb964f 100644 --- a/pmd-dcpd/src/net/sourceforge/pmd/dcpd/Chunk.java +++ b/pmd-dcpd/src/net/sourceforge/pmd/dcpd/Batch.java @@ -9,7 +9,7 @@ import net.jini.core.entry.Entry; import java.util.List; -public class Chunk implements Entry { +public class Batch implements Entry { // routing information public static final Integer DONE = new Integer( 1 ); @@ -21,9 +21,9 @@ public class Chunk implements Entry { public Integer jobID; public Integer sequenceID; - public Chunk() {} + public Batch() {} - public Chunk(Integer jobID, List tileWrappers, Integer isDone, Integer sequenceID) { + public Batch(Integer jobID, List tileWrappers, Integer isDone, Integer sequenceID) { this.jobID = jobID; this.tileWrappers = tileWrappers; this.isDone = isDone; diff --git a/pmd-dcpd/src/net/sourceforge/pmd/dcpd/TileExpander.java b/pmd-dcpd/src/net/sourceforge/pmd/dcpd/TileExpander.java index c62458f41d..5c5d3a75d2 100644 --- a/pmd-dcpd/src/net/sourceforge/pmd/dcpd/TileExpander.java +++ b/pmd-dcpd/src/net/sourceforge/pmd/dcpd/TileExpander.java @@ -28,15 +28,15 @@ public class TileExpander { } public void expandAvailableTiles() throws RemoteException, UnusableEntryException, TransactionException, InterruptedException{ - Entry twQuery = space.snapshot(new Chunk(tsw.jobID, null, Chunk.NOT_DONE, null)); + Entry twQuery = space.snapshot(new Batch(tsw.jobID, null, Batch.NOT_DONE, null)); - Chunk chunk = null; + Batch batch = null; int total = 0; - while ((chunk = (Chunk)space.take(twQuery, null, 10)) != null) { + while ((batch = (Batch)space.take(twQuery, null, 10)) != null) { total++; List wrappers = new ArrayList(); - for (int j=0; j0) System.out.println("Expanded " + total + " tiles"); } diff --git a/pmd-dcpd/src/net/sourceforge/pmd/dcpd/TileHarvester.java b/pmd-dcpd/src/net/sourceforge/pmd/dcpd/TileHarvester.java index 953f2f0b4e..fe13ed6427 100644 --- a/pmd-dcpd/src/net/sourceforge/pmd/dcpd/TileHarvester.java +++ b/pmd-dcpd/src/net/sourceforge/pmd/dcpd/TileHarvester.java @@ -29,9 +29,9 @@ public class TileHarvester { public Occurrences harvest(int originalOccurrencesCount) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException { Occurrences occ = new Occurrences(new CPDNullListener()); for (int i=0;i" + tw.occurrences.size()); tilesSoFar++; if (tilesSoFar % 100 == 0) {