- Timestamp:
- 11/28/13 10:54:54 (11 years ago)
- Location:
- DCWoRMS/branches/coolemall/src/schedframe/resources/computing
- Files:
-
- 2 deleted
- 8 edited
- 3 moved
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/Core.java
r1207 r1247 28 28 } 29 29 30 public ComputingNode getNode(){30 public Node getNode(){ 31 31 ComputingResource compRes = parent; 32 32 while(compRes != null && !compRes.getType().equals(StandardResourceType.Node)){ 33 33 compRes = compRes.getParent(); 34 34 } 35 ComputingNode compNode = null;35 Node compNode = null; 36 36 try{ 37 compNode = ( ComputingNode)compRes;37 compNode = (Node)compRes; 38 38 } catch(ClassCastException e) { 39 39 } -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/DataCenter.java
r1207 r1247 5 5 import schedframe.resources.StandardResourceType; 6 6 import schedframe.resources.computing.description.ComputingResourceDescription; 7 import schedframe.resources.computing.profiles.energy.EnergyExtension;8 import schedframe.resources.computing.profiles.energy.power.PowerInterfaceFactory;9 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;10 7 11 8 public class DataCenter extends ComputingResource{ … … 19 16 20 17 @SuppressWarnings("unchecked") 21 public List< ComputingNode> getComputingNodes(){22 return (List< ComputingNode>) getDescendantsByType(StandardResourceType.Node);18 public List<Node> getNodes(){ 19 return (List<Node>) getDescendantsByType(StandardResourceType.Node); 23 20 } 24 21 -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/Node.java
r1207 r1247 1 1 package schedframe.resources.computing; 2 2 3 import java.util.ArrayList; 3 4 import java.util.List; 4 5 import java.util.Properties; … … 9 10 import schedframe.resources.computing.extensions.ExtensionType; 10 11 import schedframe.resources.computing.profiles.energy.EnergyExtension; 11 import schedframe.resources.computing.profiles.energy.power.ui. ComputingNodePowerInterface;12 import schedframe.resources.computing.properties. ComputingNodePropertiesBuilder;12 import schedframe.resources.computing.profiles.energy.power.ui.NodePowerInterface; 13 import schedframe.resources.computing.properties.NodePropertiesBuilder; 13 14 import schedframe.resources.computing.properties.PropertiesDirector; 14 15 import schedframe.resources.units.Cost; … … 16 17 import schedframe.resources.units.StandardResourceUnitName; 17 18 18 public class ComputingNode extends ComputingResource{19 public class Node extends ComputingResource{ 19 20 20 21 21 public ComputingNode (ComputingResourceDescription resDesc) {22 public Node (ComputingResourceDescription resDesc) { 22 23 super(resDesc); 23 24 … … 29 30 } 30 31 31 public ComputingNodePowerInterface getPowerInterface(){32 ComputingNodePowerInterface powerInterface = null;32 public NodePowerInterface getPowerInterface(){ 33 NodePowerInterface powerInterface = null; 33 34 if(extensionList.isExtensionAvailable(ExtensionType.ENERGY_EXTENSION)){ 34 35 EnergyExtension ee = (EnergyExtension)extensionList.getExtension(ExtensionType.ENERGY_EXTENSION); 35 powerInterface = ( ComputingNodePowerInterface)ee.getPowerInterface();36 powerInterface = (NodePowerInterface)ee.getPowerInterface(); 36 37 } 37 38 return powerInterface; … … 48 49 } 49 50 51 public List<Core> getCores(){ 52 List<Core> cores = new ArrayList<Core>(); 53 for(Processor proc: getProcessors()){ 54 cores.addAll(proc.getCores()); 55 } 56 return cores; 57 } 58 59 public List<Core> getFreeCores(){ 60 List<Core> freeCores = new ArrayList<Core>(); 61 for(Processor proc: getProcessors()){ 62 freeCores.addAll(proc.getFreeCores()); 63 } 64 return freeCores; 65 } 66 50 67 public int getProcessorsNumber() { 51 68 return getProcessors().size(); … … 88 105 public Properties getProperties(){ 89 106 PropertiesDirector propDirector = new PropertiesDirector(); 90 propDirector.setPropertiesBuilder(new ComputingNodePropertiesBuilder());107 propDirector.setPropertiesBuilder(new NodePropertiesBuilder()); 91 108 propDirector.constructProperties(this); 92 109 return propDirector.getProperties(); -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/Processor.java
r1207 r1247 25 25 } 26 26 27 public ComputingNode getNode(){27 public Node getNode(){ 28 28 ComputingResource compRes = parent; 29 29 while(compRes != null && !compRes.getType().equals(StandardResourceType.Node)){ 30 30 compRes = compRes.getParent(); 31 31 } 32 ComputingNode compNode = null;32 Node compNode = null; 33 33 try{ 34 compNode = ( ComputingNode)compRes;34 compNode = (Node)compRes; 35 35 } catch(Exception e) { 36 36 } -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/Rack.java
r1207 r1247 16 16 17 17 @SuppressWarnings("unchecked") 18 public List< ComputingNode> getComputingNodes(){19 return (List< ComputingNode>) getDescendantsByType(StandardResourceType.Node);18 public List<Node> getNodes(){ 19 return (List<Node>) getDescendantsByType(StandardResourceType.Node); 20 20 } 21 21 -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/StandardResourceFactory.java
r1207 r1247 1 1 package schedframe.resources.computing; 2 2 3 import schedframe.resources.CoolEmAllResourceType;4 3 import schedframe.resources.StandardResourceType; 5 4 import schedframe.resources.computing.description.ComputingResourceDescription; … … 23 22 return new Rack(resDesc); 24 23 else if (resDesc.getType().equals(StandardResourceType.Node)) 25 return new ComputingNode(resDesc);24 return new Node(resDesc); 26 25 else if (resDesc.getType().equals(StandardResourceType.Processor)) 27 26 return new Processor(resDesc); … … 30 29 else 31 30 return new ComputingResource(resDesc); 32 33 /*switch(resDesc.getType()){ 34 case Grid: return new Grid(resDesc); 35 case DataCenter: return new DataCenter(resDesc); 36 case ComputingNode: return new ComputingNode(resDesc); 37 case Processor: return new Processor(resDesc); 38 default: 39 return new ComputingResource(resDesc); 40 }*/ 31 41 32 } 42 33 -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/coolemall/ComputeBox1.java
r1207 r1247 4 4 5 5 import schedframe.resources.CoolEmAllResourceType; 6 import schedframe.resources.StandardResourceType;7 import schedframe.resources.computing.ComputingNode;8 6 import schedframe.resources.computing.Rack; 9 7 import schedframe.resources.computing.description.ComputingResourceDescription; … … 19 17 return (List<NodeGroup>) getDescendantsByType(CoolEmAllResourceType.NodeGroup); 20 18 } 21 22 @SuppressWarnings("unchecked")23 public List<ComputingNode> getNodes(){24 return (List<ComputingNode>) getDescendantsByType(StandardResourceType.Node);25 }26 27 19 28 20 } -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/coolemall/NodeGroup.java
r1207 r1247 4 4 5 5 import schedframe.resources.StandardResourceType; 6 import schedframe.resources.computing.Node; 6 7 import schedframe.resources.computing.ComputingResource; 7 8 import schedframe.resources.computing.Processor; -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/PowerInterfaceFactory.java
r1207 r1247 18 18 powerInterface = new schedframe.resources.computing.profiles.energy.power.ui.DataCenterPowerInterface((ComputingResource)resource, pp); 19 19 else if (resource.getType().getName().equals(StandardResourceType.Node.getName())) 20 powerInterface = new schedframe.resources.computing.profiles.energy.power.ui. ComputingNodePowerInterface((ComputingResource)resource, pp);20 powerInterface = new schedframe.resources.computing.profiles.energy.power.ui.NodePowerInterface((ComputingResource)resource, pp); 21 21 else if (resource.getType().getName().equals(StandardResourceType.Processor.getName())) 22 22 powerInterface = new schedframe.resources.computing.profiles.energy.power.ui.ProcessorPowerInterface((ComputingResource)resource, pp); -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/ui/NodePowerInterface.java
r1207 r1247 3 3 4 4 5 import org.joda.time.DateTime;6 7 import schedframe.SimulatedEnvironment;8 5 import schedframe.resources.ResourceStatus; 9 import schedframe.resources.computing.ComputingNode;10 6 import schedframe.resources.computing.ComputingResource; 7 import schedframe.resources.computing.Node; 11 8 import schedframe.resources.computing.profiles.energy.EnergyEvent; 12 9 import schedframe.resources.computing.profiles.energy.EnergyEventType; … … 15 12 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 16 13 17 public class ComputingNodePowerInterface extends ComputingResourcePowerInterface{14 public class NodePowerInterface extends ComputingResourcePowerInterface{ 18 15 19 16 public static long START_TIME = 600000; … … 23 20 24 21 25 public ComputingNodePowerInterface(ComputingResource resource, PowerProfile pp){22 public NodePowerInterface(ComputingResource resource, PowerProfile pp){ 26 23 super(resource, pp); 27 24 currentPowerState = StandardPowerStateName.ON; … … 32 29 return false; 33 30 currentPowerState = state; 34 ComputingNode computingNode = (ComputingNode) resource;31 Node node = (Node) resource; 35 32 boolean pePowerStateChangeStatus = false; 36 if( computingNode.getProcessors() != null) {37 for(ComputingResource child: computingNode.getProcessors()){33 if(node.getProcessors() != null) { 34 for(ComputingResource child:node.getProcessors()){ 38 35 if(child.getPowerInterface() != null){ 39 36 pePowerStateChangeStatus = child.getPowerInterface().setPowerState(state); … … 43 40 44 41 if(!pePowerStateChangeStatus){ 45 computingNode.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, computingNode.getFullName()));42 node.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, node.getFullName())); 46 43 } 47 44 48 45 if(state == StandardPowerStateName.OFF){ 49 computingNode.setStatus(ResourceStatus.UNAVAILABLE);46 node.setStatus(ResourceStatus.UNAVAILABLE); 50 47 } 51 48 else if(state == StandardPowerStateName.ON){ 52 computingNode.setStatus(ResourceStatus.FREE);49 node.setStatus(ResourceStatus.FREE); 53 50 } 54 // computingNode.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, computingNode.getName()));51 //node.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, computingNode.getName())); 55 52 //ResourceController.traceResource(new DateTime().getMillis(), resource.getFullName(), "POWER_STATE_CHANGED", state.getName()); 56 53 return true; -
DCWoRMS/branches/coolemall/src/schedframe/resources/computing/properties/NodePropertiesBuilder.java
r1053 r1247 3 3 import java.util.Properties; 4 4 5 import schedframe.resources.computing. ComputingNode;5 import schedframe.resources.computing.Node; 6 6 import schedframe.resources.computing.ComputingResource; 7 7 8 public class ComputingNodePropertiesBuilder implements PropertiesBuilder{8 public class NodePropertiesBuilder implements PropertiesBuilder{ 9 9 protected Properties properties; 10 private ComputingNode node;10 private Node node; 11 11 12 12 public Properties getProperties() { … … 16 16 public void createProperties(ComputingResource resource) { 17 17 this.properties = new Properties(); 18 this.node = ( ComputingNode)resource;18 this.node = (Node)resource; 19 19 } 20 20
Note: See TracChangeset
for help on using the changeset viewer.