Skip to content
Snippets Groups Projects
Commit e7680072 authored by Florian Fittkau's avatar Florian Fittkau
Browse files

merge with pst-bachelor branch

parent 43046300
Branches
Tags
No related merge requests found
...@@ -39,8 +39,7 @@ public final class TraceReconstructionFilter extends AbstractFilter implements I ...@@ -39,8 +39,7 @@ public final class TraceReconstructionFilter extends AbstractFilter implements I
traceBuffer.insertEvent(abstractOperationEvent); traceBuffer.insertEvent(abstractOperationEvent);
if (traceBuffer.isFinished()) { if (traceBuffer.isFinished()) {
final Trace trace = traceBuffer.toTrace(true); deliver(traceBuffer.toTrace(true));
deliver(trace);
traceId2trace.remove(traceId); traceId2trace.remove(traceId);
} }
} else if (record instanceof Trace) { } else if (record instanceof Trace) {
......
...@@ -5,8 +5,6 @@ import java.util.concurrent.TimeUnit; ...@@ -5,8 +5,6 @@ import java.util.concurrent.TimeUnit;
import explorviz.live_trace_processing.configuration.Configuration; import explorviz.live_trace_processing.configuration.Configuration;
import explorviz.live_trace_processing.configuration.ConfigurationFactory; import explorviz.live_trace_processing.configuration.ConfigurationFactory;
import explorviz.live_trace_processing.filter.ITraceSink; import explorviz.live_trace_processing.filter.ITraceSink;
import explorviz.live_trace_processing.filter.counting.IRecordCounting;
import explorviz.live_trace_processing.filter.counting.RecordCountingFilter;
import explorviz.live_trace_processing.filter.reconstruction.ITraceReconstruction; import explorviz.live_trace_processing.filter.reconstruction.ITraceReconstruction;
import explorviz.live_trace_processing.filter.reconstruction.TraceReconstructionFilter; import explorviz.live_trace_processing.filter.reconstruction.TraceReconstructionFilter;
import explorviz.live_trace_processing.filter.reduction.ITraceReduction; import explorviz.live_trace_processing.filter.reduction.ITraceReduction;
...@@ -16,10 +14,11 @@ import explorviz.live_trace_processing.reader.TCPReader; ...@@ -16,10 +14,11 @@ import explorviz.live_trace_processing.reader.TCPReader;
public class FilterConfiguration { public class FilterConfiguration {
public static void configureAndStartFilters(final Configuration configuration, public static void configureAndStartFilters(final Configuration configuration,
final ITraceSink sink) { final ITraceSink sink) {
final IRecordCounting recordCounting = new RecordCountingFilter(sink); // final IRecordCounting recordCounting = new
// RecordCountingFilter(sink);
final ITraceReduction traceReduction = new TracePatternSummarizationFilter( final ITraceReduction traceReduction = new TracePatternSummarizationFilter(
TimeUnit.MILLISECONDS.toNanos(990), recordCounting); TimeUnit.MILLISECONDS.toNanos(990), sink);
final ITraceReconstruction traceReconstruction = new TraceReconstructionFilter( final ITraceReconstruction traceReconstruction = new TraceReconstructionFilter(
TimeUnit.SECONDS.toNanos(4), traceReduction); TimeUnit.SECONDS.toNanos(4), traceReduction);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment