Changeset 1312 for DCWoRMS/branches/coolemall/src/test/thermal/recs/plugins/scheduling/RecsExclusivenessCoolestSP.java

Timestamp:

03/21/14 15:43:32 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/test/thermal/recs/plugins/scheduling/RecsExclusivenessCoolestSP.java (modified) (6 diffs)

DCWoRMS/branches/coolemall/src/test/thermal/recs/plugins/scheduling/RecsExclusivenessCoolestSP.java

@@ -30 +30 @@
 import schedframe.scheduling.manager.resources.ResourceManager;
 import schedframe.scheduling.manager.tasks.JobRegistry;
+import schedframe.scheduling.manager.tasks.JobRegistryImpl;
 import schedframe.scheduling.plan.SchedulingPlanInterface;
 import schedframe.scheduling.plan.impl.SchedulingPlan;
@@ -36 +37 @@
 import schedframe.scheduling.queue.TaskQueueList;
 import schedframe.scheduling.tasks.TaskInterface;
+import test.thermal.recs.plugins.energy.ThermalConstants;
 import test.thermal.recs.utils.AppType;
 
@@ -46 +48 @@
         private ResourceBundle timeBundle;
         
+        // virtual nodes are to keep track of the intermediate power and temperature between job assignments 
+        private List<VirtualNode> virtualNodes = new ArrayList<VirtualNode>();
+        private boolean firstCall = true;
+        
         public SchedulingPlanInterface<?> schedule(SchedulingEvent event, TaskQueueList queues, JobRegistry jobRegistry,
                         ResourceManager resManager, ModuleList modules) {
-
+                
                 ClusterResourceManager resourceManager = (ClusterResourceManager) resManager;
                 SchedulingPlan plan = new SchedulingPlan();
+                
+                List<Node> nodes = resourceManager.getNodes();
+                
+                // create the virtualNodes on the first scheduling call
+                if (firstCall){
+                        
+                        VirtualNode dummyVN = new VirtualNode(0);
+                        virtualNodes.add(dummyVN);
+                        
+                        int numNodes = nodes.size();
+                        for (int i = 1; i <= numNodes; i++){
+                                VirtualNode vn = new VirtualNode(i);
+                                virtualNodes.add(vn);
+                        }
+                        firstCall = false;
+                }
+                
+                // update the power of the virtual nodes
+                for (Node node : nodes){
+                        double power = node.getPowerInterface().getRecentPowerUsage().getValue();
+                        int nodeId = Integer.parseInt(node.getName().split("_")[1]);
+                        virtualNodes.get(nodeId).setPower(power);
+                }
+                
+                // update the temperature of the virtual nodes
+                for (int i = 1; i <= 9; i++){
+                        VirtualNode vn1 = virtualNodes.get(i+9);
+                        VirtualNode vn2 = virtualNodes.get(i);
+                        
+                        double power1 = vn1.getPower();
+                        double power2 = vn2.getPower();
+                        
+                        double tout = ThermalConstants.calculateOutletTemp(power1, power2);
+                        vn1.setTemperature(tout);
+                        vn2.setTemperature(tout);
+                }
+                
                 // choose the events types to serve.
                 // Different actions for different events are possible.
@@ -87 +130 @@
                 Collections.shuffle(nodes);
                 Collections.sort(nodes, new TemperatureComparator(task));
-                
+                /*
+                System.out.println("*************************");
+                System.out.println("Assigning task " + task.getJobId());
+                for (Node node : nodes) {
+                        int nodeId = Integer.parseInt(node.getName().split("_")[1]);
+                        double node_power = node.getPowerInterface().getRecentPowerUsage().getValue();
+                        double node_temp = node.getThermalInterface().getRecentTemperature().getValue();
+                        double vn_power = virtualNodes.get(nodeId).getPower();
+                        double vn_temp = virtualNodes.get(nodeId).getTemperature();
+                        System.out.println(node.getName() + ": node_power = " + node_power + " ; node_temp = " + node_temp + " ; vn_power = " + vn_power + " ; vn_temp = " + vn_temp);
+                }
+                System.out.println("*************************");
+                */
                 for (Node node : nodes) {
                         int cpuRequest;
@@ -138 +193 @@
                                 pe.addAll(choosenResources);
                                 map.put(StandardResourceUnitName.PE, pe);
+                                
+                                // update the power and temperature of the virtualNode corresponding to the node
+                                int nodeId = Integer.parseInt(node.getName().split("_")[1]);
+                                VirtualNode vn = virtualNodes.get(nodeId);
+                                
+                                // power update
+                                double extraPower = 0;
+                        try{
+                                extraPower = Math.abs(getMeasuredPower(createQuery(task, node)) - node.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON));
+                            } catch (FileNotFoundException e) {
+                
+                                } catch (IOException e) {
+                
+                                } catch (MissingResourceException e){
+                                        
+                        } catch (NoSuchFieldException e) {
+
+                        }
+                        vn.setPower(vn.getPower() + extraPower);
+                        
+                                // temperature update
+                        double delta = 1;
+                        VirtualNode vn2;
+                        if (nodeId >= 1 && nodeId <= 9){
+                                delta = ThermalConstants.delta2;
+                                vn2 = virtualNodes.get(nodeId + 9);
+                        }
+                        else{
+                                delta = ThermalConstants.delta1;
+                                vn2 = virtualNodes.get(nodeId - 9);
+                        }
+                        double extraTemp = delta * (extraPower/(ThermalConstants.Q * ThermalConstants.C * ThermalConstants.ro));
+                        vn.setTemperature(vn.getTemperature() + extraTemp);
+                        vn2.setTemperature(vn2.getTemperature() + extraTemp);
+                        
                                 return map;
-
                         }
                 }
@@ -183 +272 @@
                 }
                 
-            public int compare(Node node1, Node node2){    
-                double node1Temp = node1.getThermalInterface().getRecentTemperature().getValue();
-                double node2Temp = node2.getThermalInterface().getRecentTemperature().getValue();
+            public int compare(Node node1, Node node2){   
+                
+                int id1 = Integer.parseInt(node1.getName().split("_")[1]);
+                int id2 = Integer.parseInt(node2.getName().split("_")[1]);
+                
+                double node1Temp = virtualNodes.get(id1).getTemperature();
+                double node2Temp = virtualNodes.get(id2).getTemperature();
                 
                 if (node1Temp > node2Temp)