phoedos/pmd
1
1
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

getting closer

Browse Source 
git-svn-id: https://pmd.svn.sourceforge.net/svnroot/pmd/trunk@817 51baf565-9d33-0410-a72c-fc3788e3496d
This commit is contained in:
Tom Copeland
2002-08-28 21:43:33 +00:00
parent 0edbe9594c
commit d023d5f970
3 changed files with 27 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -48,7 +48,9 @@ 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");
System.out.println("Starting expansion");
doExpansion();
System.out.println("Done");
} catch (Exception e) {
e.printStackTrace();

51
pmd-dcpd/src/net/sourceforge/pmd/dcpd/DGST.java
View File

@ -30,32 +30,41 @@ public class DGST {
}
public void crunch(CPDListener listener) {
// this builds the initial frequency table
Occurrences occ = new Occurrences(tokenSets, listener);
try {
scatter(occ);
System.out.println("Writing the Job to the space");
space.write(job, null, Lease.FOREVER);
while (!occ.isEmpty()) {
Occurrences newOcc = gather(occ.size()-1);
System.out.println("occ size == " + occ.size());
if (!newOcc.isEmpty()) {
occ = newOcc;
scatter(occ);
}
}
expand(occ);
} catch (Exception e) {
e.printStackTrace();
}
}
private Occurrences gather(int lastMajorSequenceNumber) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException {
private void expand(Occurrences occ) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException {
while (!occ.isEmpty()) {
occ = gather(occ.size()-1);
scatter(occ);
System.out.println("scatter..gather complete; tile count now " + occ.size());
}
}
private void scatter(Occurrences occ) throws TransactionException, RemoteException {
int tilesSoFar=0;
for (Iterator i = occ.getTiles(); i.hasNext();) {
Tile tile = (Tile)i.next();
TileWrapper tw = new TileWrapper(tile, marshal(occ.getOccurrences(tile)), job.id, TileWrapper.NOT_DONE, new Integer(tilesSoFar), null, null);
space.write(tw, null, Lease.FOREVER);
tilesSoFar++;
if (tilesSoFar % 10 == 0) {
System.out.println("tilesSoFar = " + tilesSoFar);
}
}
}
private Occurrences gather(int originalOccurrencesCount) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException {
System.out.println("STARTING TO GATHER");
Occurrences occ = new Occurrences(new CPDNullListener());
for (int i=0;i<lastMajorSequenceNumber; i++) {
for (int i=0;i<originalOccurrencesCount; i++) {
// this gets tile x:1 - i.e., (5:1/3)
TileWrapper tw = (TileWrapper)space.take(new TileWrapper(null, null, job.id, TileWrapper.DONE, new Integer(i), new Integer(1), null), null, Lease.FOREVER);
@ -80,18 +89,6 @@ public class DGST {
}
}
private void scatter(Occurrences occ) throws TransactionException, RemoteException {
int tilesSoFar=0;
for (Iterator i = occ.getTiles(); i.hasNext();) {
Tile tile = (Tile)i.next();
TileWrapper tw = new TileWrapper(tile, marshal(occ.getOccurrences(tile)), job.id, TileWrapper.NOT_DONE, new Integer(tilesSoFar), null, null);
space.write(tw, null, Lease.FOREVER);
tilesSoFar++;
if (tilesSoFar % 10 == 0) {
System.out.println("tilesSoFar = " + tilesSoFar);
}
}
}
private List marshal(Iterator i) {
List list = new ArrayList();

2
pmd-dcpd/src/net/sourceforge/pmd/dcpd/Util.java
View File

@ -34,7 +34,7 @@ public class Util {
JavaSpace space = Util.findSpace(SPACE_SERVER);
Entry e = null;
while ( (e = space.take(null, null, 100)) != null) {
System.out.println("took " + e);
//System.out.println("took " + e);
}
} else {
System.out.println("Usage: clear");