From 9b5d9462a55818f871b3ae122b4b85e6d52f45e0 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Fri, 17 Oct 2014 10:14:36 +0200
Subject: [PATCH] renamed setSignal to sendSignal
---
src/main/java/teetime/framework/OutputPort.java | 2 +-
src/main/java/teetime/framework/pipe/DummyPipe.java | 2 +-
src/main/java/teetime/framework/pipe/IPipe.java | 2 +-
src/main/java/teetime/framework/pipe/InterThreadPipe.java | 4 ++--
src/main/java/teetime/framework/pipe/IntraThreadPipe.java | 2 +-
.../examples/experiment17/MethodCallThroughputAnalysis17.java | 2 +-
src/test/java/teetime/examples/pipe/SignalQueueTest.java | 2 +-
7 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/src/main/java/teetime/framework/OutputPort.java b/src/main/java/teetime/framework/OutputPort.java
index e53b5aff..45a8de63 100644
--- a/src/main/java/teetime/framework/OutputPort.java
+++ b/src/main/java/teetime/framework/OutputPort.java
@@ -18,7 +18,7 @@ public final class OutputPort<T> extends AbstractPort<T> {
}
public void sendSignal(final ISignal signal) {
- this.pipe.setSignal(signal);
+ this.pipe.sendSignal(signal);
}
public void reportNewElement() {
diff --git a/src/main/java/teetime/framework/pipe/DummyPipe.java b/src/main/java/teetime/framework/pipe/DummyPipe.java
index 98629184..716046dc 100644
--- a/src/main/java/teetime/framework/pipe/DummyPipe.java
+++ b/src/main/java/teetime/framework/pipe/DummyPipe.java
@@ -44,7 +44,7 @@ public final class DummyPipe implements IPipe {
}
@Override
- public void setSignal(final ISignal signal) {}
+ public void sendSignal(final ISignal signal) {}
@Override
public void connectPorts(final OutputPort sourcePort, final InputPort targetPort) {}
diff --git a/src/main/java/teetime/framework/pipe/IPipe.java b/src/main/java/teetime/framework/pipe/IPipe.java
index 1e9d2f43..8fee03e7 100644
--- a/src/main/java/teetime/framework/pipe/IPipe.java
+++ b/src/main/java/teetime/framework/pipe/IPipe.java
@@ -18,7 +18,7 @@ public interface IPipe {
InputPort<?> getTargetPort();
- void setSignal(ISignal signal);
+ void sendSignal(ISignal signal);
@Deprecated
<T> void connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort);
diff --git a/src/main/java/teetime/framework/pipe/InterThreadPipe.java b/src/main/java/teetime/framework/pipe/InterThreadPipe.java
index 258b6412..a38e5951 100644
--- a/src/main/java/teetime/framework/pipe/InterThreadPipe.java
+++ b/src/main/java/teetime/framework/pipe/InterThreadPipe.java
@@ -13,14 +13,14 @@ import teetime.framework.signal.ISignal;
public abstract class InterThreadPipe extends AbstractPipe {
- private final Queue<ISignal> signalQueue = QueueFactory.newQueue(new ConcurrentQueueSpec(1, 1, 0, Ordering.FIFO, Preference.THROUGHPUT));;
+ private final Queue<ISignal> signalQueue = QueueFactory.newQueue(new ConcurrentQueueSpec(1, 1, 0, Ordering.FIFO, Preference.THROUGHPUT));
<T> InterThreadPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
super(sourcePort, targetPort);
}
@Override
- public void setSignal(final ISignal signal) {
+ public void sendSignal(final ISignal signal) {
this.signalQueue.offer(signal);
}
diff --git a/src/main/java/teetime/framework/pipe/IntraThreadPipe.java b/src/main/java/teetime/framework/pipe/IntraThreadPipe.java
index 27a7aa2a..42257bc9 100644
--- a/src/main/java/teetime/framework/pipe/IntraThreadPipe.java
+++ b/src/main/java/teetime/framework/pipe/IntraThreadPipe.java
@@ -11,7 +11,7 @@ public abstract class IntraThreadPipe extends AbstractPipe {
}
@Override
- public void setSignal(final ISignal signal) {
+ public void sendSignal(final ISignal signal) {
if (this.getTargetPort() != null) { // BETTER remove this check since there are DummyPorts
this.cachedTargetStage.onSignal(signal, this.getTargetPort());
}
diff --git a/src/performancetest/java/teetime/examples/experiment17/MethodCallThroughputAnalysis17.java b/src/performancetest/java/teetime/examples/experiment17/MethodCallThroughputAnalysis17.java
index a6464885..b61ed4da 100644
--- a/src/performancetest/java/teetime/examples/experiment17/MethodCallThroughputAnalysis17.java
+++ b/src/performancetest/java/teetime/examples/experiment17/MethodCallThroughputAnalysis17.java
@@ -149,7 +149,7 @@ public class MethodCallThroughputAnalysis17 {
final CollectorSink<TimestampObject> collectorSink = new CollectorSink<TimestampObject>(timestampObjects);
IPipe startPipe = new RelayTestPipe<TimestampObject>(this.numInputObjects, this.inputObjectCreator);
- startPipe.setSignal(new TerminatingSignal());
+ startPipe.sendSignal(new TerminatingSignal());
relay.getInputPort().setPipe(startPipe);
UnorderedGrowablePipe.connect(relay.getOutputPort(), startTimestampFilter.getInputPort());
diff --git a/src/test/java/teetime/examples/pipe/SignalQueueTest.java b/src/test/java/teetime/examples/pipe/SignalQueueTest.java
index 4b31ab26..9e42dabc 100644
--- a/src/test/java/teetime/examples/pipe/SignalQueueTest.java
+++ b/src/test/java/teetime/examples/pipe/SignalQueueTest.java
@@ -28,7 +28,7 @@ public class SignalQueueTest {
SpScPipe pipe = new SignalQueueConfiguration().pipe;
for (ISignal s : list) {
- pipe.setSignal(s);
+ pipe.sendSignal(s);
}
ArrayList<ISignal> secondList = new ArrayList<ISignal>();
--
GitLab