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

Timestamp:

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

Author:

wojtekp

Message:

 

File:

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

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

@@ -47 +47 @@
         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) {
@@ -52 +56 @@
                 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.
@@ -138 +179 @@
                                 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;
 
@@ -179 +255 @@
                 private TaskInterface<?> task;
                 
-                double Q = ThermalConstants.Q;
-                double C = ThermalConstants.C;
-                double delta1 = ThermalConstants.delta1;
-                double delta2 = ThermalConstants.delta2;
-                double ro = ThermalConstants.ro;
-                
                 public TemperatureComparator(TaskInterface<?> task){
                         this.task = task;
@@ -190 +260 @@
                 
             public int compare(Node node1, Node node2){    
-                double currentNode1Temp = node1.getThermalInterface().getRecentTemperature().getValue();
-                double currentNode2Temp = node2.getThermalInterface().getRecentTemperature().getValue();
+                
+                int id1 = Integer.parseInt(node1.getName().split("_")[1]);
+                int id2 = Integer.parseInt(node2.getName().split("_")[1]);
+                
+                double currentNode1Temp = virtualNodes.get(id1).getTemperature();
+                double currentNode2Temp = virtualNodes.get(id2).getTemperature();
                 
                 double power1 = 0;
@@ -208 +282 @@
                 }
                 
-                Integer id1 = Integer.parseInt(node1.getName().split("_")[1]);
-                Integer id2 = Integer.parseInt(node2.getName().split("_")[1]);
-                
                 double deltaOne = 1, deltaTwo = 1;
-                if (id1 >= 0 && id1 <= 8) // outlet
-                        deltaOne = delta2;
-                else if (id1 >= 9 && id1 <= 17) // inlet
-                        deltaOne = delta1;
-                if (id2 >= 0 && id2 <= 8) // outlet
-                        deltaTwo = delta2;
-                else if (id2 >= 9 && id2 <= 17) // inlet
-                        deltaTwo = delta1;
-                
-                double afterNode1Temp = currentNode1Temp + deltaOne * (power1/(Q * C * ro));
-                double afterNode2Temp = currentNode2Temp + deltaTwo * (power2/(Q * C * ro));
+                if (id1 >= 1 && id1 <= 9) // outlet
+                        deltaOne = ThermalConstants.delta2;
+                else if (id1 >= 10 && id1 <= 18) // inlet
+                        deltaOne = ThermalConstants.delta1;
+                if (id2 >= 1 && id2 <= 9) // outlet
+                        deltaTwo = ThermalConstants.delta2;
+                else if (id2 >= 10 && id2 <= 18) // inlet
+                        deltaTwo = ThermalConstants.delta1;
+                
+                double afterNode1Temp = currentNode1Temp + deltaOne * (power1/(ThermalConstants.Q * ThermalConstants.C * ThermalConstants.ro));
+                double afterNode2Temp = currentNode2Temp + deltaTwo * (power2/(ThermalConstants.Q * ThermalConstants.C * ThermalConstants.ro));
                 
                 if (afterNode1Temp > afterNode2Temp)