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

Add a log for testing.

Browse Source
This commit is contained in:
Kui LIU
2017-07-22 23:52:16 +02:00
parent bc56e9b6ba
commit 4fb3be8ff8
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/edu/lu/uni/serval/FixPatternMiner/AkkaMiner.java
+11 -3
View File
@@ -4,15 +4,21 @@ import java.io.File;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import akka.actor.ActorRef; import akka.actor.ActorRef;
import akka.actor.ActorSystem; import akka.actor.ActorSystem;
import edu.lu.uni.serval.utils.FileHelper; import edu.lu.uni.serval.utils.FileHelper;
public class AkkaMiner { public class AkkaMiner {
private static Logger log = LoggerFactory.getLogger(AkkaMiner.class);
@SuppressWarnings("deprecation") @SuppressWarnings("deprecation")
public static void main(String[] args) { public static void main(String[] args) {
// input data // input data
log.info("Get the input data...");
final List<MessageFile> msgFiles = getMessageFiles(); final List<MessageFile> msgFiles = getMessageFiles();
// output path // output path
@@ -25,6 +31,7 @@ public class AkkaMiner {
ActorRef parsingActor = null; ActorRef parsingActor = null;
final int numberOfWorkers = 100; final int numberOfWorkers = 100;
try { try {
log.info("Akka beings...");
system = ActorSystem.create("Mining-FixPattern-System"); system = ActorSystem.create("Mining-FixPattern-System");
parsingActor = system.actorOf(MineFixPatternActor.props(numberOfWorkers, editScriptsFilePath, patchesSourceCodeFilePath), "mine-fix-pattern-actor"); parsingActor = system.actorOf(MineFixPatternActor.props(numberOfWorkers, editScriptsFilePath, patchesSourceCodeFilePath), "mine-fix-pattern-actor");
parsingActor.tell(msgFiles, ActorRef.noSender()); parsingActor.tell(msgFiles, ActorRef.noSender());
@@ -38,6 +45,7 @@ public class AkkaMiner {
String inputPath = "../OUTPUT/"; //DiffEntries prevFiles revFiles String inputPath = "../OUTPUT/"; //DiffEntries prevFiles revFiles
File inputFileDirector = new File(inputPath); File inputFileDirector = new File(inputPath);
File[] files = inputFileDirector.listFiles(); // project folders File[] files = inputFileDirector.listFiles(); // project folders
log.info("Projects: " + files.length);
List<MessageFile> msgFiles = new ArrayList<>(); List<MessageFile> msgFiles = new ArrayList<>();
for (File file : files) { for (File file : files) {
@@ -50,15 +58,15 @@ public class AkkaMiner {
File prevFile = new File(projectFolder + "/prevFiles/prev_" + revFile.getName());// previous file File prevFile = new File(projectFolder + "/prevFiles/prev_" + revFile.getName());// previous file
File diffentryFile = new File(projectFolder + "/DiffEntries/" + revFile.getName().replace(".java", ".txt")); // DiffEntry file File diffentryFile = new File(projectFolder + "/DiffEntries/" + revFile.getName().replace(".java", ".txt")); // DiffEntry file
if (!revFile.exists()) { if (!revFile.exists()) {
System.out.println("======" + revFile.getPath()); log.info("======" + revFile.getPath());
continue; continue;
} }
if (!prevFile.exists()) { if (!prevFile.exists()) {
System.out.println("======" + prevFile.getPath()); log.info("======" + prevFile.getPath());
continue; continue;
} }
if (!diffentryFile.exists()) { if (!diffentryFile.exists()) {
System.out.println("======" + diffentryFile.getPath()); log.info("======" + diffentryFile.getPath());
continue; continue;
} }
MessageFile msgFile = new MessageFile(revFile, prevFile, diffentryFile); MessageFile msgFile = new MessageFile(revFile, prevFile, diffentryFile);