From 9062a4b6e275e05d006ee569f0f6ef7f3f42b650 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Fri, 21 Aug 2015 15:40:13 +0200
Subject: [PATCH] added active flag typo
---
.../java/teetime/framework/AbstractCompositeStage.java | 1 +
src/main/java/teetime/framework/Stage.java | 10 ++++++++++
.../teetime/framework/AbstractCompositeStageTest.java | 6 +++---
3 files changed, 14 insertions(+), 3 deletions(-)
diff --git a/src/main/java/teetime/framework/AbstractCompositeStage.java b/src/main/java/teetime/framework/AbstractCompositeStage.java
index ab55c4b3..342d057e 100644
--- a/src/main/java/teetime/framework/AbstractCompositeStage.java
+++ b/src/main/java/teetime/framework/AbstractCompositeStage.java
@@ -54,6 +54,7 @@ public abstract class AbstractCompositeStage {
AbstractRunnableStage runnable = AbstractRunnableStage.create(stage);
Thread newThread = new TeeTimeThread(runnable, threadName);
stage.setOwningThread(newThread);
+ stage.setActive(true);
}
/**
diff --git a/src/main/java/teetime/framework/Stage.java b/src/main/java/teetime/framework/Stage.java
index 4cc0cf76..4a246b59 100644
--- a/src/main/java/teetime/framework/Stage.java
+++ b/src/main/java/teetime/framework/Stage.java
@@ -50,6 +50,8 @@ public abstract class Stage {
/** The owning thread of this stage if this stage is directly executed by a {@link AbstractRunnableStage}, <code>null</code> otherwise. */
private Thread owningThread;
+ private boolean isActive;
+
private ConfigurationContext owningContext;
ConfigurationContext getOwningContext() {
@@ -181,4 +183,12 @@ public abstract class Stage {
protected abstract void removeDynamicPort(InputPort<?> inputPort);
+ public boolean isActive() {
+ return isActive;
+ }
+
+ void setActive(final boolean isActive) {
+ this.isActive = isActive;
+ }
+
}
diff --git a/src/test/java/teetime/framework/AbstractCompositeStageTest.java b/src/test/java/teetime/framework/AbstractCompositeStageTest.java
index 414e0f1c..418d9994 100644
--- a/src/test/java/teetime/framework/AbstractCompositeStageTest.java
+++ b/src/test/java/teetime/framework/AbstractCompositeStageTest.java
@@ -27,17 +27,17 @@ public class AbstractCompositeStageTest {
@Ignore
@Test
public void testNestedStages() {
- Execution<NestesConfig> exec = new Execution<NestesConfig>(new NestesConfig());
+ Execution<NestedConf> exec = new Execution<NestedConf>(new NestedConf());
// assertThat(exec.getConfiguration().getContext().getThreadableStages().size(), is(3));
}
- private class NestesConfig extends Configuration {
+ private class NestedConf extends Configuration {
private final InitialElementProducer<Object> init;
private final Sink sink;
private final TestNestingCompositeStage compositeStage;
- public NestesConfig() {
+ public NestedConf() {
init = new InitialElementProducer<Object>(new Object());
sink = new Sink();
compositeStage = new TestNestingCompositeStage();
--
GitLab