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

no akka

Browse Source
This commit is contained in:
Anil Koyuncu
2018-04-04 19:24:25 +02:00
parent 37b36051fc
commit 5c27c2c87b
1 changed files with 32 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/edu/lu/uni/serval/FixPatternParser/violations/AkkaTreeLoader.java
+32 -26
View File
@@ -152,17 +152,17 @@ public class AkkaTreeLoader {
File[] listFiles = files.listFiles();
Stream<File> stream = Arrays.stream(listFiles);
List<File> folders = stream
.filter(x -> x.getName().equals(chunkName))
.collect(Collectors.toList());
for (File folder : folders) {
// Stream<File> stream = Arrays.stream(listFiles);
// List<File> folders = stream
// .filter(x -> x.getName().equals(chunkName))
// .collect(Collectors.toList());
// for (File folder : folders) {
String cmd = "bash "+dbDir + "/" + "startServer.sh" +" %s %s %s";
cmd = String.format(cmd, dbDir,folder.getName(),Integer.valueOf(innerPort));
cmd = String.format(cmd, dbDir,chunkName,Integer.valueOf(innerPort));
loadRedis(cmd,serverWait);
@@ -185,30 +185,36 @@ public class AkkaTreeLoader {
List<String> result = scan.getResult();
ActorSystem system = null;
ActorRef parsingActor = null;
final WorkMessage msg = new WorkMessage(0, result,innerPort,inputPath,dbDir,serverWait);
try {
log.info("Akka begins...");
system = ActorSystem.create("Tree-System");
parsingActor = system.actorOf(TreeActor.props(Integer.valueOf(numOfWorkers),dbDir,innerPort,serverWait), "tree-actor");
parsingActor.tell(msg, ActorRef.noSender());
} catch (Exception e) {
system.shutdown();
e.printStackTrace();
}
// ActorSystem system = null;
// ActorRef parsingActor = null;
// final WorkMessage msg = new WorkMessage(0, result,innerPort,inputPath,dbDir,serverWait);
// try {
//
// log.info("Akka begins...");
// system = ActorSystem.create("Tree-System");
// parsingActor = system.actorOf(TreeActor.props(Integer.valueOf(numOfWorkers),dbDir,innerPort,serverWait), "tree-actor");
// parsingActor.tell(msg, ActorRef.noSender());
// } catch (Exception e) {
// system.shutdown();
// e.printStackTrace();
// }
// greeter.tell();
// .parallelStream()
// .forEach(m -> coreCompare(m, inputPath, innerPort));
result
.parallelStream()
.forEach(m ->
{
Compare compare = new Compare(poolConfig);
compare.coreCompare(m, inputPath, innerPort);
;
}
);
// String stopServer = "bash "+dbDir + "/" + "stopServer.sh" +" %s";
// stopServer = String.format(stopServer,Integer.valueOf(innerPort));
// loadRedis(stopServer,serverWait);
String stopServer = "bash "+dbDir + "/" + "stopServer.sh" +" %s";
stopServer = String.format(stopServer,Integer.valueOf(innerPort));
loadRedis(stopServer,serverWait);
}
// }