Changeset 21

Timestamp:

08/24/11 13:33:28 (14 years ago)

Author:

wojtekp

Message:

adjustment of time requirements to experiment specific and modification of resource allocation violation policy

Location:

gssim/trunk/src/test/guiexp

Files:

• GridARResourcePriorityPlugin.java (modified) (1 diff)
• MixedAllSlots.java (modified) (2 diffs)

gssim/trunk/src/test/guiexp/GridARResourcePriorityPlugin.java

@@ -198 +198 @@
 
                                         log.warn("Changing task time requirements: " + task.getJobId() + "_" + task.getId());
-                                        //change task time requirements - set the possible end time to infinity
+                                        //change task time requirements - extend the possible end period to 100 hours
                                         if(timeFault)
-                                                timeRequirements = new TimeRequirements(task, -(new DateTime().getMillis()-timeRequirements.getStartMillis())/1000, Long.MAX_VALUE);
+                                                timeRequirements = new TimeRequirements(task, -(new DateTime().getMillis()-timeRequirements.getStartMillis())/1000, 360000);
                                         else
-                                                timeRequirements = new TimeRequirements(task, x, Long.MAX_VALUE);
+                                                timeRequirements = new TimeRequirements(task, x, 360000);
                                         
                                         resourceRequirements = new ResourceRequirements(task);

gssim/trunk/src/test/guiexp/MixedAllSlots.java

@@ -24 +24 @@
 import schedframe.scheduling.events.SchedulingEvent;
 import schedframe.scheduling.events.SchedulingEventType;
+import schedframe.scheduling.events.SchedulingResponseType;
 import schedframe.scheduling.events.StartTaskExecutionEvent;
 import schedframe.scheduling.plugin.SchedulingPluginConfiguration;
@@ -409 +410 @@
         }
         
+        public SchedulingResponseType handleResourceAllocationViolation(SchedulingEvent event,
+                        List<? extends TaskInterface<?>> inExecution,
+                                        List<? extends Queue<? extends TaskInterface<?>>> queues,
+                                        ResourceUnitsManagerInterface unitsManager,
+                                        LocalReservationManager reservationManager){
+                SchedulingResponseType timeEvent = null;
+                switch(event.getType()){
+                        case TASK_REQUESTED_TIME_EXPIRED: 
+                                timeEvent = SchedulingResponseType.STOP_AND_RESUME_FROM_CHECKPOINT;
+                                break;  
+                }
+                return timeEvent;
+        }
+        
+        public SchedulingResponseType handleResourceAllocationViolation(SchedulingEvent event,
+                        List<? extends TaskInterface<?>> inExecution,
+                                        List<? extends Queue<? extends TaskInterface<?>>> queues,
+                                        ResourceUnitsManagerInterface unitsManager){
+                SchedulingResponseType timeEvent = null;
+                switch(event.getType()){
+                        case TASK_REQUESTED_TIME_EXPIRED: 
+                                timeEvent = SchedulingResponseType.STOP_AND_RESUME_FROM_CHECKPOINT;
+                                break;  
+                }
+                return timeEvent;
+        }
+
 }