From 1983a690eb3b5122a1523174022a27d99ddd618a Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <ntd@informatik.uni-kiel.de>
Date: Wed, 18 Feb 2015 16:27:23 +0100
Subject: [PATCH] As there is no mechanism indicating a potential loss of data,
this test can't be modified to always run perfectly
---
src/main/java/teetime/framework/RunnableConsumerStage.java | 2 +-
src/main/java/teetime/stage/basic/merger/Merger.java | 3 +--
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/src/main/java/teetime/framework/RunnableConsumerStage.java b/src/main/java/teetime/framework/RunnableConsumerStage.java
index 1def6deb..95d6db17 100644
--- a/src/main/java/teetime/framework/RunnableConsumerStage.java
+++ b/src/main/java/teetime/framework/RunnableConsumerStage.java
@@ -81,7 +81,7 @@ final class RunnableConsumerStage extends AbstractRunnableStage {
logger.debug("Checking signals for: " + Arrays.toString(inputPorts));
for (InputPort<?> inputPort : inputPorts) {
IPipe pipe = inputPort.getPipe();
- if (pipe instanceof AbstractInterThreadPipe) {
+ if (pipe instanceof AbstractInterThreadPipe) { // TODO: is this needed?
AbstractInterThreadPipe intraThreadPipe = (AbstractInterThreadPipe) pipe;
ISignal signal = intraThreadPipe.getSignal();
if (null != signal) {
diff --git a/src/main/java/teetime/stage/basic/merger/Merger.java b/src/main/java/teetime/stage/basic/merger/Merger.java
index 706fe08a..739574e8 100644
--- a/src/main/java/teetime/stage/basic/merger/Merger.java
+++ b/src/main/java/teetime/stage/basic/merger/Merger.java
@@ -77,7 +77,7 @@ public final class Merger<T> extends AbstractStage {
@SuppressWarnings("unchecked")
@Override
public void onSignal(final ISignal signal, final InputPort<?> inputPort) {
- this.logger.debug("Got signal: " + signal + " from input port: " + inputPort);
+ this.logger.warn("Got signal: " + signal + " from input port: " + inputPort);
Class<? extends ISignal> signalClass = signal.getClass();
@@ -94,7 +94,6 @@ public final class Merger<T> extends AbstractStage {
}
if (signalMap.get(signalClass).size() == this.getInputPorts().length) {
- System.out.println("SENT");
signal.trigger(this);
this.outputPort.sendSignal(signal);
signalMap.remove(signalClass);
--
GitLab