diff --git a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy.java b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy.java index de7df44939c81d24ff6698996dfd12f32368823a..77dae9254342e38c34366652caba9cadb523c584 100644 --- a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy.java +++ b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy.java @@ -25,7 +25,7 @@ import teetime.framework.Stage; */ public final class RoundRobinStrategy implements IDistributorStrategy { - private int index = 0; + private int index; @Override public <T> boolean distribute(final OutputPort<T>[] outputPorts, final T element) { diff --git a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java index fb11cefcad5287f01e8e5a14976a5e2137302802..54103cb2fe24386f7ae5b45bab760db8285a9587 100644 --- a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java +++ b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java @@ -25,7 +25,7 @@ import teetime.framework.Stage; */ public final class RoundRobinStrategy2 implements IDistributorStrategy { - private int index = 0; + private int index; private int numWaits; @Override @@ -46,8 +46,6 @@ public final class RoundRobinStrategy2 implements IDistributorStrategy { numLoops--; } while (!success); - System.out.println("Sent " + element + " via " + outputPort); - return true; } diff --git a/src/main/java/teetime/stage/basic/distributor/dynamic/CreatePortAction.java b/src/main/java/teetime/stage/basic/distributor/dynamic/CreatePortAction.java index 7141ff95c0ce3c3973cf30dd2296b6d5094a9e1b..5c1cf8facdbbf1dec6eeef55caa055c722c85633 100644 --- a/src/main/java/teetime/stage/basic/distributor/dynamic/CreatePortAction.java +++ b/src/main/java/teetime/stage/basic/distributor/dynamic/CreatePortAction.java @@ -19,13 +19,8 @@ public class CreatePortAction<T> implements PortAction<T> { this.inputPort = inputPort; } - public InputPort<T> getInputPort() { - return inputPort; - } - @Override public void execute(final DynamicDistributor<T> dynamicDistributor) { - System.out.println("Creating..."); OutputPort<? extends T> newOutputPort = dynamicDistributor.getNewOutputPort(); INTER_THREAD_PIPE_FACTORY.create(newOutputPort, inputPort); @@ -38,6 +33,9 @@ public class CreatePortAction<T> implements PortAction<T> { newOutputPort.sendSignal(new StartingSignal()); // FIXME pass the new thread to the analysis so that it can terminate the thread at the end - System.out.println("Created."); + } + + InputPort<T> getInputPort() { // for testing purposes only + return inputPort; } } diff --git a/src/main/java/teetime/stage/basic/distributor/dynamic/RemovePortAction.java b/src/main/java/teetime/stage/basic/distributor/dynamic/RemovePortAction.java index 848445ff3219c04a80520244da9375a5523bac9c..46d7f09f074aa1dc9169f105f707c11204e8fe7d 100644 --- a/src/main/java/teetime/stage/basic/distributor/dynamic/RemovePortAction.java +++ b/src/main/java/teetime/stage/basic/distributor/dynamic/RemovePortAction.java @@ -13,22 +13,20 @@ public class RemovePortAction<T> implements PortAction<T> { this.outputPort = outputPort; } - // public DynamicOutputPort<T> getOutputPort() { - // return outputPort; - // } - @Override public void execute(final DynamicDistributor<T> dynamicDistributor) { - System.out.println("Removing..."); + OutputPort<?> outputPortToRemove; + if (dynamicDistributor instanceof ControlledDynamicDistributor) { + // for testing purposes only OutputPort<?>[] outputPorts = ((ControlledDynamicDistributor<?>) dynamicDistributor).getOutputPorts(); - OutputPort<?> outputPortToRemove = outputPorts[outputPorts.length - 1]; - // outputPortToRemove = outputPort; + outputPortToRemove = outputPorts[outputPorts.length - 1]; + } else { + outputPortToRemove = outputPort; + } - outputPortToRemove.sendSignal(new TerminatingSignal()); + outputPortToRemove.sendSignal(new TerminatingSignal()); - dynamicDistributor.removeDynamicPort((DynamicOutputPort<?>) outputPortToRemove); - } - System.out.println("Removed."); + dynamicDistributor.removeDynamicPort((DynamicOutputPort<?>) outputPortToRemove); } }