Changeset 1379 for DCWoRMS/branches

Timestamp:

06/06/14 11:25:49 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/local/LocalManagementSystem.java (modified) (4 diffs)

DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/local/LocalManagementSystem.java

@@ -178 +178 @@
                         String[] ids = (String[]) ev.get_data();
                         execTask = jobRegistry.getTask(ids[0], ids[1]);
-                        taskResume(execTask, execTask.getAllocatedResources().getLast().getResourceUnits());
+                        taskResume(execTask, execTask.getAllocatedResources().getLast().getResourceUnits(), true);
                         if (pluginSupportsEvent(tag)) {
                                 SchedulingEvent event = new StartTaskExecutionEvent(ids[0], ids[1]);
@@ -254 +254 @@
         }
         
-        public void taskResume(ExecTask execTask, Map<ResourceUnitName, ResourceUnit> resources) {
+        public void taskResume(ExecTask execTask, Map<ResourceUnitName, ResourceUnit> resources, boolean exclusive) {
                 if (execTask == null) {
                         return;
@@ -262 +262 @@
                                 Executable exec = (Executable) execTask;
 
-                                boolean status = allocateResources(exec, resources, true);
+                                boolean status = allocateResources(exec, resources, exclusive);
                                 if(status == false){
                                         TaskList newTasks = new TaskListImpl();
@@ -284 +284 @@
         public void taskMove(ExecTask execTask, Map<ResourceUnitName, ResourceUnit> map) {
                 taskPause(execTask);
-                taskResume(execTask, map);
+                taskResume(execTask, map, false);
         }