hiifong/pmd
1
0
Fork 0
forked from phoedos/pmd
Code Pull Requests Activity

now the worker expands tiles and writes them back to the space

Browse Source 
git-svn-id: https://pmd.svn.sourceforge.net/svnroot/pmd/trunk@788 51baf565-9d33-0410-a72c-fc3788e3496d
This commit is contained in:
Tom Copeland
2002-08-27 20:26:23 +00:00
parent 8c44c12704
commit c317eaf287
1 changed files with 40 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
pmd-dcpd/src/net/sourceforge/pmd/dcpd/DCPDWorker.java
View File

@ -10,9 +10,12 @@ import net.jini.core.lease.Lease;
import net.jini.core.event.RemoteEventListener;
import net.jini.core.event.RemoteEvent;
import net.jini.core.event.UnknownEventException;
import net.jini.core.entry.Entry;
import net.sourceforge.pmd.cpd.*;
import java.rmi.RemoteException;
import java.rmi.MarshalledObject;
import java.util.*;
public class DCPDWorker {
@ -44,16 +47,49 @@ public class DCPDWorker {
tsw = (TokenSetsWrapper)space.read(new TokenSetsWrapper(null, job.id), null, 100);
System.out.println("Read a TokenSetsWrapper with " + tsw.tokenSets.size() + " token lists");
TileWrapper tw = null;
while ( (tw = (TileWrapper)space.take(new TileWrapper(null ,null, job.id), null, 100)) != null) {
System.out.println("tw = " + tw);
Entry tileWrapperQuery = space.snapshot(new TileWrapper(null, null, job.id));
TileWrapper tileWrapper = null;
while ((tileWrapper = (TileWrapper)space.take(tileWrapperQuery, null, 100)) != null) {
Occurrences results = expand(tileWrapper);
for (Iterator i = results.getTiles();i.hasNext();) {
Tile tile = (Tile)i.next();
TileWrapper newTW = new TileWrapper(tile, marshal(results.getOccurrences(tile)), job.id);
System.out.println("Writing " + newTW.tile.getImage());
space.write(newTW, null, Lease.FOREVER);
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
private List marshal(Iterator i) {
List list = new ArrayList();
while (i.hasNext()) {
list.add(i.next());
}
return list;
}
private Occurrences expand(TileWrapper tileWrapper) {
Occurrences newOcc = new Occurrences(new CPDNullListener());
for (Iterator i = tileWrapper.occurrences.iterator(); i.hasNext();) {
TokenEntry tok = (TokenEntry)i.next();
TokenList tokenSet = tsw.tokenSets.getTokenList(tok);
if (tokenSet.hasTokenAfter(tileWrapper.tile, tok)) {
TokenEntry token = (TokenEntry)tokenSet.get(tok.getIndex() + tileWrapper.tile.getTokenCount());
// make sure the next token hasn't already been used in an occurrence
if (!newOcc.contains(token)) {
Tile newTile = tileWrapper.tile.copy();
newTile.add(token);
newOcc.addTile(newTile, tok);
}
}
}
newOcc.deleteSoloTiles();
return newOcc;
}
public static void main(String[] args) {
new DCPDWorker();
}