Skip to content
Snippets Groups Projects
Commit 91242cf8 authored by erbel's avatar erbel
Browse files

Adjusted Output

parent 470dd541
No related branches found
No related tags found
1 merge request!5Dev/live
Pipeline #88136 passed
...@@ -79,29 +79,16 @@ public class DownScaler extends AbsScaler { ...@@ -79,29 +79,16 @@ public class DownScaler extends AbsScaler {
} }
for(Link link: linksToDelete) { for(Link link: linksToDelete) {
System.out.println("Deleting: " + link);
System.out.println(link);
EcoreUtil.delete(link); EcoreUtil.delete(link);
} }
System.out.println(config.getResources());
System.out.println("");
config.getResources().removeAll(resourcesToDelete); config.getResources().removeAll(resourcesToDelete);
for(org.eclipse.cmf.occi.core.Resource res: resourcesToDelete) { for(org.eclipse.cmf.occi.core.Resource res: resourcesToDelete) {
System.out.println(res);
EcoreUtil.delete(res); EcoreUtil.delete(res);
} }
Resource rM = runtimeModel; Resource rM = runtimeModel;
System.out.println(rM); MAPE.newComp = null;
System.out.println("");
System.out.println(config.getResources());
CachedResourceSet.getCache().clear(); CachedResourceSet.getCache().clear();
return rM; return rM;
...@@ -126,7 +113,6 @@ public class DownScaler extends AbsScaler { ...@@ -126,7 +113,6 @@ public class DownScaler extends AbsScaler {
for(Link link: comp.getRlinks()) { for(Link link: comp.getRlinks()) {
if(link.getSource() instanceof Component) { if(link.getSource() instanceof Component) {
System.out.println(link);
resourcesToDelete.add(link.getSource()); resourcesToDelete.add(link.getSource());
linksToDelete.addAll(link.getSource().getLinks()); linksToDelete.addAll(link.getSource().getLinks());
linksToDelete.addAll(link.getSource().getRlinks()); linksToDelete.addAll(link.getSource().getRlinks());
...@@ -137,17 +123,13 @@ public class DownScaler extends AbsScaler { ...@@ -137,17 +123,13 @@ public class DownScaler extends AbsScaler {
} }
for(Link link: comp.getLinks()) { for(Link link: comp.getLinks()) {
System.out.println(link);
if(link instanceof Networkinterface) { if(link instanceof Networkinterface) {
Networkinterface nwi = (Networkinterface) link; Networkinterface nwi = (Networkinterface) link;
System.out.println(nwi.getAttributes());
for(MixinBase mixB: nwi.getParts()) { for(MixinBase mixB: nwi.getParts()) {
if(mixB instanceof Ipnetworkinterface) { if(mixB instanceof Ipnetworkinterface) {
System.out.println(mixB);
Ipnetworkinterface ipnwi = (Ipnetworkinterface) mixB; Ipnetworkinterface ipnwi = (Ipnetworkinterface) mixB;
if(ipnwi.getOcciNetworkinterfaceAddress().startsWith("100.254.1")) { if(ipnwi.getOcciNetworkinterfaceAddress().startsWith("100.254.1")) {
interfaces.add(ipnwi.getOcciNetworkinterfaceAddress()); interfaces.add(ipnwi.getOcciNetworkinterfaceAddress());
System.out.println("Addin ip to interface list");
} }
} }
} }
......
...@@ -48,7 +48,6 @@ public class InitialDeployment { ...@@ -48,7 +48,6 @@ public class InitialDeployment {
System.out.println("Initial Deployment"); System.out.println("Initial Deployment");
Path occiPath = getModelPath("de/ugoe/cs/rwm/mocci/occi/hadoopClusterNewExtWithMem.occic"); Path occiPath = getModelPath("de/ugoe/cs/rwm/mocci/occi/hadoopClusterNewExtWithMem.occic");
Resource model = ModelUtility.loadOCCIintoEMFResource(occiPath); Resource model = ModelUtility.loadOCCIintoEMFResource(occiPath);
System.out.println(model.getResourceSet().getResources());
Transformator trans = TransformatorFactory.getTransformator("OCCI2OCCI"); Transformator trans = TransformatorFactory.getTransformator("OCCI2OCCI");
trans.transform(model, occiPath); trans.transform(model, occiPath);
......
...@@ -66,10 +66,10 @@ public class UpScaler extends AbsScaler { ...@@ -66,10 +66,10 @@ public class UpScaler extends AbsScaler {
Compute comp = iFactory.createCompute(); Compute comp = iFactory.createCompute();
comp.setOcciComputeState(ComputeStatus.ACTIVE); comp.setOcciComputeState(ComputeStatus.ACTIVE);
AttributeState attr = factory.createAttributeState(); AttributeState state = factory.createAttributeState();
attr.setName("occi.compute.state"); state.setName("occi.compute.state");
attr.setValue("active"); state.setValue("active");
comp.getAttributes().add(attr); comp.getAttributes().add(state);
config.getResources().add(comp); config.getResources().add(comp);
Ubuntu_xenialxerus mixOs = osFactory.createUbuntu_xenialxerus(); Ubuntu_xenialxerus mixOs = osFactory.createUbuntu_xenialxerus();
...@@ -83,16 +83,16 @@ public class UpScaler extends AbsScaler { ...@@ -83,16 +83,16 @@ public class UpScaler extends AbsScaler {
mixB.setOcciNetworkinterfaceAddress(ip); mixB.setOcciNetworkinterfaceAddress(ip);
nwi.getParts().add(mixB); nwi.getParts().add(mixB);
AttributeState ipAttr = factory.createAttributeState(); AttributeState ipAttr = factory.createAttributeState();
attr.setName("occi.networkinterface.address"); ipAttr.setName("occi.networkinterface.address");
attr.setValue(ip); ipAttr.setValue(ip);
nwi.getAttributes().add(attr); nwi.getAttributes().add(ipAttr);
String ipadjusted = ip.replace(".", "-"); String ipadjusted = ip.replace(".", "-");
comp.setTitle("hadoop-worker-additional-" + ipadjusted); comp.setTitle("hadoop-worker-additional-" + ipadjusted);
AttributeState hostname = factory.createAttributeState(); AttributeState hostname = factory.createAttributeState();
attr.setName("occi.compute.hostname"); hostname.setName("occi.compute.hostname");
attr.setValue("hadoop-worker-additional-" + ipadjusted); hostname.setValue("hadoop-worker-additional-" + ipadjusted);
comp.getAttributes().add(hostname); comp.getAttributes().add(hostname);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment