diff --git a/src/main/java/kieker/gui/common/model/importer/ImportAnalysisConfiguration.java b/src/main/java/kieker/gui/common/model/importer/ImportAnalysisConfiguration.java index 35f0a6686975ae5b7ad0ceae0ef118ba6b01bb97..f99f60151288785cc7b563bf4075c2e911582f6c 100644 --- a/src/main/java/kieker/gui/common/model/importer/ImportAnalysisConfiguration.java +++ b/src/main/java/kieker/gui/common/model/importer/ImportAnalysisConfiguration.java @@ -66,11 +66,11 @@ public final class ImportAnalysisConfiguration extends AnalysisConfiguration { final InitialElementProducer<File> producer = new InitialElementProducer<>(importDirectory); final Dir2RecordsFilter reader = new Dir2RecordsFilter(new ClassNameRegistryRepository()); final MultipleInstanceOfFilter<IMonitoringRecord> typeFilter = new MultipleInstanceOfFilter<>(); - final Distributor<IFlowRecord> fstDistributor = new Distributor<>(); + final Distributor<IFlowRecord> fstDistributor = new Distributor<>(new CopyByReferenceStrategy()); final RecordSimplificator recordSimplificator = new RecordSimplificator(); final CollectorSink<Record> recordCollector = new CollectorSink<>(this.recordsList); final TraceReconstructor traceReconstructor = new TraceReconstructor(); - final Distributor<Execution> sndDistributor = new Distributor<>(); + final Distributor<Execution> sndDistributor = new Distributor<>(new CopyByReferenceStrategy()); final CollectorSink<Execution> traceCollector = new CollectorSink<>(this.tracesList); final FailedTraceFilter failedTraceFilter = new FailedTraceFilter(); final CollectorSink<Execution> failedTraceCollector = new CollectorSink<>(this.failedTracesList); @@ -80,16 +80,11 @@ public final class ImportAnalysisConfiguration extends AnalysisConfiguration { final CollectorSink<AggregatedExecution> aggregatedTraceCollector = new CollectorSink<>(this.aggregatedTraces); final CollectorSink<KiekerMetadataRecord> metadataCollector = new CollectorSink<>(this.metadataRecords); final FailedAggregatedTraceFilter failedAggregatedTraceFilter = new FailedAggregatedTraceFilter(); - final Distributor<AggregatedExecution> thrdDistributor = new Distributor<>(); + final Distributor<AggregatedExecution> thrdDistributor = new Distributor<>(new CopyByReferenceStrategy()); final CollectorSink<AggregatedExecution> failedAggregatedTraceCollector = new CollectorSink<>(this.failedAggregatedTracesList); final FailureContainingAggregatedTraceFilter failureContainingAggregatedTraceFilter = new FailureContainingAggregatedTraceFilter(); final CollectorSink<AggregatedExecution> failureContainingAggregatedTraceCollector = new CollectorSink<>(this.failureContainingAggregatedTracesList); - // Configure the stages - fstDistributor.setStrategy(new CopyByReferenceStrategy<IFlowRecord>()); - sndDistributor.setStrategy(new CopyByReferenceStrategy<Execution>()); - thrdDistributor.setStrategy(new CopyByReferenceStrategy<AggregatedExecution>()); - // Connect the stages final IPipeFactory pipeFactory = AnalysisConfiguration.PIPE_FACTORY_REGISTRY.getPipeFactory(ThreadCommunication.INTRA, PipeOrdering.ARBITRARY, false); pipeFactory.create(producer.getOutputPort(), reader.getInputPort()); diff --git a/src/main/java/kieker/gui/mainview/View.java b/src/main/java/kieker/gui/mainview/View.java index 9e4ba0a2efc3c2ba603d5c82809d179a51c9705a..204f90c28aca963153378670ff3feed001631846 100644 --- a/src/main/java/kieker/gui/mainview/View.java +++ b/src/main/java/kieker/gui/mainview/View.java @@ -87,8 +87,6 @@ public final class View implements Observer { this.shell.open(); this.shell.layout(); - this.dataModel.loadMonitoringLogFromFS("example/kieker-20141217-134719867-UTC-SE-Nils-Ehmke-KIEKER"); - while (!this.shell.isDisposed()) { if (!display.readAndDispatch()) { display.sleep();