Skip to content
Snippets Groups Projects
Commit 449f20ef authored by Sören Henning's avatar Sören Henning
Browse files

seperate logic and stage

parent 12128353
No related branches found
No related tags found
1 merge request!19Trace aggr analysis
Hide whitespace changes
Inline Side-by-side
src/main/java/kieker/analysis/dev/dependencygraphs/DeploymentDependencyGraphCreator.java 0 → 100644
+ 141
− 0
View file @ 449f20ef
package kieker.analysis.dev.dependencygraphs;
import java.util.Collection;
import java.util.EnumSet;
import java.util.Set;
import kieker.analysis.domain.systemdependency.Component;
import kieker.analysis.domain.systemdependency.Container;
import kieker.analysis.domain.systemdependency.Dependency;
import kieker.analysis.domain.systemdependency.Operation;
import kieker.analysis.domain.systemdependency.SoftwareSystem;
import kieker.analysis.util.graph.Edge;
import kieker.analysis.util.graph.Graph;
import kieker.analysis.util.graph.Vertex;
import kieker.analysis.util.graph.impl.GraphImpl;
public class DeploymentDependencyGraphCreator {
private final DeploymentDependencyGraphLevel depth;
private final Set<DeploymentDependencyGraphLevel> relations;
public DeploymentDependencyGraphCreator(final DeploymentDependencyGraphLevel depth) {
this.depth = depth;
this.relations = EnumSet.of(depth);
}
public DeploymentDependencyGraphCreator(final DeploymentDependencyGraphLevel depth, final Collection<DeploymentDependencyGraphLevel> relations) {
this.depth = depth;
this.relations = EnumSet.copyOf(relations);
}
public Graph create(final SoftwareSystem softwareSystem) {
Graph graph = new GraphImpl();
graph.setName("OperationsDependencyGraph"); // TODO
for (Container container : softwareSystem.getContainers()) {
Vertex containerVertex = graph.addVertex(container.getIdentifier());
containerVertex.setProperty("Name", container.getName());
containerVertex.setProperty("Type", "Container");
containerVertex.setProperty("MaxDuration", container.getMaxDuration());
containerVertex.setProperty("MinDuration", container.getMinDuration());
containerVertex.setProperty("MeanDuration", container.getMeanDuration());
containerVertex.setProperty("MedianDuration", container.getMedianDuration());
containerVertex.setProperty("TotalDuration", container.getTotalDuration());
Graph componentGraph = containerVertex.addChildGraph();
if (this.depth.compareTo(DeploymentDependencyGraphLevel.COMPONENT) <= 0) {
for (Component component : container.getComponents()) {
Vertex componentVertex = componentGraph.addVertex(component.getIdentifier());
componentVertex.setProperty("Name", component.getName());
componentVertex.setProperty("Type", "Component");
componentVertex.setProperty("MaxDuration", component.getMaxDuration());
componentVertex.setProperty("MinDuration", component.getMinDuration());
componentVertex.setProperty("MeanDuration", component.getMeanDuration());
componentVertex.setProperty("MedianDuration", component.getMedianDuration());
componentVertex.setProperty("TotalDuration", component.getTotalDuration());
Graph operationsGraph = componentVertex.addChildGraph();
if (this.depth.compareTo(DeploymentDependencyGraphLevel.OPERATION) <= 0) {
for (Operation operation : component.getOperations()) {
Vertex operationVertex = operationsGraph.addVertex(operation.getIdentifier());
operationVertex.setProperty("Name", operation.getName());
operationVertex.setProperty("Type", "Operation");
operationVertex.setProperty("MaxDuration", operation.getMaxDuration());
operationVertex.setProperty("MinDuration", operation.getMinDuration());
operationVertex.setProperty("MeanDuration", operation.getMeanDuration());
operationVertex.setProperty("MedianDuration", operation.getMedianDuration());
operationVertex.setProperty("TotalDuration", operation.getTotalDuration());
}
}
}
}
}
if (this.relations.contains(DeploymentDependencyGraphLevel.CONTAINER)) {
for (Dependency<Container> dependency : softwareSystem.getContainerDependencies()) {
String callerContainerIdentifier = dependency.getCaller().getIdentifier();
String calleeContainerIdentifier = dependency.getCallee().getIdentifier();
Vertex callerVertex = graph.getVertex(callerContainerIdentifier);
Vertex calleeVertex = graph.getVertex(calleeContainerIdentifier);
Edge dependencyEdge = graph.addEdge(null, callerVertex, calleeVertex);
dependencyEdge.setProperty("calls", dependency.getCalls());
dependencyEdge.setProperty("failuredCalls", dependency.getFailuredCalls());
}
}
if (this.relations.contains(DeploymentDependencyGraphLevel.COMPONENT)) {
for (Dependency<Component> dependency : softwareSystem.getComponentDependencies()) {
String callerContainerIdentifier = dependency.getCaller().getContainer().getIdentifier();
String callerComponentIdentifier = dependency.getCaller().getIdentifier();
String calleeContainerIdentifier = dependency.getCallee().getContainer().getIdentifier();
String calleeComponentIdentifier = dependency.getCallee().getIdentifier();
Vertex callerVertex = graph.getVertex(callerContainerIdentifier).getChildGraph().getVertex(callerComponentIdentifier);
Vertex calleeVertex = graph.getVertex(calleeContainerIdentifier).getChildGraph().getVertex(calleeComponentIdentifier);
Edge dependencyEdge = graph.addEdge(null, callerVertex, calleeVertex);
dependencyEdge.setProperty("calls", dependency.getCalls());
dependencyEdge.setProperty("failuredCalls", dependency.getFailuredCalls());
}
}
if (this.relations.contains(DeploymentDependencyGraphLevel.OPERATION)) {
for (Dependency<Operation> dependency : softwareSystem.getOperationDependencies()) {
String callerContainerIdentifier = dependency.getCaller().getComponent().getContainer().getIdentifier();
String callerComponentIdentifier = dependency.getCaller().getComponent().getIdentifier();
String callerOperationIdentifier = dependency.getCaller().getIdentifier();
String calleeContainerIdentifier = dependency.getCallee().getComponent().getContainer().getIdentifier();
String calleeComponentIdentifier = dependency.getCallee().getComponent().getIdentifier();
String calleeOperationIdentifier = dependency.getCallee().getIdentifier();
Vertex callerVertex = graph.getVertex(callerContainerIdentifier).getChildGraph().getVertex(callerComponentIdentifier).getChildGraph()
.getVertex(callerOperationIdentifier);
Vertex calleeVertex = graph.getVertex(calleeContainerIdentifier).getChildGraph().getVertex(calleeComponentIdentifier).getChildGraph()
.getVertex(calleeOperationIdentifier);
Edge dependencyEdge = graph.addEdge(null, callerVertex, calleeVertex);
dependencyEdge.setProperty("calls", dependency.getCalls());
dependencyEdge.setProperty("failuredCalls", dependency.getFailuredCalls());
}
}
return graph;
}
}
src/main/java/kieker/analysis/dev/dependencygraphs/DeploymentDependencyGraphLevel.java 0 → 100644
+ 7
− 0
View file @ 449f20ef
package kieker.analysis.dev.dependencygraphs;
public enum DeploymentDependencyGraphLevel {
OPERATION, COMPONENT, CONTAINER;
}
src/main/java/kieker/analysis/dev/dependencygraphs/OperationsDependencyGraphCreatorStage.java
+ 7
− 101
View file @ 449f20ef
package kieker.analysis.dev.dependencygraphs;
import kieker.analysis.domain.systemdependency.Component;
import kieker.analysis.domain.systemdependency.Container;
import kieker.analysis.domain.systemdependency.Dependency;
import kieker.analysis.domain.systemdependency.Operation;
import kieker.analysis.domain.systemdependency.SoftwareSystem;
import kieker.analysis.util.graph.Edge;
import kieker.analysis.util.graph.Graph;
import kieker.analysis.util.graph.Vertex;
import kieker.analysis.util.graph.impl.GraphImpl;
import teetime.stage.basic.AbstractTransformation;
public class OperationsDependencyGraphCreatorStage extends AbstractTransformation<SoftwareSystem, Graph> {
@Override
protected void execute(final SoftwareSystem softwareSystem) {
Graph graph = new GraphImpl();
for (Container container : softwareSystem.getContainers()) {
Vertex containerVertex = graph.addVertex(container.getIdentifier());
containerVertex.setProperty("Name", container.getName());
containerVertex.setProperty("Type", "Container");
containerVertex.setProperty("MaxDuration", container.getMaxDuration());
containerVertex.setProperty("MinDuration", container.getMinDuration());
containerVertex.setProperty("MeanDuration", container.getMeanDuration());
containerVertex.setProperty("MedianDuration", container.getMedianDuration());
containerVertex.setProperty("TotalDuration", container.getTotalDuration());
Graph componentGraph = containerVertex.addChildGraph();
for (Component component : container.getComponents()) {
Vertex componentVertex = componentGraph.addVertex(component.getIdentifier());
componentVertex.setProperty("Name", component.getName());
componentVertex.setProperty("Type", "Component");
componentVertex.setProperty("MaxDuration", component.getMaxDuration());
componentVertex.setProperty("MinDuration", component.getMinDuration());
componentVertex.setProperty("MeanDuration", component.getMeanDuration());
componentVertex.setProperty("MedianDuration", component.getMedianDuration());
componentVertex.setProperty("TotalDuration", component.getTotalDuration());
Graph operationsGraph = componentVertex.addChildGraph();
for (Operation operation : component.getOperations()) {
Vertex operationVertex = operationsGraph.addVertex(operation.getIdentifier());
operationVertex.setProperty("Name", operation.getName());
operationVertex.setProperty("Type", "Operation");
operationVertex.setProperty("MaxDuration", operation.getMaxDuration());
operationVertex.setProperty("MinDuration", operation.getMinDuration());
operationVertex.setProperty("MeanDuration", operation.getMeanDuration());
operationVertex.setProperty("MedianDuration", operation.getMedianDuration());
operationVertex.setProperty("TotalDuration", operation.getTotalDuration());
}
}
}
private final DeploymentDependencyGraphCreator graphCreator;
/*
* for (Dependency<Container> dependency : softwareSystem.getContainerDependencies()) {
*
* String callerContainerIdentifier = dependency.getCaller().getIdentifier();
* String calleeContainerIdentifier = dependency.getCallee().getIdentifier();
*
* Vertex callerVertex = graph.getVertex(callerContainerIdentifier);
* Vertex calleeVertex = graph.getVertex(calleeContainerIdentifier);
*
* Edge dependencyEdge = graph.addEdge(null, callerVertex, calleeVertex);
* dependencyEdge.setProperty("calls", dependency.getCalls());
* dependencyEdge.setProperty("failuredCalls", dependency.getFailuredCalls());
* }
*
* for (Dependency<Component> dependency : softwareSystem.getComponentDependencies()) {
*
* String callerContainerIdentifier = dependency.getCaller().getContainer().getIdentifier();
* String callerComponentIdentifier = dependency.getCaller().getIdentifier();
*
* String calleeContainerIdentifier = dependency.getCallee().getContainer().getIdentifier();
* String calleeComponentIdentifier = dependency.getCallee().getIdentifier();
*
* Vertex callerVertex = graph.getVertex(callerContainerIdentifier).getChildGraph().getVertex(callerComponentIdentifier);
* Vertex calleeVertex = graph.getVertex(calleeContainerIdentifier).getChildGraph().getVertex(calleeComponentIdentifier);
*
* Edge dependencyEdge = graph.addEdge(null, callerVertex, calleeVertex);
* dependencyEdge.setProperty("calls", dependency.getCalls());
* dependencyEdge.setProperty("failuredCalls", dependency.getFailuredCalls());
* }
*/
for (Dependency<Operation> dependency : softwareSystem.getOperationDependencies()) {
String callerContainerIdentifier = dependency.getCaller().getComponent().getContainer().getIdentifier();
String callerComponentIdentifier = dependency.getCaller().getComponent().getIdentifier();
String callerOperationIdentifier = dependency.getCaller().getIdentifier();
String calleeContainerIdentifier = dependency.getCallee().getComponent().getContainer().getIdentifier();
String calleeComponentIdentifier = dependency.getCallee().getComponent().getIdentifier();
String calleeOperationIdentifier = dependency.getCallee().getIdentifier();
Vertex callerVertex = graph.getVertex(callerContainerIdentifier).getChildGraph().getVertex(callerComponentIdentifier).getChildGraph()
.getVertex(callerOperationIdentifier);
Vertex calleeVertex = graph.getVertex(calleeContainerIdentifier).getChildGraph().getVertex(calleeComponentIdentifier).getChildGraph()
.getVertex(calleeOperationIdentifier);
Edge dependencyEdge = graph.addEdge(null, callerVertex, calleeVertex);
dependencyEdge.setProperty("calls", dependency.getCalls());
dependencyEdge.setProperty("failuredCalls", dependency.getFailuredCalls());
}
public OperationsDependencyGraphCreatorStage() {
this.graphCreator = new DeploymentDependencyGraphCreator(DeploymentDependencyGraphLevel.OPERATION);
}
@Override
protected void execute(final SoftwareSystem softwareSystem) {
final Graph graph = graphCreator.create(softwareSystem);
this.outputPort.send(graph);
}
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment