Changeset 883 for DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_LocalPlugin.java

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/localplugin/FCFSBF_LocalPlugin.java (modified) (3 diffs)

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) {