Changeset 883 for DCWoRMS/branches/coolemall/src/example

Timestamp:

02/26/13 08:41:50 (12 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall

Files:

• . (copied) (copied from DCWoRMS/trunk)
• src/example/energy/CPUEnergyEstimationPlugin.java (modified) (1 diff)
• src/example/energy/recs/ProcessorEnergyEstimationPlugin.java (modified) (3 diffs)
• src/example/localplugin/FCFSBF_LocalPlugin.java (modified) (3 diffs)
• src/example/localplugin/coolemall/recs/RECS_Consolidation_SP.java (added)

DCWoRMS/branches/coolemall/src/example/energy/CPUEnergyEstimationPlugin.java

@@ -17 +17 @@
                         powerConsumption = 0;
                 else {
-                        try {
-                                if(resource.getStatus() == ResourceStatus.BUSY)
+                        if(resource.getStatus() == ResourceStatus.BUSY){
+                                try {
+
                                         powerConsumption = cpu.getPowerInterface().getPowerConsumption(cpu.getPowerInterface().getPState());
-                                else {
-                                        powerConsumption = cpu.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON);
+                                } catch (NoSuchFieldException e) {
+                                        try {
+                                                powerConsumption = cpu.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON);
+                                        } catch (NoSuchFieldException e1) {
+                                                powerConsumption = 10;
+                                        }
                                 }
-                        } catch (NoSuchFieldException e) {
+                        } else{
                                 try {
-                                        powerConsumption = cpu.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON);
-                                } catch (NoSuchFieldException e1) {
-                                        powerConsumption = 10;
+                                        powerConsumption = cpu.getPowerInterface().getPowerConsumption(cpu.getPowerInterface().getPState());
+                                } catch (NoSuchFieldException e) {
+                                        try {
+                                                powerConsumption = cpu.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON);
+                                        } catch (NoSuchFieldException e1) {
+                                                powerConsumption = 0;
+                                        }
                                 }
                         }
+                        
                 }
                 return powerConsumption;

DCWoRMS/branches/coolemall/src/example/energy/recs/ProcessorEnergyEstimationPlugin.java

@@ -6 +6 @@
 import schedframe.resources.computing.Processor;
 import schedframe.resources.computing.profiles.energy.EnergyEvent;
+import schedframe.resources.computing.profiles.energy.EnergyEventType;
 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName;
 import schedframe.scheduling.manager.tasks.JobRegistry;
@@ -20 +21 @@
                         try {
                                 if(resource.getStatus() == ResourceStatus.BUSY)
-                                        powerConsumption = cpu.getPowerInterface().getPowerConsumption(cpu.getPowerInterface().getPState());
+                                        powerConsumption = 60;
+                                        //powerConsumption = cpu.getPowerInterface().getPowerConsumption(cpu.getPowerInterface().getPState());
                                 else {
-                                        powerConsumption = cpu.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON);
+                                        powerConsumption = 10;
+                                        //powerConsumption = cpu.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON);
                                 }
-                        } catch (NoSuchFieldException e) {
+                        } catch (Exception e) {
                                 try {
                                         powerConsumption = cpu.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON);
@@ -32 +35 @@
                         }
                 }
+                if(event.getType() == EnergyEventType.RESOURCE_UTILIZATION_CHANGED)
+                        powerConsumption = powerConsumption/2;
                 return powerConsumption;
         }

DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_LocalPlugin.java

@@ -2 +2 @@
 
 import gridsim.dcworms.DCWormsTags;
+import schedframe.events.scheduling.EventReason;
 import schedframe.events.scheduling.SchedulingEvent;
+import schedframe.resources.computing.profiles.energy.EnergyEvent;
+import schedframe.resources.computing.profiles.energy.EnergyEventType;
 import schedframe.scheduling.manager.resources.ResourceManager;
 import schedframe.scheduling.manager.tasks.JobRegistry;
@@ -10 +13 @@
 import schedframe.scheduling.queue.TaskQueueList;
 import schedframe.scheduling.tasks.TaskInterface;
+import simulator.DataCenterWorkloadSimulator;
+import test.EventManager;
 
 public class FCFSBF_LocalPlugin extends BaseLocalSchedulingPlugin {
@@ -28 +33 @@
                         for (int i = 0; i < q.size(); i++) {
                                 TaskInterface<?> task = q.get(i);
-                                
+                                //EventManager em = DataCenterWorkloadSimulator.getEventManager();
+                                //EnergyEvent energyEvent = new EnergyEvent(EnergyEventType.AIRFLOW_STATE_CHANGED, "Resource controller");
+                                //energyEvent.setReason(EventReason.SIM_INIT);
+                                //em.sendToAllResources(40000, energyEvent);
+                                //em.sendToAllSchedulers(40000, DCWormsTags.UPDATE_PROCESSING, new String("test"));
                                 // if status of the tasks in READY
                                 if (task.getStatus() == DCWormsTags.READY) {