diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/IPerformanceDataRepositoryHandler.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/IPerformanceDataRepositoryHandler.java
new file mode 100644
index 0000000000000000000000000000000000000000..0732aef2288fb1ffbb80b7cfec79e4ebf9040599
--- /dev/null
+++ b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/IPerformanceDataRepositoryHandler.java
@@ -0,0 +1,15 @@
+package edu.kit.ipd.descartes.adaptation.model.perfdatarepo;
+
+import edu.kit.ipd.descartes.mm.adaptation.WeightedTactic;
+import edu.kit.ipd.descartes.perfdatarepo.Impact;
+import edu.kit.ipd.descartes.perfdatarepo.Result;
+
+public interface IPerformanceDataRepositoryHandler {
+
+ public void load(String modelFileUri);
+
+ public Impact getLatestImpact();
+ public Impact getLatestImpact(WeightedTactic tactic);
+
+ public Result getCurrentSystemState();
+}
diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryHandler.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryHandler.java
new file mode 100644
index 0000000000000000000000000000000000000000..02e85323bcf024eb6701e94269380af0937203dc
--- /dev/null
+++ b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryHandler.java
@@ -0,0 +1,65 @@
+package edu.kit.ipd.descartes.adaptation.model.perfdatarepo;
+
+import static edu.kit.ipd.descartes.adaptation.model.perfdatarepo.PerfDataRepoConverter.convertObservableImpact;
+
+import org.apache.log4j.Logger;
+import org.eclipse.emf.common.util.URI;
+
+import edu.kit.ipd.descartes.adaptation.TacticsHistory;
+import edu.kit.ipd.descartes.adaptation.modelrepository.AbstractEcoreModelLoader;
+import edu.kit.ipd.descartes.adaptation.modelrepository.AdaptationProcessModelLoader;
+import edu.kit.ipd.descartes.adaptation.util.BlueYonderExperimentTracker;
+import edu.kit.ipd.descartes.mm.adaptation.WeightedTactic;
+import edu.kit.ipd.descartes.perfdatarepo.Impact;
+import edu.kit.ipd.descartes.perfdatarepo.Result;
+import edu.kit.ipd.descartes.ql.models.repository.Observation;
+import edu.kit.ipd.descartes.ql.models.repository.ObservationRepository;
+
+public class ObservationRepositoryHandler implements IPerformanceDataRepositoryHandler {
+
+ private BlueYonderExperimentTracker tracker = BlueYonderExperimentTracker.getInstance();
+ private static Logger logger = Logger.getLogger(ObservationRepositoryHandler.class);
+ private AbstractEcoreModelLoader modelLoader = null;
+ private ObservationRepository repository = null;
+
+ public ObservationRepositoryHandler() {
+ modelLoader = ObservationRepositoryModelLoader.getInstance();
+ logger.debug("ObservationRepositoryHandler loaded.");
+ }
+
+ @Override
+ public Impact getLatestImpact() {
+ return convertObservableImpact(repository.getLatestImpact());
+ }
+
+ @Override
+ public void load(String modelFileUri) {
+ repository = (ObservationRepository) modelLoader.load(URI.createFileURI(modelFileUri));
+ }
+
+ @Override
+ public Result getCurrentSystemState() {
+ WeightedTactic latestTactic = TacticsHistory.getInstance().getLatestAppliedTactic();
+ Observation o = null;
+
+ if (latestTactic == null) {
+ o = repository.getLatestObservation();
+ } else {
+ // TODO: Blue Yonder specific, introduce abstraction layer
+ String expName = tracker.getExperimentNameForDistributedDataCenter(AdaptationProcessModelLoader.getDistributedDataCenter());
+ logger.debug("Searching for result of " + expName);
+ o = ObservationRepositoryHelper.getResultEndingWith(expName, repository);
+ }
+
+ return PerfDataRepoConverter.convertResult(o);
+ }
+
+ @Override
+ public Impact getLatestImpact(WeightedTactic tactic) {
+ String expName = tracker.getExperimentNameForDistributedDataCenter(AdaptationProcessModelLoader.getDistributedDataCenter());
+ logger.debug("Searching for impact of " + expName);
+ Impact latestImpact = PerfDataRepoConverter.convertObservableImpact(ObservationRepositoryHelper
+ .searchImpactOfTactic(expName, repository));
+ return latestImpact;
+ }
+}
diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryHelper.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryHelper.java
new file mode 100644
index 0000000000000000000000000000000000000000..f81f7def7969228fa928be298fe99fbeded7eb10
--- /dev/null
+++ b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryHelper.java
@@ -0,0 +1,52 @@
+package edu.kit.ipd.descartes.adaptation.model.perfdatarepo;
+
+import java.util.List;
+
+import org.eclipse.emf.ecore.util.EcoreUtil;
+
+import edu.kit.ipd.descartes.ql.models.repository.ObservableImpact;
+import edu.kit.ipd.descartes.ql.models.repository.Observation;
+import edu.kit.ipd.descartes.ql.models.repository.ObservationRepository;
+
+public class ObservationRepositoryHelper {
+
+ public static ObservableImpact searchImpactOfTactic(String name, ObservationRepository repository) {
+ // Get correct result
+ Observation o = getResultEndingWith(name, repository);
+
+ // Derive impact from result
+ ObservableImpact i = getImpactForObservation(o, repository);
+ return i;
+ }
+
+ public static ObservableImpact getImpactForObservation(Observation o, ObservationRepository repo) {
+ if (o == null || repo == null)
+ return null;
+
+ List<ObservableImpact> impacts = repo.getImpacts();
+ for (ObservableImpact oi : impacts) {
+ if (EcoreUtil.equals(oi.getAfter(), o))
+ return oi;
+ }
+
+ return null;
+ }
+
+ /**
+ * Searches the observation repository for an observation that ends with the given suffix.
+ *
+ * @param suffix
+ * @return first result that ends the given suffix, null otherwise.
+ */
+ public static Observation getResultEndingWith(String suffix, ObservationRepository repo) {
+ if (suffix == null || repo == null)
+ return null;
+
+ List<Observation> results = repo.getObservations();
+ for (Observation o : results) {
+ if (o.getIdentifier().endsWith(suffix))
+ return o;
+ }
+ return null;
+ }
+}
diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryModelLoader.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryModelLoader.java
new file mode 100644
index 0000000000000000000000000000000000000000..48986fc0cc3d1845c67587569a45e8a851dcc9fb
--- /dev/null
+++ b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryModelLoader.java
@@ -0,0 +1,45 @@
+package edu.kit.ipd.descartes.adaptation.model.perfdatarepo;
+
+import org.eclipse.emf.ecore.EPackage;
+import org.eclipse.emf.ecore.resource.Resource;
+import org.eclipse.emf.ecore.resource.ResourceSet;
+import org.eclipse.emf.ecore.resource.impl.ResourceSetImpl;
+import org.eclipse.emf.ecore.xmi.impl.XMIResourceFactoryImpl;
+
+import edu.kit.ipd.descartes.adaptation.modelrepository.AbstractEcoreModelLoader;
+import edu.kit.ipd.descartes.ql.models.repository.RepositoryPackage;
+
+public class ObservationRepositoryModelLoader extends AbstractEcoreModelLoader {
+
+ public static final EPackage[] OBSERVATION_REPO_EPACKAGES = new EPackage[] {
+ RepositoryPackage.eINSTANCE
+ };
+
+ private static ObservationRepositoryModelLoader instance = null;
+
+ public static ObservationRepositoryModelLoader getInstance() {
+ if (instance == null) {
+ instance = new ObservationRepositoryModelLoader();
+ }
+ return instance;
+ }
+
+ private ObservationRepositoryModelLoader() {
+ initializeResourceSet(new ResourceSetImpl());
+ }
+
+ @Override
+ public void initializeResourceSet(ResourceSet resourceSet) {
+ setResourceSet(resourceSet);
+
+ /* Register the default resource factory -- only needed for stand-alone! */
+ getResourceSet().getResourceFactoryRegistry().getExtensionToFactoryMap()
+ .put(Resource.Factory.Registry.DEFAULT_EXTENSION, new XMIResourceFactoryImpl());
+
+ /* Register also the packages needed for the DMM meta model */
+ for (EPackage ePackage : OBSERVATION_REPO_EPACKAGES) {
+ getResourceSet().getResourceFactoryRegistry().getExtensionToFactoryMap().put(ePackage.getNsURI(), ePackage);
+ }
+ }
+
+}
diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerfDataRepoConverter.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerfDataRepoConverter.java
new file mode 100644
index 0000000000000000000000000000000000000000..a348d5d7306764ea3c0072bbc1ddd13f3c294ed7
--- /dev/null
+++ b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerfDataRepoConverter.java
@@ -0,0 +1,79 @@
+package edu.kit.ipd.descartes.adaptation.model.perfdatarepo;
+
+import java.util.ArrayList;
+import java.util.Collection;
+
+import edu.kit.ipd.descartes.perfdatarepo.Impact;
+import edu.kit.ipd.descartes.perfdatarepo.MeasuredEntity;
+import edu.kit.ipd.descartes.perfdatarepo.MetricType;
+import edu.kit.ipd.descartes.perfdatarepo.MetricValue;
+import edu.kit.ipd.descartes.perfdatarepo.PerfdatarepoFactory;
+import edu.kit.ipd.descartes.perfdatarepo.Result;
+import edu.kit.ipd.descartes.ql.models.mapping.domain.DecimalResult;
+import edu.kit.ipd.descartes.ql.models.mapping.domain.Entity;
+import edu.kit.ipd.descartes.ql.models.mapping.domain.Probe;
+import edu.kit.ipd.descartes.ql.models.mapping.domain.Resource;
+import edu.kit.ipd.descartes.ql.models.mapping.domain.Service;
+import edu.kit.ipd.descartes.ql.models.mapping.mapping.EntityMapping;
+import edu.kit.ipd.descartes.ql.models.repository.ObservableImpact;
+import edu.kit.ipd.descartes.ql.models.repository.Observation;
+
+public class PerfDataRepoConverter {
+
+ public static Impact convertObservableImpact(ObservableImpact o) {
+ if (o == null)
+ return null;
+ Impact impact = PerfdatarepoFactory.eINSTANCE.createImpact();
+ impact.setId(o.getIdentifier());
+ impact.setName("ObservableImpact (ID: " + o.getIdentifier() + ")");
+ impact.setBefore(convertResult(o.getBefore()));
+ impact.setAfter(convertResult(o.getAfter()));
+ return impact;
+ }
+
+ public static Result convertResult(Observation o) {
+ Result result = PerfdatarepoFactory.eINSTANCE.createResult();
+ result.setId(o.getIdentifier());
+ result.setName("Observation (ID: " + o.getIdentifier() + ")");
+ Collection<MetricValue> values = convertMapping(o.getObservation());
+ result.getMetricValues().addAll(values);
+ return result;
+ }
+
+ public static Collection<MetricValue> convertMapping(EntityMapping observation) {
+ Collection<MetricValue> values = new ArrayList<MetricValue>();
+
+ for (Resource r : observation.getResources()) {
+ values.addAll(convertProbes(r));
+ }
+
+ for (Service s : observation.getServices()) {
+ values.addAll(convertProbes(s));
+ }
+
+ return values;
+ }
+
+ private static Collection<MetricValue> convertProbes(Entity e) {
+ Collection<MetricValue> values = new ArrayList<MetricValue>();
+ MetricType mType = PerfdatarepoFactory.eINSTANCE.createMetricType();
+ mType.setName(e.getProbes().get(0).getMetricName());
+ mType.setId(e.getProbes().get(0).getMetricName());
+ MeasuredEntity entity = PerfdatarepoFactory.eINSTANCE.createMeasuredEntity();
+ entity.setName(e.getAlias());
+ entity.setId(e.getIdentifier());
+
+ for (Probe p : e.getProbes()) {
+ DecimalResult r = (DecimalResult) p;
+ MetricValue value = PerfdatarepoFactory.eINSTANCE.createMetricValue();
+ value.setMeasuredEntity(entity);
+ value.setName(e.getAlias() + ": " + r.getMetricName());
+ value.setMetricType(mType);
+ value.setValue(r.getValue().doubleValue());
+ values.add(value);
+ }
+
+ return values;
+ }
+
+}
diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryHandler.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryHandler.java
new file mode 100644
index 0000000000000000000000000000000000000000..4e6d972d95782a09da1be44386d0ec701df7c93b
--- /dev/null
+++ b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryHandler.java
@@ -0,0 +1,55 @@
+package edu.kit.ipd.descartes.adaptation.model.perfdatarepo;
+
+import org.apache.log4j.Logger;
+import org.eclipse.emf.common.util.EList;
+import org.eclipse.emf.common.util.URI;
+
+import edu.kit.ipd.descartes.mm.adaptation.WeightedTactic;
+import edu.kit.ipd.descartes.perfdatarepo.Impact;
+import edu.kit.ipd.descartes.perfdatarepo.PerformanceDataRepository;
+import edu.kit.ipd.descartes.perfdatarepo.Result;
+
+public class PerformanceDataRepositoryHandler implements IPerformanceDataRepositoryHandler {
+
+ private static Logger logger = Logger.getLogger(PerformanceDataRepositoryHandler.class);
+
+ private int iteration = 0;
+
+ private PerformanceDataRepository repository = null;
+ private PerformanceDataRepositoryModelLoader modelLoader = null;
+
+ public PerformanceDataRepositoryHandler() {
+ modelLoader = PerformanceDataRepositoryModelLoader.getInstance();
+ logger.debug("PerformanceDataRepositoryHandler instantiated.");
+ }
+
+ public void load(String fileUri) {
+ repository = modelLoader.load(URI.createFileURI(fileUri));
+ }
+
+ @Override
+ public Impact getLatestImpact() {
+ EList<Impact> impactHistory = repository.getImpactHistory();
+ Impact mostRecentImpact = impactHistory.get(impactHistory.size() - 1);
+
+ for (Impact currentImpact : impactHistory) {
+ Result afterResult = currentImpact.getAfter();
+ if (afterResult.getTimestamp().compareTo(mostRecentImpact.getAfter().getTimestamp()) > 0 )
+ mostRecentImpact = currentImpact;
+ }
+
+ return mostRecentImpact;
+ }
+
+ @Override
+ public Impact getLatestImpact(WeightedTactic tactic) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ @Override
+ public Result getCurrentSystemState() {
+ return repository.getResultHistory().get(iteration++);
+ }
+
+}
diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryHandlerFactory.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryHandlerFactory.java
new file mode 100644
index 0000000000000000000000000000000000000000..2bbcd7dcc5ff0be33d56b8bd96b064aeab693891
--- /dev/null
+++ b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryHandlerFactory.java
@@ -0,0 +1,18 @@
+package edu.kit.ipd.descartes.adaptation.model.perfdatarepo;
+
+import edu.kit.ipd.descartes.perfdatarepo.PerformanceDataRepository;
+import edu.kit.ipd.descartes.ql.models.repository.ObservationRepository;
+
+public class PerformanceDataRepositoryHandlerFactory {
+
+ public static IPerformanceDataRepositoryHandler createHandler(String repositoryType) {
+
+ if (repositoryType.equals(PerformanceDataRepository.class.getName()))
+ return new PerformanceDataRepositoryHandler();
+
+ if (repositoryType.equals(ObservationRepository.class.getName()))
+ return new ObservationRepositoryHandler();
+
+ return null;
+ }
+}
diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryModelLoader.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryModelLoader.java
new file mode 100644
index 0000000000000000000000000000000000000000..0a14f7050054dd7c315c23737c0b75b2c7ac89b2
--- /dev/null
+++ b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryModelLoader.java
@@ -0,0 +1,51 @@
+package edu.kit.ipd.descartes.adaptation.model.perfdatarepo;
+
+import org.eclipse.emf.common.util.URI;
+import org.eclipse.emf.ecore.EPackage;
+import org.eclipse.emf.ecore.resource.Resource;
+import org.eclipse.emf.ecore.resource.ResourceSet;
+import org.eclipse.emf.ecore.resource.impl.ResourceSetImpl;
+import org.eclipse.emf.ecore.xmi.impl.XMIResourceFactoryImpl;
+
+import edu.kit.ipd.descartes.adaptation.modelrepository.AbstractEcoreModelLoader;
+import edu.kit.ipd.descartes.perfdatarepo.PerfdatarepoPackage;
+import edu.kit.ipd.descartes.perfdatarepo.PerformanceDataRepository;
+
+public class PerformanceDataRepositoryModelLoader extends AbstractEcoreModelLoader {
+
+ public static final EPackage[] PERF_DATA_REPO_EPACKAGES = new EPackage[] { PerfdatarepoPackage.eINSTANCE };
+
+ private static PerformanceDataRepositoryModelLoader instance = null;
+
+ public static PerformanceDataRepositoryModelLoader getInstance() {
+ if (instance == null) {
+ instance = new PerformanceDataRepositoryModelLoader();
+ }
+ return instance;
+ }
+
+
+ private PerformanceDataRepositoryModelLoader() {
+ initializeResourceSet(new ResourceSetImpl());
+ }
+
+ @Override
+ public void initializeResourceSet(ResourceSet resourceSet) {
+ setResourceSet(resourceSet);
+ /* Register the default resource factory -- only needed for stand-alone! */
+ getResourceSet().getResourceFactoryRegistry().getExtensionToFactoryMap()
+ .put(Resource.Factory.Registry.DEFAULT_EXTENSION, new XMIResourceFactoryImpl());
+
+ /* Register also the packages needed for the DMM meta model */
+ for (EPackage ePackage : PERF_DATA_REPO_EPACKAGES) {
+ getResourceSet().getResourceFactoryRegistry().getExtensionToFactoryMap().put(ePackage.getNsURI(), ePackage);
+ }
+
+ }
+
+ @Override
+ public PerformanceDataRepository load(URI uri) {
+ return (PerformanceDataRepository) super.load(uri);
+ }
+
+}