diff --git a/tools.descartes.dql.connector.kieker.examples/JPetStore/JPetStore.properties b/tools.descartes.dql.connector.kieker.examples/JPetStore/JPetStore.properties index 13f37c5c5d0bfdd4cc633608e00dd2098503065c..63b86ab9908f5672543593aa4230cff4dd25500c 100644 --- a/tools.descartes.dql.connector.kieker.examples/JPetStore/JPetStore.properties +++ b/tools.descartes.dql.connector.kieker.examples/JPetStore/JPetStore.properties @@ -1,2 +1 @@ -kieker.log.directory=traceFiles -kieker.log.hostname=KIEKER-DEMO-SRV \ No newline at end of file +kieker.log.directory=traceFiles \ No newline at end of file diff --git a/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/KiekerManager.java b/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/KiekerManager.java index 4c2f7873cbab26837a9755930a2dd730da1e949a..25952d1442186bf8f2ebd4e3af6bf865048b4e8e 100644 --- a/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/KiekerManager.java +++ b/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/KiekerManager.java @@ -90,8 +90,10 @@ public class KiekerManager { } } this.traceFileHostName= (String) prop.get(KiekerHelper.KIEKER_LOG_HOSTNAME); - if (this.traceFileHostName == ""){ - this.traceFileHostName = KiekerHelper.getHostName(); + if (this.traceFileHostName == null){ + // no special hostname for filtering, accept all + this.traceFileHostName = ""; + //this.traceFileHostName = KiekerHelper.getHostName(); } log("TraceFiles found under "+traceFileOutputPath); startAnalysis(); @@ -191,8 +193,8 @@ public class KiekerManager { log("Starting analysis..."); try{ Configuration analysisConfiguration = KiekerHelper.createAnalysisConfig(request, traceFileOutputPath,traceFileHostName); - - KiekerAnalysisController c = new KiekerAnalysisController(analysisConfiguration); + boolean ignoreHost = this.traceFileHostName.equals(""); + KiekerAnalysisController c = new KiekerAnalysisController(analysisConfiguration,ignoreHost); c.fillTrace(); this.analysisResult = c.getTrace(); this.analysisResult.sortChronological(); diff --git a/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/filter/KiekerAnalysisController.java b/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/filter/KiekerAnalysisController.java index 801012b5f4ce5a6a9ea53abe9d15cd0be99717af..4a055481853cb480f2b3ee7b32dd93a57ede9e75 100644 --- a/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/filter/KiekerAnalysisController.java +++ b/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/filter/KiekerAnalysisController.java @@ -12,9 +12,11 @@ public class KiekerAnalysisController { private final Configuration config; public static final String CONFIG_LOG4J_FILE_PATH = "LOG4J_FILE_PATH"; private Trace trace; + private boolean ignoreHost = false; - public KiekerAnalysisController(Configuration config) { + public KiekerAnalysisController(Configuration config, boolean ignoreHost) { this.config=config; + this.ignoreHost = ignoreHost; } public KiekerAnalysisController(String configFilePath) { @@ -73,7 +75,7 @@ public class KiekerAnalysisController { t = new KiekerTraceLoader(t) .loadKiekerTraceFromDirectories(traceDirectories.toArray(new String[traceDirectories.size()])); - this.trace = t.initializeMaps(); + this.trace = t.initializeMaps(ignoreHost); } diff --git a/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/structures/Trace.java b/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/structures/Trace.java index 3312a295fb24d725b016e07dfbf8d22b20701f68..c7b40488e708b55c9d828f29f8087bda9b487f07 100644 --- a/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/structures/Trace.java +++ b/tools.descartes.dql.connector.kieker/src/tools/descartes/dql/connector/kieker/structures/Trace.java @@ -35,6 +35,7 @@ public class Trace { } } + //preset identifiers connected to Components/Resources (Components/Resources initialized via name only) private Map<ComponentIdentifier, Component> componentIdentifierToComponentMap; //must be preset private Map<ResourceIdentifier, Resource> resourceIdentifierToResourceMap; //must be preset @@ -103,16 +104,22 @@ public class Trace { resources.add(event); } - public Trace initializeMaps() { + public Trace initializeMaps(boolean ignoreHost) { idToRequestMap = new HashMap<String, Request>(); componentToTraceMap = new HashMap<Component, Trace>(); resourceToTraceMap = new HashMap<Resource, Trace>(); for (EventRecord event : events) { + if (ignoreHost){ + event.getIdentifier().setHostID(""); + } if (addToComponentMap(event)) { addToRequestMap(event); } } for (ResourceRecord resource : resources) { + if (ignoreHost){ + resource.getIdentifier().setHostID(""); + } addToResourceMap(resource); } return this;