From aeebc88e3be26243c79dea706850226e1ed80908 Mon Sep 17 00:00:00 2001
From: Nils Christian Ehmke <nie@informatik.uni-kiel.de>
Date: Thu, 18 Dec 2014 15:45:27 +0100
Subject: [PATCH] Modified code for the TeeTime API changes
---
.../model/importer/ImportAnalysisConfiguration.java | 11 +++--------
src/main/java/kieker/gui/mainview/View.java | 2 --
2 files changed, 3 insertions(+), 10 deletions(-)
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 35f0a668..f99f6015 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 9e4ba0a2..204f90c2 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();
--
GitLab