From 80a9810fab25518ec3773fe9a359d2d05a6cf765 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Fri, 5 Dec 2014 15:16:37 +0100
Subject: [PATCH] adapted new API
---
.settings/edu.umd.cs.findbugs.core.prefs | 2 +-
.../stage/className/ClassNameRegistryCreationFilter.java | 2 +-
.../java/teetime/stage/explorviz/KiekerRecordTcpReader.java | 4 ++--
src/main/java/teetime/stage/io/database/DbReader.java | 2 +-
.../format/binary/file/BinaryFile2RecordFilter.java | 2 +-
.../io/filesystem/format/text/file/TextLine2RecordFilter.java | 2 +-
src/main/java/teetime/stage/io/network/TcpReader.java | 2 +-
.../java/teetime/stage/stringBuffer/StringBufferFilter.java | 2 +-
.../trace/traceReconstruction/TraceReconstructionFilter.java | 2 +-
.../stage/trace/traceReduction/TraceReductionFilter.java | 4 ++--
10 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/.settings/edu.umd.cs.findbugs.core.prefs b/.settings/edu.umd.cs.findbugs.core.prefs
index d8e404f2..f9c5ef79 100644
--- a/.settings/edu.umd.cs.findbugs.core.prefs
+++ b/.settings/edu.umd.cs.findbugs.core.prefs
@@ -1,5 +1,5 @@
#FindBugs User Preferences
-#Fri Dec 05 08:18:05 CET 2014
+#Fri Dec 05 15:14:55 CET 2014
detector_threshold=3
effort=max
excludefilter0=.fbExcludeFilterFile|true
diff --git a/src/main/java/teetime/stage/className/ClassNameRegistryCreationFilter.java b/src/main/java/teetime/stage/className/ClassNameRegistryCreationFilter.java
index e8c3a29b..ddd9c536 100644
--- a/src/main/java/teetime/stage/className/ClassNameRegistryCreationFilter.java
+++ b/src/main/java/teetime/stage/className/ClassNameRegistryCreationFilter.java
@@ -61,7 +61,7 @@ public class ClassNameRegistryCreationFilter extends AbstractConsumerStage<File>
try {
final ClassNameRegistry classNameRegistry = this.mappingFileParser.parseFromStream(new FileInputStream(mappingFile));
this.classNameRegistryRepository.put(inputDir, classNameRegistry);
- this.send(this.outputPort, inputDir);
+ outputPort.send(inputDir);
// final String filePrefix = this.mappingFileParser.getFilePrefixFromMappingFile(mappingFile);
// context.put(this.filePrefixOutputPort, filePrefix); // TODO pass prefix
diff --git a/src/main/java/teetime/stage/explorviz/KiekerRecordTcpReader.java b/src/main/java/teetime/stage/explorviz/KiekerRecordTcpReader.java
index 8fc450e7..beb743eb 100644
--- a/src/main/java/teetime/stage/explorviz/KiekerRecordTcpReader.java
+++ b/src/main/java/teetime/stage/explorviz/KiekerRecordTcpReader.java
@@ -181,7 +181,7 @@ public class KiekerRecordTcpReader extends AbstractProducerStage<IMonitoringReco
}
final IMonitoringRecord record = new BeforeOperationEvent(timestamp, traceId, orderIndex, operation, clazz);
- this.send(this.outputPort, record);
+ outputPort.send(record);
}
private final void readInAfterOperationEvent(final ByteBuffer buffer) {
@@ -190,7 +190,7 @@ public class KiekerRecordTcpReader extends AbstractProducerStage<IMonitoringReco
final int orderIndex = buffer.getInt();
final IMonitoringRecord record = new AfterOperationEvent(timestamp, traceId, orderIndex, null, null);
- this.send(this.outputPort, record);
+ outputPort.send(record);
}
private final void putInWaitingMessages(final ByteBuffer buffer, final int length) {
diff --git a/src/main/java/teetime/stage/io/database/DbReader.java b/src/main/java/teetime/stage/io/database/DbReader.java
index 3c3d6648..c9f1972b 100644
--- a/src/main/java/teetime/stage/io/database/DbReader.java
+++ b/src/main/java/teetime/stage/io/database/DbReader.java
@@ -173,7 +173,7 @@ public class DbReader extends AbstractProducerStage<IMonitoringRecord> {
}
final IMonitoringRecord record = AbstractMonitoringRecord.createFromArray(clazz, recordValues);
record.setLoggingTimestamp(records.getLong(2));
- this.send(this.outputPort, record);
+ outputPort.send(record);
}
} finally {
if (records != null) {
diff --git a/src/main/java/teetime/stage/io/filesystem/format/binary/file/BinaryFile2RecordFilter.java b/src/main/java/teetime/stage/io/filesystem/format/binary/file/BinaryFile2RecordFilter.java
index 79670050..7e3b3738 100644
--- a/src/main/java/teetime/stage/io/filesystem/format/binary/file/BinaryFile2RecordFilter.java
+++ b/src/main/java/teetime/stage/io/filesystem/format/binary/file/BinaryFile2RecordFilter.java
@@ -79,7 +79,7 @@ public class BinaryFile2RecordFilter extends AbstractConsumerStage<File> {
try {
IMonitoringRecord record = this.recordFromBinaryFileCreator.createRecordFromBinaryFile(binaryFile, in);
while (record != null) {
- this.send(this.outputPort, record);
+ outputPort.send(record);
record = this.recordFromBinaryFileCreator.createRecordFromBinaryFile(binaryFile, in);
}
} catch (final MonitoringRecordException e) {
diff --git a/src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java b/src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java
index a165b77a..b7cec874 100644
--- a/src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java
+++ b/src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java
@@ -81,7 +81,7 @@ public class TextLine2RecordFilter extends AbstractConsumerStage<TextLine> {
protected void execute(final TextLine textLine) {
try {
final IMonitoringRecord record = this.recordFromTextLineCreator.createRecordFromLine(textLine.getTextFile(), textLine.getTextLine());
- this.send(this.outputPort, record);
+ outputPort.send(record);
} catch (final MonitoringRecordException e) {
this.logger.error("Could not create record from text line: '" + textLine + "'", e);
} catch (final IllegalRecordFormatException e) {
diff --git a/src/main/java/teetime/stage/io/network/TcpReader.java b/src/main/java/teetime/stage/io/network/TcpReader.java
index ac6575ed..668234f5 100644
--- a/src/main/java/teetime/stage/io/network/TcpReader.java
+++ b/src/main/java/teetime/stage/io/network/TcpReader.java
@@ -85,7 +85,7 @@ public class TcpReader extends AbstractTcpReader<IMonitoringRecord> {
IMonitoringRecord record = recordFactory.create(buffer, this.stringRegistry);
record.setLoggingTimestamp(loggingTimestamp);
- this.send(this.outputPort, record);
+ outputPort.send(record);
} catch (final BufferUnderflowException ex) {
super.logger.error("Failed to create record.", ex);
} catch (final RecordInstantiationException ex) {
diff --git a/src/main/java/teetime/stage/stringBuffer/StringBufferFilter.java b/src/main/java/teetime/stage/stringBuffer/StringBufferFilter.java
index 73a8e99c..24d030f5 100644
--- a/src/main/java/teetime/stage/stringBuffer/StringBufferFilter.java
+++ b/src/main/java/teetime/stage/stringBuffer/StringBufferFilter.java
@@ -40,7 +40,7 @@ public class StringBufferFilter<T> extends AbstractConsumerStage<T> {
@Override
protected void execute(final T element) {
final T returnedElement = this.handle(element);
- this.send(this.outputPort, returnedElement);
+ outputPort.send(returnedElement);
}
@Override
diff --git a/src/main/java/teetime/stage/trace/traceReconstruction/TraceReconstructionFilter.java b/src/main/java/teetime/stage/trace/traceReconstruction/TraceReconstructionFilter.java
index 3652abe7..081bbd5f 100644
--- a/src/main/java/teetime/stage/trace/traceReconstruction/TraceReconstructionFilter.java
+++ b/src/main/java/teetime/stage/trace/traceReconstruction/TraceReconstructionFilter.java
@@ -105,7 +105,7 @@ public class TraceReconstructionFilter extends AbstractConsumerStage<IFlowRecord
private void sendTraceBuffer(final TraceBuffer traceBuffer) {
OutputPort<TraceEventRecords> outputPort = (traceBuffer.isInvalid()) ? this.traceInvalidOutputPort
: this.traceValidOutputPort;
- this.send(outputPort, traceBuffer.toTraceEvents());
+ outputPort.send(traceBuffer.toTraceEvents());
}
public TimeUnit getTimeunit() {
diff --git a/src/main/java/teetime/stage/trace/traceReduction/TraceReductionFilter.java b/src/main/java/teetime/stage/trace/traceReduction/TraceReductionFilter.java
index 3f5dda01..4da8edc8 100644
--- a/src/main/java/teetime/stage/trace/traceReduction/TraceReductionFilter.java
+++ b/src/main/java/teetime/stage/trace/traceReduction/TraceReductionFilter.java
@@ -79,7 +79,7 @@ public class TraceReductionFilter extends AbstractConsumerStage<TraceEventRecord
final TraceAggregationBuffer buffer = entry.getValue();
final TraceEventRecords record = buffer.getTraceEventRecords();
record.setCount(buffer.getCount());
- this.send(this.outputPort, record);
+ outputPort.send(record);
}
this.trace2buffer.clear();
}
@@ -97,7 +97,7 @@ public class TraceReductionFilter extends AbstractConsumerStage<TraceEventRecord
if (traceBuffer.getBufferCreatedTimestamp() <= bufferTimeoutInNs) {
final TraceEventRecords record = traceBuffer.getTraceEventRecords();
record.setCount(traceBuffer.getCount());
- this.send(this.outputPort, record);
+ outputPort.send(record);
}
iterator.remove();
}
--
GitLab