Changeset 1300 for DCWoRMS/branches

Timestamp:

03/19/14 18:23:01 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/test/EventManager.java (modified) (6 diffs)

DCWoRMS/branches/coolemall/src/test/EventManager.java

@@ -12 +12 @@
 import java.util.Properties;
 
+import schedframe.Initializable;
 import schedframe.SimulatedEnvironment;
 import schedframe.events.Event;
 import schedframe.events.ResourceEventCommand;
 import schedframe.exceptions.ModuleException;
+import schedframe.exceptions.ResourceException;
 import schedframe.resources.ResourceType;
 import schedframe.resources.computing.ComputingResource;
@@ -24 +26 @@
 public class EventManager extends GridSimCore implements Module{
 
-        protected SimulatedEnvironment resourceController;
+        protected SimulatedEnvironment simEnv;
         
         public EventManager(String name, SimulatedEnvironment resourceController) throws Exception {
                 super(name, 1);
-                this.resourceController = resourceController;
+                this.simEnv = resourceController;
         }
 
         public void body() {
-
-
+                
+                for(Initializable initObj: simEnv.getToInit()){
+                        initObj.initiate();
+                }
+                simEnv.setInitList(null);
+                
                 // Process events until END_OF_SIMULATION is received from the
                 // GridSimShutdown Entity
@@ -87 +93 @@
         public void sendToAllSchedulers(double delay, int tag, Object data){
                 List<Scheduler> allSchedulers =  new ArrayList<Scheduler>();
-                if (resourceController.getScheduler().getChildren() != null) {
+                if (simEnv.getScheduler().getChildren() != null) {
                         LinkedList<Scheduler> toExamine = new LinkedList<Scheduler>();
-                        toExamine.push(resourceController.getScheduler());
-                        allSchedulers.add(resourceController.getScheduler());
+                        toExamine.push(simEnv.getScheduler());
+                        allSchedulers.add(simEnv.getScheduler());
 
                         while (!toExamine.isEmpty()) {
@@ -114 +120 @@
                 List<ComputingResource> allComputingResources = new ArrayList<ComputingResource>();
 
-                if (resourceController.getComputingResources() != null) {
-                        for(ComputingResource compRes: resourceController.getComputingResources()){
+                if (simEnv.getComputingResources() != null) {
+                        for(ComputingResource compRes: simEnv.getComputingResources()){
                                 allComputingResources.addAll(compRes.getDescendantsByType(type));
                         }
@@ -125 +131 @@
                 List<ComputingResource> allComputingResources = new ArrayList<ComputingResource>();
 
-                if (resourceController.getComputingResources() != null) {
+                if (simEnv.getComputingResources() != null) {
                         LinkedList<ComputingResource> toExamine = new LinkedList<ComputingResource>();
-                        for(ComputingResource compRes: resourceController.getComputingResources()){
+                        for(ComputingResource compRes: simEnv.getComputingResources()){
                                 toExamine.push(compRes);
                                 allComputingResources.add(compRes);
@@ -146 +152 @@
         }
 
+        public void sendToResource(String resourceName, double delay, Event event){
+                List<ComputingResource> allComputingResources = new ArrayList<ComputingResource>();
+
+                try {
+                        allComputingResources.add(SimulatedEnvironment.getComputingResourceByName(resourceName));
+                } catch (ResourceException e) {
+
+                }
+                sendInternal(delay, DCWormsTags.TO_COMP_RESOURCES, new ResourceBroadcastOrder(allComputingResources, event));
+        }
+        
         private void sendToResources(Sim_event ev){
                 ResourceEventCommand rec;