diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/IPerformanceDataRepositoryHandler.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/IPerformanceDataRepositoryHandler.java deleted file mode 100644 index 0732aef2288fb1ffbb80b7cfec79e4ebf9040599..0000000000000000000000000000000000000000 --- a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/IPerformanceDataRepositoryHandler.java +++ /dev/null @@ -1,15 +0,0 @@ -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/perfdatarepo/ObservationRepositoryHandler.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/ObservationRepositoryHandler.java deleted file mode 100644 index a3a8824a3776ea6df2887c1d6d7c9e8f61a81ef6..0000000000000000000000000000000000000000 --- a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/ObservationRepositoryHandler.java +++ /dev/null @@ -1,65 +0,0 @@ -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; - } -} diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/ObservationRepositoryHelper.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/ObservationRepositoryHelper.java deleted file mode 100644 index f81f7def7969228fa928be298fe99fbeded7eb10..0000000000000000000000000000000000000000 --- a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/ObservationRepositoryHelper.java +++ /dev/null @@ -1,52 +0,0 @@ -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/perfdatarepo/ObservationRepositoryModelLoader.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/ObservationRepositoryModelLoader.java deleted file mode 100644 index 7f711f7a076642f779ac846a9360d32df9bd4115..0000000000000000000000000000000000000000 --- a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/ObservationRepositoryModelLoader.java +++ /dev/null @@ -1,45 +0,0 @@ -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); - } - } - -} diff --git a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerfDataRepoConverter.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerfDataRepoConverter.java deleted file mode 100644 index a348d5d7306764ea3c0072bbc1ddd13f3c294ed7..0000000000000000000000000000000000000000 --- a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerfDataRepoConverter.java +++ /dev/null @@ -1,79 +0,0 @@ -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/perfdatarepo/PerformanceDataRepositoryHandler.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerformanceDataRepositoryHandler.java deleted file mode 100644 index 4e6d972d95782a09da1be44386d0ec701df7c93b..0000000000000000000000000000000000000000 --- a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerformanceDataRepositoryHandler.java +++ /dev/null @@ -1,55 +0,0 @@ -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/perfdatarepo/PerformanceDataRepositoryHandlerFactory.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerformanceDataRepositoryHandlerFactory.java deleted file mode 100644 index 2bbcd7dcc5ff0be33d56b8bd96b064aeab693891..0000000000000000000000000000000000000000 --- a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerformanceDataRepositoryHandlerFactory.java +++ /dev/null @@ -1,18 +0,0 @@ -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/perfdatarepo/PerformanceDataRepositoryModelLoader.java b/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerformanceDataRepositoryModelLoader.java deleted file mode 100644 index eff23365487f70b6e2690c29a88daf0dcbf44bc1..0000000000000000000000000000000000000000 --- a/edu.kit.ipd.descartes.adaptation/src/edu/kit/ipd/descartes/adaptation/model/perfdatarepo/PerformanceDataRepositoryModelLoader.java +++ /dev/null @@ -1,51 +0,0 @@ -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); - } - -}