Changeset 241 for xssim/branches/tpiontek/src/example/energy

Timestamp:

04/11/12 16:30:38 (13 years ago)

Author:

piontek

Message:

 

Location:

xssim/branches/tpiontek/src/example/energy

Files:

• CPUEnergyEstimationPlugin.java (modified) (2 diffs)
• ComputingNodeEnergyEstimationPlugin.java (modified) (3 diffs)

xssim/branches/tpiontek/src/example/energy/CPUEnergyEstimationPlugin.java

@@ -1 +1 @@
 package example.energy;
 
+import gssim.schedframe.scheduling.ExecTaskInterface;
+
+import java.util.List;
 import java.util.Properties;
 
@@ -16 +19 @@
                         ComputingResource resource) {
                 Processor cpu = (Processor)resource;
+                
                 if(resource.getPowerInterface().getPowerState() == PowerState.OFF)
                         return 0;
+                
+                double factor = 1.3;
+                
                 if(resource.getStatus() == ResourceStatus.BUSY)
-                        return cpu.getPowerInterface().getPState().getPower();
+                {
+                        List<ExecTaskInterface> tasks = jobRegistry.getRunningTasks();
+                        int type = Integer.parseInt( tasks.get(0).getJobId());
+                        
+                        switch( type % 4)
+                        {
+                                default: factor = 1.3; 
+                        }
+                        
+                        return cpu.getPowerInterface().getPState().getPower() * factor;
+                }       
                 else 
-                        return 1; 
+                        return cpu.getPowerInterface().getPState().getPower(); 
         }
 

xssim/branches/tpiontek/src/example/energy/ComputingNodeEnergyEstimationPlugin.java

@@ -5 +5 @@
 import test.rewolucja.energy.EnergyEvent;
 import test.rewolucja.resources.physical.base.ComputingResource;
+import test.rewolucja.resources.physical.implementation.ComputingNode;
 import test.rewolucja.resources.physical.implementation.Processor;
-import test.rewolucja.resources.physical.implementation.ComputingNode;
 import test.rewolucja.scheduling.JobRegistryInterface;
 
@@ -16 +16 @@
                 double power = 0;
                 ComputingNode node = (ComputingNode) resource;
+                
+                if( node.getCategory().getName().equals("A"))
+                        power = 240;
+                else if( node.getCategory().getName().equals("B"))
+                        power = 95;
+                else
+                {
+                        System.err.println("Unknown Model: "  +node.getCategory().getName());
+                        System.exit(1);
+                }       
+                
+                
+                
                 for(Processor cpu: node.getProcessors()){
                         //try{
@@ -23 +36 @@
                         //}
                 }
-                power += node.getPowerInterface().getPowerConsumption(node.getPowerInterface().getPowerState());
+                //power += node.getPowerInterface().getPowerConsumption(node.getPowerInterface().getPowerState());
                 return power;
         }