diff --git a/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java b/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java index 4a7804e1d31bd67ee5a77e6165e68fe36fb33507..946ef33f4556b35eb0128c97dc519305c856bc34 100644 --- a/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java +++ b/src/main/java/kieker/analysis/TraceAnalysisConfiguration.java @@ -4,18 +4,11 @@ package kieker.analysis; import java.io.File; -import java.util.ArrayList; -import java.util.List; -import kieker.analysis.dev.DependencyCreatorStage; -import kieker.analysis.dev.DependencyStatisticsDecoratorStage; -import kieker.analysis.domain.AggregatedOperationCall; import kieker.analysis.domain.AggregatedTrace; -import kieker.analysis.domain.OperationCall; import kieker.analysis.domain.Trace; import kieker.analysis.stage.tracediagnosis.AllowedRecordsFilter; import kieker.analysis.stage.tracediagnosis.BeginEndOfMonitoringDetector; -import kieker.analysis.stage.tracediagnosis.OperationCallHandlerComposite; import kieker.analysis.stage.tracediagnosis.ReadingComposite; import kieker.analysis.stage.tracediagnosis.TraceAggregationComposite; import kieker.analysis.stage.tracediagnosis.TraceReconstructionComposite; @@ -25,36 +18,32 @@ import kieker.analysis.trace.traversal.TraceTraverserStage; import kieker.analysis.util.graph.Graph; import kieker.analysis.util.graph.export.graphml.GraphMLFileWriterStage; import kieker.common.record.IMonitoringRecord; -import kieker.common.record.misc.KiekerMetadataRecord; import teetime.framework.Configuration; -import teetime.stage.CollectorSink; import teetime.stage.MultipleInstanceOfFilter; import teetime.stage.basic.distributor.Distributor; import teetime.stage.basic.distributor.strategy.CopyByReferenceStrategy; /** + * This {@link Configuration} imports monitoring records from a directory and + * generate several graphs. + * + * @author Sören Henning * */ - public class TraceAnalysisConfiguration extends Configuration { - private final List<OperationCall> operationCalls = new ArrayList<>(1000); - private final List<AggregatedOperationCall> aggregatedOperationCalls = new ArrayList<>(1000); - - private final List<KiekerMetadataRecord> metadataRecords = new ArrayList<>(1000); private final TraceReconstructionComposite reconstruction; private final BeginEndOfMonitoringDetector beginEndOfMonitoringDetector; private final AllowedRecordsFilter allowedRecordsFilter; public TraceAnalysisConfiguration(final File importDirectory) { + // Create the stages final ReadingComposite reader = new ReadingComposite(importDirectory); final MultipleInstanceOfFilter<IMonitoringRecord> typeFilter = new MultipleInstanceOfFilter<>(); final Distributor<Trace> distributor = new Distributor<>(new CopyByReferenceStrategy()); final TraceAggregationComposite aggregation = new TraceAggregationComposite(); - final CollectorSink<KiekerMetadataRecord> metadataCollector = new CollectorSink<>(this.metadataRecords); - final OperationCallHandlerComposite operationCallHandler = new OperationCallHandlerComposite(this.operationCalls, this.aggregatedOperationCalls); this.allowedRecordsFilter = new AllowedRecordsFilter(); this.beginEndOfMonitoringDetector = new BeginEndOfMonitoringDetector(); @@ -66,9 +55,7 @@ public class TraceAnalysisConfiguration extends Configuration { super.connectPorts(typeFilter.getOutputPortForType(IMonitoringRecord.class), this.beginEndOfMonitoringDetector.getInputPort()); super.connectPorts(this.beginEndOfMonitoringDetector.getOutputPort(), this.reconstruction.getInputPort()); super.connectPorts(this.reconstruction.getOutputPort(), distributor.getInputPort()); - super.connectPorts(distributor.getNewOutputPort(), operationCallHandler.getInputPort()); super.connectPorts(distributor.getNewOutputPort(), aggregation.getInputPort()); - super.connectPorts(typeFilter.getOutputPortForType(KiekerMetadataRecord.class), metadataCollector.getInputPort()); // Graph Creation // TODO move to own composite(s) @@ -98,10 +85,10 @@ public class TraceAnalysisConfiguration extends Configuration { super.connectPorts(graphDistributor2.getNewOutputPort(), graphMLFileWriterComposite2.getInputPort()); super.connectPorts(graphDistributor2.getNewOutputPort(), dotTraceGraphFileWriterStage2.getInputPort()); - DependencyCreatorStage dependencyCreatorStage = new DependencyCreatorStage(); - DependencyStatisticsDecoratorStage dependencyStatisticsDecoratorStage = new DependencyStatisticsDecoratorStage(); - super.connectPorts(aggregatedTraceDistributor.getNewOutputPort(), dependencyCreatorStage.getInputPort()); - super.connectPorts(dependencyCreatorStage.getOutputPort(), dependencyStatisticsDecoratorStage.getInputPort()); + // DependencyCreatorStage dependencyCreatorStage = new DependencyCreatorStage(); + // DependencyStatisticsDecoratorStage dependencyStatisticsDecoratorStage = new DependencyStatisticsDecoratorStage(); + // super.connectPorts(aggregatedTraceDistributor.getNewOutputPort(), dependencyCreatorStage.getInputPort()); + // super.connectPorts(dependencyCreatorStage.getOutputPort(), dependencyStatisticsDecoratorStage.getInputPort()); /* * @@ -110,36 +97,4 @@ public class TraceAnalysisConfiguration extends Configuration { } - public long getBeginTimestamp() { - return this.beginEndOfMonitoringDetector.getBeginTimestamp(); - } - - public long getEndTimestamp() { - return this.beginEndOfMonitoringDetector.getEndTimestamp(); - } - - public int countIncompleteTraces() { - return this.reconstruction.countIncompleteTraces(); - } - - public int countDanglingEvents() { - return this.reconstruction.countDanglingRecords(); - } - - public int countIgnoredRecords() { - return this.allowedRecordsFilter.getIgnoredRecords(); - } - - public List<KiekerMetadataRecord> getMetadataRecords() { - return this.metadataRecords; - } - - public List<OperationCall> getOperationCalls() { - return this.operationCalls; - } - - public List<AggregatedOperationCall> getAggregatedOperationCalls() { - return this.aggregatedOperationCalls; - } - }