From 165895e6f72c053c623b02a835b3f442000395aa Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Thu, 12 Feb 2015 18:07:58 +0100
Subject: [PATCH] removed logging in Relay
---
.settings/edu.umd.cs.findbugs.core.prefs | 2 +-
src/main/java/teetime/stage/Relay.java | 15 ---------------
2 files changed, 1 insertion(+), 16 deletions(-)
diff --git a/.settings/edu.umd.cs.findbugs.core.prefs b/.settings/edu.umd.cs.findbugs.core.prefs
index 9234b725..b3cb73a2 100644
--- a/.settings/edu.umd.cs.findbugs.core.prefs
+++ b/.settings/edu.umd.cs.findbugs.core.prefs
@@ -1,5 +1,5 @@
#FindBugs User Preferences
-#Wed Feb 04 15:13:53 CET 2015
+#Mon Feb 09 10:32:26 CET 2015
detector_threshold=3
effort=max
excludefilter0=.fbExcludeFilterFile|true
diff --git a/src/main/java/teetime/stage/Relay.java b/src/main/java/teetime/stage/Relay.java
index 7849b8b2..7bf8e450 100644
--- a/src/main/java/teetime/stage/Relay.java
+++ b/src/main/java/teetime/stage/Relay.java
@@ -20,31 +20,16 @@ import teetime.framework.OutputPort;
public final class Relay<T> extends AbstractConsumerStage<T> {
- // private final InputPort<T> inputPort = this.createInputPort();
private final OutputPort<T> outputPort = this.createOutputPort();
- // private AbstractInterThreadPipe cachedCastedInputPipe;
-
@Override
protected void execute(final T element) {
if (null == element) {
- // if (this.cachedCastedInputPipe.getSignal() instanceof TerminatingSignal) {
- // this.terminate();
- // }
- // Thread.yield();
- // return;
- logger.trace("relay: returnNoElement");
returnNoElement();
}
outputPort.send(element);
}
- // @Override
- // public void onStarting() throws Exception {
- // super.onStarting();
- // this.cachedCastedInputPipe = (AbstractInterThreadPipe) this.inputPort.getPipe();
- // }
-
public OutputPort<T> getOutputPort() {
return outputPort;
}
--
GitLab