From 1b383675cd719b095e0c0c76a7e6dc745e1f3082 Mon Sep 17 00:00:00 2001 From: Anil Koyuncu Date: Wed, 4 Apr 2018 22:38:14 +0200 Subject: [PATCH] poolfix --- .../violations/RunnableCompare.java | 13 +++++++------ .../FixPatternParser/violations/TreeWorker.java | 5 ++--- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/src/main/java/edu/lu/uni/serval/FixPatternParser/violations/RunnableCompare.java b/src/main/java/edu/lu/uni/serval/FixPatternParser/violations/RunnableCompare.java index 0ff319f..3079eb3 100644 --- a/src/main/java/edu/lu/uni/serval/FixPatternParser/violations/RunnableCompare.java +++ b/src/main/java/edu/lu/uni/serval/FixPatternParser/violations/RunnableCompare.java @@ -1,25 +1,26 @@ package edu.lu.uni.serval.FixPatternParser.violations; import edu.lu.uni.serval.FixPatternParser.Parser; +import redis.clients.jedis.JedisPool; import java.io.File; public class RunnableCompare implements Runnable { private String name; - private String inputPath; - private String innerPort; + private JedisPool innerPool; + private JedisPool outerPool; private Compare comparer; - public RunnableCompare(String name , String inputPath, String innerPort, Compare comp) { + public RunnableCompare(String name , JedisPool innerPool, JedisPool outerPool, Compare comp) { this.name = name; - this.inputPath = inputPath; - this.innerPort = innerPort; + this.innerPool = innerPool; + this.outerPool = outerPool; this.comparer = comp; } @Override public void run() { - comparer.coreCompare(name, inputPath, innerPort); + comparer.coreCompare(name, innerPool, outerPool); } } diff --git a/src/main/java/edu/lu/uni/serval/FixPatternParser/violations/TreeWorker.java b/src/main/java/edu/lu/uni/serval/FixPatternParser/violations/TreeWorker.java index c5b2205..f6839b5 100644 --- a/src/main/java/edu/lu/uni/serval/FixPatternParser/violations/TreeWorker.java +++ b/src/main/java/edu/lu/uni/serval/FixPatternParser/violations/TreeWorker.java @@ -80,9 +80,8 @@ public class TreeWorker extends UntypedActor { peek(x -> counter++). forEach(m -> { - Compare compare = new Compare(poolConfig); - compare.coreCompare(m, inputPath, innerPort); - ; + Compare compare = new Compare(); +// compare.coreCompare(m, inputPath, innerPort); } ); }