Changeset 1299 for DCWoRMS/branches/coolemall/src/example/load

Timestamp:

03/19/14 18:22:27 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/example/load/ProcessorLoadEstimationPlugin.java (modified) (3 diffs)

DCWoRMS/branches/coolemall/src/example/load/ProcessorLoadEstimationPlugin.java

@@ -1 +1 @@
 package example.load;
 
-import schedframe.resources.ResourceStatus;
-import schedframe.resources.computing.Core;
 import schedframe.resources.computing.Processor;
 import schedframe.resources.computing.profiles.energy.EnergyEvent;
@@ -13 +11 @@
 public class ProcessorLoadEstimationPlugin extends BaseLoadEstimationPlugin{
 
-        @Override
         public double estimateUtlization(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) {
                 Processor proc = (Processor) resource;
@@ -24 +21 @@
                 }
 
-                //for(Core core: proc.getCores()){
-                        
-                        //if(core.getStatus().equals(ResourceStatus.BUSY)){
-                                JobRegistry jr = new JobRegistryImpl(proc.getFullName());
-                                for(ExecTask task: jr.getRunningTasks()){
-                                        double cpuUsage = 1 / nrOfThreadsOnCpu;
-                                        double nrOfThreadsOfApplication = 1;
 
-                                        for(PhaseBehaviour pb: task.getCurrentResourceConsumption().getBehaviourList()){
-                                                if(pb.getResouceName().equals("PM_CPU_Usage")){
-                                                        cpuUsage = pb.getUtilization();
-                                                }
-                                                if(pb.getResouceName().equals("PM_Threads")){
-                                                        nrOfThreadsOfApplication = pb.getUtilization();
-                                                        break;
-                                                }
-                                        }
-                                        sumCoresLoad = sumCoresLoad + cpuUsage;// * (nrOfThreadsOfApplication / nrOfThreadsOnCpu);
+                JobRegistry jr = new JobRegistryImpl(proc.getFullName());
+                for(ExecTask task: jr.getRunningTasks()){
+                        double cpuUsage = 1 / nrOfThreadsOnCpu;
 
+                        for(PhaseBehaviour pb: task.getCurrentResourceConsumption().getBehaviourList()){
+                                if(pb.getResouceName().equals("PM_CPU_Usage")){
+                                        cpuUsage = pb.getUtilization();
                                 }
-                //      }
-                //}
+                        }
+                        sumCoresLoad = sumCoresLoad + cpuUsage;
+
+                }
+
 
                 double processorLoad = 100 * sumCoresLoad;