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

server config

Browse Source
This commit is contained in:
Anil Koyuncu
2018-02-24 15:17:32 +01:00
parent 9d3b5fe4e3
commit ec9b8616a2
1 changed files with 45 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/edu/lu/uni/serval/MultipleThreadsParser/AkkaParser2.java
+45 -25
View File
@@ -11,6 +11,8 @@ import java.io.File;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
/** /**
* Multi-thread parser of parsing the difference between buggy code file and fixed code file. * Multi-thread parser of parsing the difference between buggy code file and fixed code file.
@@ -49,33 +51,51 @@ public class AkkaParser2 {
// input data // input data
String GUM_TREE_INPUT = inputRootPath + "GumTreeInput/"; String GUM_TREE_INPUT = inputRootPath + "GumTreeInput/";
log.info("Get the input data..." + GUM_TREE_INPUT ); log.info("Get the input data..." + GUM_TREE_INPUT );
String GUM_TREE_OUTPUT = inputRootPath + "GumTreeResults/"; String outputPath = inputRootPath + "GumTreeResults/";
log.info("Set the output data..." + GUM_TREE_OUTPUT ); log.info("Set the output data..." + outputPath );
final List<MessageFile> msgFiles = getMessageFiles(GUM_TREE_INPUT);
log.info("MessageFiles: " + msgFiles.size());
// output path
final String editScriptsFilePath = GUM_TREE_OUTPUT + "editScripts/";
final String patchesSourceCodeFilePath = GUM_TREE_OUTPUT + "patchSourceCode/";
final String buggyTokensFilePath = GUM_TREE_OUTPUT + "tokens/";
final String editScriptSizesFilePath = GUM_TREE_OUTPUT + "editScriptSizes/";
FileHelper.deleteDirectory(editScriptsFilePath);
FileHelper.deleteDirectory(patchesSourceCodeFilePath);
FileHelper.deleteDirectory(buggyTokensFilePath);
FileHelper.deleteDirectory(editScriptSizesFilePath);
ActorSystem system = null; File folder = new File(GUM_TREE_INPUT);
ActorRef parsingActor = null; File[] listOfFiles = folder.listFiles();
final WorkMessage msg = new WorkMessage(0, msgFiles); Stream<File> stream = Arrays.stream(listOfFiles);
try { List<File> folders = stream
log.info("Akka begins..."); .filter(x -> !x.getName().startsWith("."))
system = ActorSystem.create("Mining-FixPattern-System"); .collect(Collectors.toList());
parsingActor = system.actorOf(ParseFixPatternActor.props(numberOfWorkers, editScriptsFilePath,
patchesSourceCodeFilePath, buggyTokensFilePath, editScriptSizesFilePath), "mine-fix-pattern-actor"); for (File target : folders) {
parsingActor.tell(msg, ActorRef.noSender()); final List<MessageFile> msgFiles = getMessageFiles(target.toString() + "/");
} catch (Exception e) { log.info("MessageFiles: " + msgFiles.size());
system.shutdown(); // output path
e.printStackTrace();
String pjName = target.getName();
// output path
String GUM_TREE_OUTPUT = outputPath + pjName + "/";
final String editScriptsFilePath = GUM_TREE_OUTPUT + "editScripts.list";
final String patchesSourceCodeFilePath =GUM_TREE_OUTPUT + "patchSourceCode.list";
final String buggyTokensFilePath = GUM_TREE_OUTPUT + "tokens.list";
final String editScriptSizesFilePath = GUM_TREE_OUTPUT + "editScriptSizes.csv";
final String alarmTypesFilePath = GUM_TREE_OUTPUT + "alarmTypes.list";
FileHelper.deleteDirectory(editScriptsFilePath);
FileHelper.deleteDirectory(patchesSourceCodeFilePath);
FileHelper.deleteDirectory(buggyTokensFilePath);
FileHelper.deleteDirectory(editScriptSizesFilePath);
ActorSystem system = null;
ActorRef parsingActor = null;
final WorkMessage msg = new WorkMessage(0, msgFiles);
try {
log.info("Akka begins...");
system = ActorSystem.create("Mining-FixPattern-System");
parsingActor = system.actorOf(ParseFixPatternActor.props(numberOfWorkers, editScriptsFilePath,
patchesSourceCodeFilePath, buggyTokensFilePath, editScriptSizesFilePath), "mine-fix-pattern-actor");
parsingActor.tell(msg, ActorRef.noSender());
} catch (Exception e) {
system.shutdown();
e.printStackTrace();
}
} }