git-svn-id: https://se1.informatik.uni-wuerzburg.de/usvn/svn/code/code/DMM/trunk@13072 9e42b895-fcda-4063-8a3b-11be15eb1bbd

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/IPerformanceDataRepositoryHandler.java

+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();
+}

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryHandler.java

+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;
+    }
+}

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryHelper.java

+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;
+    }
+}

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/ObservationRepositoryModelLoader.java

+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);
+        }
+    }
+
+}

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerfDataRepoConverter.java

+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;
+    }
+
+}

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryHandler.java

+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++);
+    }
+
+}

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryHandlerFactory.java

+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;
+    }
+}

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/repository/perfdatarepo/PerformanceDataRepositoryModelLoader.java

+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);
+    }
+
+}