Changeset 478 for DCWoRMS/trunk/src/schedframe/scheduling/policy/local/LocalManagementSystem.java

Timestamp:

10/01/12 10:05:16 (13 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/src/schedframe/scheduling/policy/local/LocalManagementSystem.java (modified) (5 diffs)

DCWoRMS/trunk/src/schedframe/scheduling/policy/local/LocalManagementSystem.java

@@ -192 +192 @@
         
 
-        public void notifyReturnedWorkloadUnit(WorkloadUnit<?> wu) {
+        public void notifyReturnedWorkloadUnit(WorkloadUnit wu) {
                 if (pluginSupportsEvent(WormsTags.TASK_EXECUTION_FINISHED)) {
                         SchedulingEvent event = new SchedulingEvent(SchedulingEventType.TASK_FINISHED);
@@ -204 +204 @@
         }
 
-        public void notifyCanceledWorkloadUnit(WorkloadUnit<?> job) {
+        public void notifyCanceledWorkloadUnit(WorkloadUnit job) {
 
                 if (!pluginSupportsEvent(GridSimTags.GRIDLET_CANCEL))
@@ -247 +247 @@
                                 ArrayList<AllocationInterface> allocations = taskDecision.getAllocations();
 
-                                WorkloadUnit<?> task = taskDecision.getTask();
+                                WorkloadUnit task = taskDecision.getTask();
                                 for (int j = 0; j < allocations.size(); j++) {
 
@@ -633 +633 @@
 
         
-        public void notifySubmittedWorkloadUnit(WorkloadUnit<?> job, boolean ack) {
+        public void notifySubmittedWorkloadUnit(WorkloadUnit job, boolean ack) {
                 updateProcessingProgress();
                 registerWorkloadUnit(job);
         }
 
-        private void registerWorkloadUnit(WorkloadUnit<?> wu){
+        private void registerWorkloadUnit(WorkloadUnit wu){
                 if(!wu.isRegistered()){
                         wu.register(jobRegistry);
@@ -660 +660 @@
                         }
 
-                        for(WorkloadUnit<?> e:readyTasks){      
+                        for(WorkloadUnit e:readyTasks){ 
                                 registerWorkloadUnit(e);
                         }