azalea/fixminer_source
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

new compare

Browse Source
This commit is contained in:
fixminer
2020-01-19 17:01:45 +01:00
parent d439bbe8a2
commit 2cd0783300
1 changed files with 85 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/edu/lu/uni/serval/fixminer/akka/compare/CompareTrees.java
+85 -43
View File
@@ -14,7 +14,11 @@ import redis.clients.jedis.JedisPool;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
/** /**
@@ -52,37 +56,72 @@ public class CompareTrees {
// List<String> listOfPairs = AkkaTreeParser.getMessages(innerPool,Integer.valueOf(numOfWorkers)); // List<String> listOfPairs = AkkaTreeParser.getMessages(innerPool,Integer.valueOf(numOfWorkers));
HashMap<String, String> filenames = AkkaTreeParser.filenames(outerPool); HashMap<String, String> filenames = AkkaTreeParser.filenames(outerPool);
List<String> listOfPairs = AkkaTreeParser.files2compare(outerPool); // List<String> listOfPairs = AkkaTreeParser.files2compare(outerPool);
ArrayList<String> samePairs = new ArrayList<>(); ArrayList<String> samePairs = new ArrayList<>();
ArrayList<String> errorPairs = new ArrayList<>(); ArrayList<String> errorPairs = new ArrayList<>();
final ExecutorService executor = Executors.newWorkStealingPool();
// schedule the work
final Future<?> future = executor.submit( new RunnableCompare( job,errorPairs,filenames,outerPool));
try {
// wait for task to complete
future.get();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdownNow();
}
// listOfPairs.stream().parallel().forEach(m->coreCompare(m, job,null, samePairs,errorPairs,filenames,outerPool));
listOfPairs.stream().parallel().forEach(m->newCoreCompare(m, job, samePairs,errorPairs,filenames,outerPool));
// try (Jedis jedis = outerPool.getResource()) {
// jedis.select(2);
// for (String samePair : samePairs) {
//// jedis.hset("compare", errorPair, "1");
// jedis.set(samePair, "1");
// }
// jedis.select(0);
//// jedis.flushDB();
// jedis.del("compare");
// for (String errorPair : errorPairs) {
// jedis.hset("compare", errorPair, "1");
// }
//
//
// }
log.info("End process"); log.info("End process");
} }
public static void newCoreCompare(String pairName, String treeType,ArrayList<String> samePairs,ArrayList<String> errorPairs, HashMap<String, String> filenames,JedisPool outerPool ) {
public static class RunnableCompare implements Runnable {
String job;
ArrayList<String> errorPairs;
HashMap<String, String> filenames;
JedisPool outerPool;
public RunnableCompare(String treeType,ArrayList<String> errorPairs, HashMap<String, String> filenames,JedisPool outerPool) {
this.job = treeType;
this.errorPairs = errorPairs;
this.filenames = filenames;
this.outerPool = outerPool;
}
@Override
public void run() {
int dbsize = 1;
while(dbsize>0) {
try (Jedis outer = outerPool.getResource()) {
dbsize = Math.toIntExact(outer.scard("compare"));
}
if (dbsize != 0){
newCoreCompare(job, errorPairs, filenames, outerPool);
}
}
}
}
public static void newCoreCompare( String treeType,ArrayList<String> errorPairs, HashMap<String, String> filenames,JedisPool outerPool ) {
String pairName;
try (Jedis outer = outerPool.getResource()) {
pairName = outer.spop("compare");
}
String matchKey = null; String matchKey = null;
try { try {
@@ -101,14 +140,17 @@ public class CompareTrees {
if (matchKey == null){ if (matchKey == null){
System.out.println(); System.out.println();
} }
String oldShapeTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames, "shapeTree"); Map<String, String> oldTreeString = EDiffHelper.getTreeString(keyName, i, outerPool, filenames);
String newShapeTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames, "shapeTree"); Map<String, String> newTreeString = EDiffHelper.getTreeString(keyName, j, outerPool, filenames);
String oldActionTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames, "actionTree"); String oldShapeTree =oldTreeString.get("shapeTree");
String newActionTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames, "actionTree"); String newShapeTree =newTreeString.get("shapeTree");
String oldTargetTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames, "targetTree"); String oldActionTree = oldTreeString.get("actionTree");
String newTargetTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames, "targetTree"); String newActionTree = newTreeString.get("actionTree");
String oldTargetTree = oldTreeString.get("targetTree");
String newTargetTree = newTreeString.get("targetTree");
if (oldShapeTree.equals(newShapeTree)) { if (oldShapeTree.equals(newShapeTree)) {
@@ -170,23 +212,23 @@ public class CompareTrees {
switch (treeType) { switch (treeType) {
case "single": case "single":
String oldShapeTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames,"shapeTree"); // String oldShapeTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames,"shapeTree");
String newShapeTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames,"shapeTree"); // String newShapeTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames,"shapeTree");
//
String oldActionTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames,"actionTree"); // String oldActionTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames,"actionTree");
String newActionTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames,"actionTree"); // String newActionTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames,"actionTree");
//
String oldTargetTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames,"targetTree"); // String oldTargetTree = EDiffHelper.getTreeString(keyName, i, outerPool, filenames,"targetTree");
String newTargetTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames,"targetTree"); // String newTargetTree = EDiffHelper.getTreeString(keyName, j, outerPool, filenames,"targetTree");
//
//
if(oldShapeTree.equals(newShapeTree)){ // if(oldShapeTree.equals(newShapeTree)){
if(oldActionTree.equals(newActionTree)){ // if(oldActionTree.equals(newActionTree)){
if(oldTargetTree.equals(newTargetTree)){ // if(oldTargetTree.equals(newTargetTree)){
samePairs.add(matchKey); // samePairs.add(matchKey);
} // }
} // }
} // }
return; return;
// break; // break;