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

edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/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/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.model.repository.AbstractEcoreModelLoader;
-import edu.kit.ipd.descartes.adaptation.model.repository.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/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/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.model.repository.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/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/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/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/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.model.repository.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);
-    }
-
-}