Changeset 192 for xssim/trunk/src/example/localplugin/FCFSConsolidationClusterLocalPlugin.java

Timestamp:

03/26/12 12:03:27 (13 years ago)

Author:

wojtekp

Message:

 

File:

• xssim/trunk/src/example/localplugin/FCFSConsolidationClusterLocalPlugin.java (modified) (5 diffs)

xssim/trunk/src/example/localplugin/FCFSConsolidationClusterLocalPlugin.java

@@ -2 +2 @@
 
 import gridsim.Gridlet;
-import gridsim.gssim.ResourceHistoryItem;
-import gridsim.gssim.SubmittedTask;
 
 import java.util.ArrayList;
@@ -17 +15 @@
 import schedframe.scheduling.TaskInterface;
 import schedframe.scheduling.events.SchedulingEvent;
-import schedframe.scheduling.events.TaskFinishedEvent;
 import schedframe.scheduling.plugin.grid.ModuleList;
 import schedframe.scheduling.utils.ResourceParameterName;
 import test.rewolucja.GSSIMJobInterface;
-import test.rewolucja.energy.profile.PStateType;
 import test.rewolucja.resources.ProcessingElements;
 import test.rewolucja.resources.ResourceStatus;
-import test.rewolucja.resources.ResourceType;
 import test.rewolucja.resources.manager.implementation.ClusterResourceManager;
 import test.rewolucja.resources.manager.interfaces.ResourceManagerInterface;
 import test.rewolucja.resources.physical.base.ComputingResource;
-import test.rewolucja.resources.physical.implementation.CPU;
 import test.rewolucja.resources.physical.implementation.ComputingNode;
 import test.rewolucja.scheduling.JobRegistryInterface;
@@ -52 +46 @@
                 case TASK_FINISHED:
                         // our tasks are placed only in first queue (see
-                        // BaseLocalPlugin.placeTasksInQueues() method)
+                        // BaseLocalPlugin.placeJobsInQueues() method)
                         Queue q = queues.get(0);
                         // check all tasks in queue
@@ -111 +105 @@
                         }
                         if (memoryRequest != 0) {
-                                Memory memory = new Memory(node.getMemory(), memoryRequest, memoryRequest);
+                                Memory memory = new Memory(node.getMemoryUnit(), memoryRequest, memoryRequest);
                                 map.put(ResourceParameterName.MEMORY, memory);
                         }
@@ -132 +126 @@
                         memoryRequest = 0;
                 }
-                List<ComputingNode> avNodes = new ArrayList<ComputingNode>();
+                List<ComputingNode> suitableNodes = new ArrayList<ComputingNode>();
                 for(ComputingNode node: nodes){
                         if(node.getFreeProcessorsNumber() >= cpuRequest && node.getFreeMemory() >= memoryRequest){
-                                avNodes.add(node);
+                                suitableNodes.add(node);
                         }
                 }
-                return avNodes;
+                return suitableNodes;
         }