Skip to content
Snippets Groups Projects
Commit ea939900 authored by Christian Wulf's avatar Christian Wulf
Browse files

changed variable declarations from HashSet to Set

parent 2889ad31
No related branches found
No related tags found
No related merge requests found
#FindBugs User Preferences #FindBugs User Preferences
#Tue Nov 18 10:57:28 CET 2014 #Tue Nov 25 12:10:00 CET 2014
detector_threshold=3 detector_threshold=3
effort=max effort=max
excludefilter0=.fbExcludeFilterFile|true excludefilter0=.fbExcludeFilterFile|true
......
...@@ -19,6 +19,7 @@ package teetime.stage.basic.merger; ...@@ -19,6 +19,7 @@ package teetime.stage.basic.merger;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
import java.util.Map; import java.util.Map;
import java.util.Set;
import teetime.framework.AbstractStage; import teetime.framework.AbstractStage;
import teetime.framework.InputPort; import teetime.framework.InputPort;
...@@ -43,7 +44,7 @@ public class Merger<T> extends AbstractStage { ...@@ -43,7 +44,7 @@ public class Merger<T> extends AbstractStage {
private IMergerStrategy<T> strategy = new RoundRobinStrategy<T>(); private IMergerStrategy<T> strategy = new RoundRobinStrategy<T>();
private final Map<Class<?>, HashSet<InputPort<?>>> signalMap = new HashMap<Class<?>, HashSet<InputPort<?>>>(); private final Map<Class<?>, Set<InputPort<?>>> signalMap = new HashMap<Class<?>, Set<InputPort<?>>>();
@Override @Override
public void executeWithPorts() { public void executeWithPorts() {
...@@ -71,7 +72,7 @@ public class Merger<T> extends AbstractStage { ...@@ -71,7 +72,7 @@ public class Merger<T> extends AbstractStage {
this.logger.trace("Got signal: " + signal + " from input port: " + inputPort); this.logger.trace("Got signal: " + signal + " from input port: " + inputPort);
if (signalMap.containsKey(signal.getClass())) { if (signalMap.containsKey(signal.getClass())) {
HashSet<InputPort<?>> set = signalMap.get(signal.getClass()); Set<InputPort<?>> set = signalMap.get(signal.getClass());
if (!set.add(inputPort)) { if (!set.add(inputPort)) {
this.logger.warn("Received more than one signal - " + signal + " - from input port: " + inputPort); this.logger.warn("Received more than one signal - " + signal + " - from input port: " + inputPort);
} }
...@@ -82,7 +83,7 @@ public class Merger<T> extends AbstractStage { ...@@ -82,7 +83,7 @@ public class Merger<T> extends AbstractStage {
} }
} else { } else {
signal.trigger(this); signal.trigger(this);
HashSet<InputPort<?>> tempSet = new HashSet<InputPort<?>>(); Set<InputPort<?>> tempSet = new HashSet<InputPort<?>>();
tempSet.add(inputPort); tempSet.add(inputPort);
signalMap.put(signal.getClass(), tempSet); signalMap.put(signal.getClass(), tempSet);
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment