From e292a1a5310a10c18c03fefeac32b54583b3dfed Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Fri, 19 Jun 2015 14:47:11 +0200
Subject: [PATCH] some renaming
---
...mpositeStage.java => AbstractStageComposition.java} | 8 ++++----
src/main/java/teetime/framework/Analysis.java | 6 +++---
.../java/teetime/framework/AnalysisInstantiation.java | 6 +++---
.../framework/{Network.java => Configuration.java} | 2 +-
...{AnalysisContext.java => ConfigurationContext.java} | 2 +-
src/main/java/teetime/framework/test/StageTester.java | 8 ++++----
src/main/java/teetime/stage/io/EveryXthPrinter.java | 8 ++++----
src/main/java/teetime/stage/string/WordCounter.java | 8 ++++----
.../teetime/examples/cipher/CipherConfiguration.java | 4 ++--
src/test/java/teetime/examples/cipher/CipherTest.java | 4 ++--
.../examples/tokenizer/TokenizerConfiguration.java | 4 ++--
src/test/java/teetime/framework/AnalysisTest.java | 10 +++++-----
.../RunnableConsumerStageTestConfiguration.java | 2 +-
src/test/java/teetime/framework/StageTest.java | 2 +-
src/test/java/teetime/framework/TraversorTest.java | 2 +-
.../teetime/framework/WaitStrategyConfiguration.java | 2 +-
.../teetime/framework/YieldStrategyConfiguration.java | 2 +-
.../exceptionHandling/ExceptionTestConfiguration.java | 4 ++--
src/test/java/teetime/stage/InstanceOfFilterTest.java | 4 ++--
19 files changed, 44 insertions(+), 44 deletions(-)
rename src/main/java/teetime/framework/{AbstractCompositeStage.java => AbstractStageComposition.java} (85%)
rename src/main/java/teetime/framework/{Network.java => Configuration.java} (90%)
rename src/main/java/teetime/framework/{AnalysisContext.java => ConfigurationContext.java} (99%)
diff --git a/src/main/java/teetime/framework/AbstractCompositeStage.java b/src/main/java/teetime/framework/AbstractStageComposition.java
similarity index 85%
rename from src/main/java/teetime/framework/AbstractCompositeStage.java
rename to src/main/java/teetime/framework/AbstractStageComposition.java
index e0d86063..86567aec 100644
--- a/src/main/java/teetime/framework/AbstractCompositeStage.java
+++ b/src/main/java/teetime/framework/AbstractStageComposition.java
@@ -23,11 +23,11 @@ package teetime.framework;
*
*
*/
-public abstract class AbstractCompositeStage extends Network {
+public abstract class AbstractStageComposition extends Configuration {
- private final AnalysisContext context;
+ private final ConfigurationContext context;
- public AbstractCompositeStage(final AnalysisContext context) {
+ public AbstractStageComposition(final ConfigurationContext context) {
this.context = context;
}
@@ -46,7 +46,7 @@ public abstract class AbstractCompositeStage extends Network {
context.addThreadableStage(stage);
}
- protected AnalysisContext getContext() {
+ protected ConfigurationContext getContext() {
return context;
}
diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java
index 0b376d32..fbc63b73 100644
--- a/src/main/java/teetime/framework/Analysis.java
+++ b/src/main/java/teetime/framework/Analysis.java
@@ -35,7 +35,7 @@ import teetime.util.Pair;
/**
* Represents an Analysis to which stages can be added and executed later.
- * This needs a {@link AnalysisContext},
+ * This needs a {@link ConfigurationContext},
* in which the adding and configuring of stages takes place.
* To start the analysis {@link #executeBlocking()} needs to be executed.
* This class will automatically create threads and join them without any further commitment.
@@ -43,9 +43,9 @@ import teetime.util.Pair;
* @author Christian Wulf, Nelson Tavares de Sousa
*
* @param <T>
- * the type of the {@link AnalysisContext}
+ * the type of the {@link ConfigurationContext}
*/
-public final class Analysis<T extends AnalysisContext> implements UncaughtExceptionHandler {
+public final class Analysis<T extends ConfigurationContext> implements UncaughtExceptionHandler {
private static final Logger LOGGER = LoggerFactory.getLogger(Analysis.class);
diff --git a/src/main/java/teetime/framework/AnalysisInstantiation.java b/src/main/java/teetime/framework/AnalysisInstantiation.java
index aa4217b8..48d824b1 100644
--- a/src/main/java/teetime/framework/AnalysisInstantiation.java
+++ b/src/main/java/teetime/framework/AnalysisInstantiation.java
@@ -36,14 +36,14 @@ class AnalysisInstantiation {
private final IPipeFactory interUnboundedThreadPipeFactory = new UnboundedSpScPipeFactory();
private final IPipeFactory intraThreadPipeFactory = new SingleElementPipeFactory();
- private final AnalysisContext configuration;
+ private final ConfigurationContext configuration;
- public AnalysisInstantiation(final AnalysisContext configuration) {
+ public AnalysisInstantiation(final ConfigurationContext configuration) {
this.configuration = configuration;
}
@SuppressWarnings("rawtypes")
- Integer colorAndConnectStages(final Integer i, final Map<Stage, Integer> colors, final Stage threadableStage, final AnalysisContext configuration) {
+ Integer colorAndConnectStages(final Integer i, final Map<Stage, Integer> colors, final Stage threadableStage, final ConfigurationContext configuration) {
Integer createdConnections = new Integer(0);
Set<Stage> threadableStageJobs = configuration.getThreadableStages();
for (OutputPort outputPort : threadableStage.getOutputPorts()) {
diff --git a/src/main/java/teetime/framework/Network.java b/src/main/java/teetime/framework/Configuration.java
similarity index 90%
rename from src/main/java/teetime/framework/Network.java
rename to src/main/java/teetime/framework/Configuration.java
index e73a7ebf..9615e6b0 100644
--- a/src/main/java/teetime/framework/Network.java
+++ b/src/main/java/teetime/framework/Configuration.java
@@ -1,6 +1,6 @@
package teetime.framework;
-public abstract class Network {
+public abstract class Configuration {
protected abstract <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity);
diff --git a/src/main/java/teetime/framework/AnalysisContext.java b/src/main/java/teetime/framework/ConfigurationContext.java
similarity index 99%
rename from src/main/java/teetime/framework/AnalysisContext.java
rename to src/main/java/teetime/framework/ConfigurationContext.java
index 5c763367..496be307 100644
--- a/src/main/java/teetime/framework/AnalysisContext.java
+++ b/src/main/java/teetime/framework/ConfigurationContext.java
@@ -29,7 +29,7 @@ import teetime.framework.pipe.PipeFactoryRegistry.ThreadCommunication;
* Represents a configuration of connected stages, which is needed to run a analysis.
* Stages can be added by executing {@link #addThreadableStage(Stage)}.
*/
-public abstract class AnalysisContext extends Network {
+public abstract class ConfigurationContext extends Configuration {
private final Set<Stage> threadableStages = new HashSet<Stage>();
diff --git a/src/main/java/teetime/framework/test/StageTester.java b/src/main/java/teetime/framework/test/StageTester.java
index e40c4d91..dea7016c 100644
--- a/src/main/java/teetime/framework/test/StageTester.java
+++ b/src/main/java/teetime/framework/test/StageTester.java
@@ -20,7 +20,7 @@ import java.util.Arrays;
import java.util.List;
import teetime.framework.Analysis;
-import teetime.framework.AnalysisContext;
+import teetime.framework.ConfigurationContext;
import teetime.framework.AnalysisException;
import teetime.framework.Stage;
import teetime.framework.StageState;
@@ -78,12 +78,12 @@ public final class StageTester {
*
*/
public void start() {
- final AnalysisContext configuration = new Configuration(inputHolders, stage, outputHolders);
- final Analysis<AnalysisContext> analysis = new Analysis<AnalysisContext>(configuration);
+ final ConfigurationContext configuration = new Configuration(inputHolders, stage, outputHolders);
+ final Analysis<ConfigurationContext> analysis = new Analysis<ConfigurationContext>(configuration);
analysis.executeBlocking();
}
- private final class Configuration extends AnalysisContext {
+ private final class Configuration extends ConfigurationContext {
public Configuration(final List<InputHolder<?>> inputHolders, final Stage stage, final List<OutputHolder<?>> outputHolders) {
for (InputHolder<?> inputHolder : inputHolders) {
diff --git a/src/main/java/teetime/stage/io/EveryXthPrinter.java b/src/main/java/teetime/stage/io/EveryXthPrinter.java
index 2641bb72..3eaa7751 100644
--- a/src/main/java/teetime/stage/io/EveryXthPrinter.java
+++ b/src/main/java/teetime/stage/io/EveryXthPrinter.java
@@ -18,8 +18,8 @@ package teetime.stage.io;
import java.util.ArrayList;
import java.util.List;
-import teetime.framework.AbstractCompositeStage;
-import teetime.framework.AnalysisContext;
+import teetime.framework.AbstractStageComposition;
+import teetime.framework.ConfigurationContext;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
import teetime.framework.Stage;
@@ -27,12 +27,12 @@ import teetime.stage.EveryXthStage;
import teetime.stage.basic.distributor.CopyByReferenceStrategy;
import teetime.stage.basic.distributor.Distributor;
-public final class EveryXthPrinter<T> extends AbstractCompositeStage {
+public final class EveryXthPrinter<T> extends AbstractStageComposition {
private final Distributor<T> distributor;
private final List<Stage> lastStages = new ArrayList<Stage>();
- public EveryXthPrinter(final int threshold, final AnalysisContext context) {
+ public EveryXthPrinter(final int threshold, final ConfigurationContext context) {
super(context);
distributor = new Distributor<T>(new CopyByReferenceStrategy());
EveryXthStage<T> everyXthStage = new EveryXthStage<T>(threshold);
diff --git a/src/main/java/teetime/stage/string/WordCounter.java b/src/main/java/teetime/stage/string/WordCounter.java
index 4ca80c65..6ca7b91a 100644
--- a/src/main/java/teetime/stage/string/WordCounter.java
+++ b/src/main/java/teetime/stage/string/WordCounter.java
@@ -17,8 +17,8 @@ package teetime.stage.string;
import java.util.ArrayList;
-import teetime.framework.AbstractCompositeStage;
-import teetime.framework.AnalysisContext;
+import teetime.framework.AbstractStageComposition;
+import teetime.framework.ConfigurationContext;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
import teetime.framework.Stage;
@@ -34,7 +34,7 @@ import teetime.stage.util.CountingMap;
* @author Nelson Tavares de Sousa
*
*/
-public final class WordCounter extends AbstractCompositeStage {
+public final class WordCounter extends AbstractStageComposition {
// This fields are needed for the methods to work.
private final Tokenizer tokenizer = new Tokenizer(" ");
@@ -42,7 +42,7 @@ public final class WordCounter extends AbstractCompositeStage {
private final ArrayList<Stage> lastStages = new ArrayList<Stage>();
// The connection of the different stages is realized within the construction of a instance of this class.
- public WordCounter(final AnalysisContext context) {
+ public WordCounter(final ConfigurationContext context) {
super(context);
this.lastStages.add(this.mapCounter);
final ToLowerCase toLowerCase = new ToLowerCase();
diff --git a/src/test/java/teetime/examples/cipher/CipherConfiguration.java b/src/test/java/teetime/examples/cipher/CipherConfiguration.java
index 11861a87..717a6fb3 100644
--- a/src/test/java/teetime/examples/cipher/CipherConfiguration.java
+++ b/src/test/java/teetime/examples/cipher/CipherConfiguration.java
@@ -17,7 +17,7 @@ package teetime.examples.cipher;
import java.io.File;
-import teetime.framework.AnalysisContext;
+import teetime.framework.ConfigurationContext;
import teetime.stage.CipherStage;
import teetime.stage.CipherStage.CipherMode;
import teetime.stage.InitialElementProducer;
@@ -26,7 +26,7 @@ import teetime.stage.ZipByteArray.ZipMode;
import teetime.stage.io.ByteArrayFileWriter;
import teetime.stage.io.File2ByteArray;
-public class CipherConfiguration extends AnalysisContext {
+public class CipherConfiguration extends ConfigurationContext {
public CipherConfiguration(final String inputFile, final String outputFile, final String password) {
final File input = new File(inputFile);
diff --git a/src/test/java/teetime/examples/cipher/CipherTest.java b/src/test/java/teetime/examples/cipher/CipherTest.java
index 38a8d1f6..da9562ed 100644
--- a/src/test/java/teetime/examples/cipher/CipherTest.java
+++ b/src/test/java/teetime/examples/cipher/CipherTest.java
@@ -22,7 +22,7 @@ import org.junit.Assert;
import org.junit.Test;
import teetime.framework.Analysis;
-import teetime.framework.AnalysisContext;
+import teetime.framework.ConfigurationContext;
import com.google.common.io.Files;
@@ -43,7 +43,7 @@ public class CipherTest {
final String outputFile = "src/test/resources/data/output.txt";
final String password = "Password";
- final AnalysisContext configuration = new CipherConfiguration(inputFile, outputFile, password);
+ final ConfigurationContext configuration = new CipherConfiguration(inputFile, outputFile, password);
final Analysis analysis = new Analysis(configuration);
analysis.executeBlocking();
diff --git a/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java b/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
index 90dea5d2..d76fcbb9 100644
--- a/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
+++ b/src/test/java/teetime/examples/tokenizer/TokenizerConfiguration.java
@@ -17,7 +17,7 @@ package teetime.examples.tokenizer;
import java.io.File;
-import teetime.framework.AnalysisContext;
+import teetime.framework.ConfigurationContext;
import teetime.stage.ByteArray2String;
import teetime.stage.CipherStage;
import teetime.stage.CipherStage.CipherMode;
@@ -28,7 +28,7 @@ import teetime.stage.ZipByteArray.ZipMode;
import teetime.stage.io.File2ByteArray;
import teetime.stage.string.Tokenizer;
-public class TokenizerConfiguration extends AnalysisContext {
+public class TokenizerConfiguration extends ConfigurationContext {
private final Counter<String> counter;
diff --git a/src/test/java/teetime/framework/AnalysisTest.java b/src/test/java/teetime/framework/AnalysisTest.java
index a77c101a..02872fc7 100644
--- a/src/test/java/teetime/framework/AnalysisTest.java
+++ b/src/test/java/teetime/framework/AnalysisTest.java
@@ -70,7 +70,7 @@ public class AnalysisTest {
assertThat(watch.getDurationInMs() + ABSOLUTE_MAX_ERROR_IN_MS, is(greaterThanOrEqualTo(DELAY_IN_MS)));
}
- private static class TestConfig extends AnalysisContext {
+ private static class TestConfig extends ConfigurationContext {
public final DelayAndTerminate delay;
public TestConfig() {
@@ -112,7 +112,7 @@ public class AnalysisTest {
assertThat(intraAnalysis.getConfiguration().init.getOwningThread(), is(intraAnalysis.getConfiguration().sink.getOwningThread()));
}
- private class AnalysisTestConfig extends AnalysisContext {
+ private class AnalysisTestConfig extends ConfigurationContext {
public InitialElementProducer<Object> init = new InitialElementProducer<Object>();
public Sink<Object> sink = new Sink<Object>();
@@ -136,7 +136,7 @@ public class AnalysisTest {
new Analysis<InvalidTestConfig>(configuration);
}
- private class InvalidTestConfig extends AnalysisContext {
+ private class InvalidTestConfig extends ConfigurationContext {
public InitialElementProducer<Object> init = new InitialElementProducer<Object>();
public InstanceOfFilter<Object, Object> iof = new InstanceOfFilter<Object, Object>(Object.class);
public Sink<Object> sink = new Sink<Object>();
@@ -153,11 +153,11 @@ public class AnalysisTest {
@Test
public void automaticallyAddHeadStages() {
AutomaticallyConfig context = new AutomaticallyConfig();
- new Analysis<AnalysisContext>(context).executeBlocking();
+ new Analysis<ConfigurationContext>(context).executeBlocking();
assertTrue(context.executed);
}
- private class AutomaticallyConfig extends AnalysisContext {
+ private class AutomaticallyConfig extends ConfigurationContext {
public boolean executed;
diff --git a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
index 89be4761..904cae28 100644
--- a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
+++ b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
@@ -21,7 +21,7 @@ import java.util.List;
import teetime.stage.CollectorSink;
import teetime.stage.InitialElementProducer;
-public class RunnableConsumerStageTestConfiguration extends AnalysisContext {
+public class RunnableConsumerStageTestConfiguration extends ConfigurationContext {
private final List<Integer> collectedElements = new ArrayList<Integer>();
private final CollectorSink<Integer> collectorSink;
diff --git a/src/test/java/teetime/framework/StageTest.java b/src/test/java/teetime/framework/StageTest.java
index 5531fb48..d21612f8 100644
--- a/src/test/java/teetime/framework/StageTest.java
+++ b/src/test/java/teetime/framework/StageTest.java
@@ -53,7 +53,7 @@ public class StageTest {
assertEquals(tc.init.exceptionHandler, tc.delay.exceptionHandler);
}
- private static class TestConfig extends AnalysisContext {
+ private static class TestConfig extends ConfigurationContext {
public final DelayAndTerminate delay;
public InitialElementProducer<String> init;
diff --git a/src/test/java/teetime/framework/TraversorTest.java b/src/test/java/teetime/framework/TraversorTest.java
index 7244e13a..7d32f1f7 100644
--- a/src/test/java/teetime/framework/TraversorTest.java
+++ b/src/test/java/teetime/framework/TraversorTest.java
@@ -53,7 +53,7 @@ public class TraversorTest {
}
// WordCounterConfiguration
- private class TestConfiguration extends AnalysisContext {
+ private class TestConfiguration extends ConfigurationContext {
public final CountingMapMerger<String> result = new CountingMapMerger<String>();
public final InitialElementProducer<File> init;
diff --git a/src/test/java/teetime/framework/WaitStrategyConfiguration.java b/src/test/java/teetime/framework/WaitStrategyConfiguration.java
index 2e7cb2ff..5ca67a38 100644
--- a/src/test/java/teetime/framework/WaitStrategyConfiguration.java
+++ b/src/test/java/teetime/framework/WaitStrategyConfiguration.java
@@ -21,7 +21,7 @@ import teetime.stage.InitialElementProducer;
import teetime.stage.Relay;
import teetime.stage.basic.Delay;
-class WaitStrategyConfiguration extends AnalysisContext {
+class WaitStrategyConfiguration extends ConfigurationContext {
private Delay<Object> delay;
private CollectorSink<Object> collectorSink;
diff --git a/src/test/java/teetime/framework/YieldStrategyConfiguration.java b/src/test/java/teetime/framework/YieldStrategyConfiguration.java
index 41edee01..b19df100 100644
--- a/src/test/java/teetime/framework/YieldStrategyConfiguration.java
+++ b/src/test/java/teetime/framework/YieldStrategyConfiguration.java
@@ -19,7 +19,7 @@ import teetime.stage.CollectorSink;
import teetime.stage.InitialElementProducer;
import teetime.stage.Relay;
-class YieldStrategyConfiguration extends AnalysisContext {
+class YieldStrategyConfiguration extends ConfigurationContext {
private CollectorSink<Object> collectorSink;
diff --git a/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java b/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
index 8dd38b07..15b5023b 100644
--- a/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
+++ b/src/test/java/teetime/framework/exceptionHandling/ExceptionTestConfiguration.java
@@ -15,9 +15,9 @@
*/
package teetime.framework.exceptionHandling;
-import teetime.framework.AnalysisContext;
+import teetime.framework.ConfigurationContext;
-public class ExceptionTestConfiguration extends AnalysisContext {
+public class ExceptionTestConfiguration extends ConfigurationContext {
ExceptionTestProducerStage first;
ExceptionTestConsumerStage second;
diff --git a/src/test/java/teetime/stage/InstanceOfFilterTest.java b/src/test/java/teetime/stage/InstanceOfFilterTest.java
index d3382247..6dbf6807 100644
--- a/src/test/java/teetime/stage/InstanceOfFilterTest.java
+++ b/src/test/java/teetime/stage/InstanceOfFilterTest.java
@@ -30,7 +30,7 @@ import org.junit.Before;
import org.junit.Test;
import teetime.framework.Analysis;
-import teetime.framework.AnalysisContext;
+import teetime.framework.ConfigurationContext;
import teetime.framework.AnalysisException;
import teetime.util.Pair;
@@ -122,7 +122,7 @@ public class InstanceOfFilterTest {
}
}
- private static class InstanceOfFilterTestConfig extends AnalysisContext {
+ private static class InstanceOfFilterTestConfig extends ConfigurationContext {
public InstanceOfFilterTestConfig() {
InitialElementProducer<Object> elementProducer = new InitialElementProducer<Object>();
--
GitLab