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

Timestamp:

07/31/13 15:29:05 (12 years ago)

Author:

wojtekp

Message:

 

File:

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

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

@@ -2 +2 @@
 
 
+import java.util.ArrayList;
+import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
 
 import schedframe.scheduling.tasks.Job;
@@ -24 +23 @@
         
         public boolean addJob(JobInterface<?> job) {
-                jobs.put(job.getId(),  job);
+                jobs.put(job.getId(), job);
                 return true;
         }
@@ -58 +57 @@
                 return (Job)jobs.get(jobId);
         }
+        
+        public List<JobInterface<?>> getJobs(){
+                List<JobInterface<?>> jobList = new ArrayList<JobInterface<?>>();
+                for(String jobId:jobs.keySet()) {
+                        jobList.add(jobs.get(jobId));
+                }
+                return jobList;
+        }
+
+        public List<JobInterface<?>> getJobs(int status) {
+                List<JobInterface<?>> jobList = new ArrayList<JobInterface<?>>();
+                synchronized (jobs) {
+                        for(String jobId:jobs.keySet()){
+                                JobInterface<?> job = jobs.get(jobId);
+                                if (job.getStatus() == status) {
+                                        jobList.add(job);
+                                }
+                        }
+                }
+                return jobList;
+        }
 
 }