From d3afffc0864e15e34e3a5df5d2ecbf6939b6fed0 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Tue, 26 May 2015 17:14:53 +0200
Subject: [PATCH] renamed method
---
.../teetime/framework/AnalysisConfiguration.java | 2 +-
.../java/teetime/framework/test/StageTester.java | 4 ++--
.../teetime/examples/cipher/CipherConfiguration.java | 12 ++++++------
.../examples/tokenizer/TokenizerConfiguration.java | 12 ++++++------
src/test/java/teetime/framework/AnalysisTest.java | 4 ++--
.../RunnableConsumerStageTestConfiguration.java | 2 +-
src/test/java/teetime/framework/StageTest.java | 2 +-
src/test/java/teetime/framework/TraversorTest.java | 10 +++++-----
.../teetime/framework/WaitStrategyConfiguration.java | 8 ++++----
.../framework/YieldStrategyConfiguration.java | 4 ++--
.../ExceptionTestConfiguration.java | 2 +-
.../java/teetime/stage/InstanceOfFilterTest.java | 6 +++---
12 files changed, 34 insertions(+), 34 deletions(-)
diff --git a/src/main/java/teetime/framework/AnalysisConfiguration.java b/src/main/java/teetime/framework/AnalysisConfiguration.java
index f9b9e4ef..b8c6bee5 100644
--- a/src/main/java/teetime/framework/AnalysisConfiguration.java
+++ b/src/main/java/teetime/framework/AnalysisConfiguration.java
@@ -145,7 +145,7 @@ public abstract class AnalysisConfiguration {
return interUnboundedThreadFactory.create(sourcePort, targetPort, capacity);
}
- protected <T> void connectStages(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
+ protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
connections.add(new Pair<OutputPort, InputPort>(sourcePort, targetPort));
}
diff --git a/src/main/java/teetime/framework/test/StageTester.java b/src/main/java/teetime/framework/test/StageTester.java
index 2c3ac523..59092010 100644
--- a/src/main/java/teetime/framework/test/StageTester.java
+++ b/src/main/java/teetime/framework/test/StageTester.java
@@ -88,7 +88,7 @@ public final class StageTester {
public Configuration(final List<InputHolder<?>> inputHolders, final Stage stage, final List<OutputHolder<?>> outputHolders) {
for (InputHolder<?> inputHolder : inputHolders) {
final InitialElementProducer<Object> producer = new InitialElementProducer<Object>(inputHolder.getInput());
- connectStages(producer.getOutputPort(), inputHolder.getPort());
+ connectPorts(producer.getOutputPort(), inputHolder.getPort());
addThreadableStage(producer);
}
@@ -96,7 +96,7 @@ public final class StageTester {
for (OutputHolder<?> outputHolder : outputHolders) {
final CollectorSink<Object> sink = new CollectorSink<Object>(outputHolder.getOutputElements());
- connectStages(outputHolder.getPort(), sink.getInputPort());
+ connectPorts(outputHolder.getPort(), sink.getInputPort());
}
}
}
diff --git a/src/test/java/teetime/examples/cipher/CipherConfiguration.java b/src/test/java/teetime/examples/cipher/CipherConfiguration.java
index 8cef45c5..95ba33f4 100644
--- a/src/test/java/teetime/examples/cipher/CipherConfiguration.java
+++ b/src/test/java/teetime/examples/cipher/CipherConfiguration.java
@@ -40,12 +40,12 @@ public class CipherConfiguration extends AnalysisConfiguration {
final CipherStage decrypt = new CipherStage(password, CipherMode.DECRYPT);
final ByteArrayFileWriter writer = new ByteArrayFileWriter(output);
- connectStages(init.getOutputPort(), f2b.getInputPort());
- connectStages(f2b.getOutputPort(), enc.getInputPort());
- connectStages(enc.getOutputPort(), comp.getInputPort());
- connectStages(comp.getOutputPort(), decomp.getInputPort());
- connectStages(decomp.getOutputPort(), decrypt.getInputPort());
- connectStages(decrypt.getOutputPort(), writer.getInputPort());
+ connectPorts(init.getOutputPort(), f2b.getInputPort());
+ connectPorts(f2b.getOutputPort(), enc.getInputPort());
+ connectPorts(enc.getOutputPort(), comp.getInputPort());
+ connectPorts(comp.getOutputPort(), decomp.getInputPort());
+ connectPorts(decomp.getOutputPort(), decrypt.getInputPort());
+ connectPorts(decrypt.getOutputPort(), writer.getInputPort());
// this.getFiniteProducerStages().add(init);
this.addThreadableStage(init);
diff --git a/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java b/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
index 32bec67f..15c325da 100644
--- a/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
+++ b/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
@@ -43,12 +43,12 @@ public class TokenizerConfiguration extends AnalysisConfiguration {
final Tokenizer tokenizer = new Tokenizer(" ");
this.counter = new Counter<String>();
- connectStages(init.getOutputPort(), f2b.getInputPort());
- connectStages(f2b.getOutputPort(), decomp.getInputPort());
- connectStages(decomp.getOutputPort(), decrypt.getInputPort());
- connectStages(decrypt.getOutputPort(), b2s.getInputPort());
- connectStages(b2s.getOutputPort(), tokenizer.getInputPort());
- connectStages(tokenizer.getOutputPort(), this.counter.getInputPort());
+ connectPorts(init.getOutputPort(), f2b.getInputPort());
+ connectPorts(f2b.getOutputPort(), decomp.getInputPort());
+ connectPorts(decomp.getOutputPort(), decrypt.getInputPort());
+ connectPorts(decrypt.getOutputPort(), b2s.getInputPort());
+ connectPorts(b2s.getOutputPort(), tokenizer.getInputPort());
+ connectPorts(tokenizer.getOutputPort(), this.counter.getInputPort());
this.addThreadableStage(init);
}
diff --git a/src/test/java/teetime/framework/AnalysisTest.java b/src/test/java/teetime/framework/AnalysisTest.java
index 4c64c25f..5a596637 100644
--- a/src/test/java/teetime/framework/AnalysisTest.java
+++ b/src/test/java/teetime/framework/AnalysisTest.java
@@ -73,7 +73,7 @@ public class AnalysisTest {
public TestConfig() {
final InitialElementProducer<String> init = new InitialElementProducer<String>("Hello");
delay = new DelayAndTerminate(DELAY_IN_MS);
- connectStages(init.getOutputPort(), delay.getInputPort());
+ connectPorts(init.getOutputPort(), delay.getInputPort());
addThreadableStage(init);
}
}
@@ -114,7 +114,7 @@ public class AnalysisTest {
public Sink<Object> sink = new Sink<Object>();
public AnalysisTestConfig(final boolean inter) {
- connectStages(init.getOutputPort(), sink.getInputPort());
+ connectPorts(init.getOutputPort(), sink.getInputPort());
addThreadableStage(init);
if (inter) {
addThreadableStage(sink);
diff --git a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
index 6e3be7ba..7dca2a99 100644
--- a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
+++ b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
@@ -35,7 +35,7 @@ public class RunnableConsumerStageTestConfiguration extends AnalysisConfiguratio
CollectorSink<Integer> collectorSink = new CollectorSink<Integer>(collectedElements);
addThreadableStage(collectorSink);
- connectStages(producer.getOutputPort(), collectorSink.getInputPort());
+ connectPorts(producer.getOutputPort(), collectorSink.getInputPort());
this.collectorSink = collectorSink;
}
diff --git a/src/test/java/teetime/framework/StageTest.java b/src/test/java/teetime/framework/StageTest.java
index 4df2995e..19580dcb 100644
--- a/src/test/java/teetime/framework/StageTest.java
+++ b/src/test/java/teetime/framework/StageTest.java
@@ -60,7 +60,7 @@ public class StageTest {
public TestConfig() {
init = new InitialElementProducer<String>("Hello");
delay = new DelayAndTerminate(0);
- connectStages(init.getOutputPort(), delay.getInputPort());
+ connectPorts(init.getOutputPort(), delay.getInputPort());
addThreadableStage(init);
}
}
diff --git a/src/test/java/teetime/framework/TraversorTest.java b/src/test/java/teetime/framework/TraversorTest.java
index f447dc20..f8951048 100644
--- a/src/test/java/teetime/framework/TraversorTest.java
+++ b/src/test/java/teetime/framework/TraversorTest.java
@@ -71,8 +71,8 @@ public class TraversorTest {
// CountingMapMerger (already as field)
// Connecting the stages of the first part of the config
- connectStages(init.getOutputPort(), f2b.getInputPort());
- connectStages(f2b.getOutputPort(), distributor.getInputPort());
+ connectPorts(init.getOutputPort(), f2b.getInputPort());
+ connectPorts(f2b.getOutputPort(), distributor.getInputPort());
// Middle part... multiple instances of WordCounter are created and connected to the merger and distrubuter stages
for (int i = 0; i < threads; i++) {
@@ -80,15 +80,15 @@ public class TraversorTest {
final WordCounter wc = new WordCounter();
// intraFact.create(inputPortSizePrinter.getOutputPort(), wc.getInputPort());
- connectStages(distributor.getNewOutputPort(), wc.getInputPort());
- connectStages(wc.getOutputPort(), merger.getNewInputPort());
+ connectPorts(distributor.getNewOutputPort(), wc.getInputPort());
+ connectPorts(wc.getOutputPort(), merger.getNewInputPort());
// Add WordCounter as a threadable stage, so it runs in its own thread
addThreadableStage(wc);
}
// Connect the stages of the last part
- connectStages(merger.getOutputPort(), result.getInputPort());
+ connectPorts(merger.getOutputPort(), result.getInputPort());
// Add the first and last part to the threadable stages
addThreadableStage(init);
diff --git a/src/test/java/teetime/framework/WaitStrategyConfiguration.java b/src/test/java/teetime/framework/WaitStrategyConfiguration.java
index 785aafd7..191f8460 100644
--- a/src/test/java/teetime/framework/WaitStrategyConfiguration.java
+++ b/src/test/java/teetime/framework/WaitStrategyConfiguration.java
@@ -42,7 +42,7 @@ class WaitStrategyConfiguration extends AnalysisConfiguration {
Clock clock = new Clock();
clock.setInitialDelayInMs(initialDelayInMs);
- connectStages(clock.getOutputPort(), delay.getTimestampTriggerInputPort());
+ connectPorts(clock.getOutputPort(), delay.getTimestampTriggerInputPort());
return clock;
}
@@ -51,7 +51,7 @@ class WaitStrategyConfiguration extends AnalysisConfiguration {
InitialElementProducer<Object> initialElementProducer = new InitialElementProducer<Object>(elements);
delay = new Delay<Object>();
- connectStages(initialElementProducer.getOutputPort(), delay.getInputPort());
+ connectPorts(initialElementProducer.getOutputPort(), delay.getInputPort());
return initialElementProducer;
}
@@ -62,8 +62,8 @@ class WaitStrategyConfiguration extends AnalysisConfiguration {
// relay.setIdleStrategy(new WaitStrategy(relay));
- connectStages(delay.getOutputPort(), relay.getInputPort());
- connectStages(relay.getOutputPort(), collectorSink.getInputPort());
+ connectPorts(delay.getOutputPort(), relay.getInputPort());
+ connectPorts(relay.getOutputPort(), collectorSink.getInputPort());
this.collectorSink = collectorSink;
diff --git a/src/test/java/teetime/framework/YieldStrategyConfiguration.java b/src/test/java/teetime/framework/YieldStrategyConfiguration.java
index 8c784d11..a6302594 100644
--- a/src/test/java/teetime/framework/YieldStrategyConfiguration.java
+++ b/src/test/java/teetime/framework/YieldStrategyConfiguration.java
@@ -44,8 +44,8 @@ class YieldStrategyConfiguration extends AnalysisConfiguration {
// relay.setIdleStrategy(new YieldStrategy());
- connectStages(producer.getOutputPort(), relay.getInputPort());
- connectStages(relay.getOutputPort(), collectorSink.getInputPort());
+ connectPorts(producer.getOutputPort(), relay.getInputPort());
+ connectPorts(relay.getOutputPort(), collectorSink.getInputPort());
this.collectorSink = collectorSink;
diff --git a/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java b/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
index ab1d2e27..d985faf2 100644
--- a/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
+++ b/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
@@ -28,7 +28,7 @@ public class ExceptionTestConfiguration extends AnalysisConfiguration {
second = new ExceptionTestConsumerStage();
third = new ExceptionTestProducerStage();
- connectStages(first.getOutputPort(), second.getInputPort());
+ connectPorts(first.getOutputPort(), second.getInputPort());
// this.addThreadableStage(new ExceptionTestStage());
this.addThreadableStage(first);
diff --git a/src/test/java/teetime/stage/InstanceOfFilterTest.java b/src/test/java/teetime/stage/InstanceOfFilterTest.java
index 03e13bfc..b87d2ec3 100644
--- a/src/test/java/teetime/stage/InstanceOfFilterTest.java
+++ b/src/test/java/teetime/stage/InstanceOfFilterTest.java
@@ -130,9 +130,9 @@ public class InstanceOfFilterTest {
CollectorSink<Clazz> clazzCollector = new CollectorSink<Clazz>();
CollectorSink<Object> mismatchedCollector = new CollectorSink<Object>();
- connectStages(elementProducer.getOutputPort(), instanceOfFilter.getInputPort());
- connectStages(instanceOfFilter.getMatchedOutputPort(), clazzCollector.getInputPort());
- connectStages(instanceOfFilter.getMismatchedOutputPort(), mismatchedCollector.getInputPort());
+ connectPorts(elementProducer.getOutputPort(), instanceOfFilter.getInputPort());
+ connectPorts(instanceOfFilter.getMatchedOutputPort(), clazzCollector.getInputPort());
+ connectPorts(instanceOfFilter.getMismatchedOutputPort(), mismatchedCollector.getInputPort());
addThreadableStage(elementProducer);
}
--
GitLab