Changeset 1374 for DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/tasks

Timestamp:

06/05/14 15:24:38 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/tasks/AbstractJobRegistry.java (modified) (5 diffs)

DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/tasks/AbstractJobRegistry.java

@@ -11 +11 @@
 import schedframe.resources.units.ResourceUnit;
 import schedframe.resources.units.ResourceUnitName;
+import schedframe.scheduling.manager.resources.utils.ResourceManagerUtils;
 import schedframe.scheduling.tasks.Job;
 import schedframe.scheduling.tasks.JobInterface;
@@ -65 +66 @@
         public List<JobInterface<?>> getJobs(){
                 List<JobInterface<?>> jobList = new ArrayList<JobInterface<?>>();
-                for(String jobId:jobs.keySet()) {
+                for(String jobId: jobs.keySet()) {
                         jobList.add(jobs.get(jobId));
                 }
@@ -74 +75 @@
                 List<JobInterface<?>> jobList = new ArrayList<JobInterface<?>>();
                 synchronized (jobs) {
-                        for(String jobId:jobs.keySet()){
+                        for(String jobId: jobs.keySet()){
                                 JobInterface<?> job = jobs.get(jobId);
                                 if (job.getStatus() == status) {
@@ -90 +91 @@
                         return false;
                 }else{
+                        try {
+                                execTask.setStatus(DCWormsTags.PAUSING);
+                        } catch (Exception e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                        }
                         String[] ids = new String[2];
                         ids[0] = new String(jobId);
@@ -116 +123 @@
                         return false;
                 }else{
+                        try {
+                                execTask.setStatus(DCWormsTags.IN_MIGRATION);
+                        } catch (Exception e) {
+                                return false;
+                        }
+                        if(choosenResources != null){
+                                ResourceManagerUtils.setPendingResources(choosenResources);
+                        }
                         Object[] data = new Object[3];
                         data[0] = new String(jobId);