Changes between Version 14 and Version 15 of schedule

Timestamp:

10/22/2012 10:50:46 AM (13 years ago)

Author:

liaojiaohe

Comment:

--

schedule

@@ -45 +45 @@
 
 {{{
- @Override
+   //增加一个map保存job真是分配到哪个queue，在jobAdd里面增加，jobRemoved清除
+  private Map<String,String> jobQueueMap = new HashMap<String, String>();
+  public String getJobQueue( JobInProgress job){
+      if (jobQueueMap.get(job.getJobID().toString()) != null){
+            return jobQueueMap.get(job.getJobID().toString());        
+      }else{
+          return job.getProfile().queueName;
+      }
+  }
+
+  public Map<String, String> getJobQueueMap() {
+        return jobQueueMap;
+  }
+
+  @Override
   public void jobAdded(JobInProgress job) throws IOException {
     LOG.info("Job " + job.getJobID() + " submitted to queue " + 
@@ -68 +82 @@
         if (highPriorityQueue != null ){
             highPriorityQueue.addWaitingJob(job);
+            jobQueueMap.put(job.getJobID().toString(), "highpriority");
         }else{
             queue.addWaitingJob(job);
@@ -83 +98 @@
   }
 
+  @Override
+  public void jobRemoved(JobInProgress job) {
+    jobQueueMap.remove(job.getJobID().toString());
+  }
+
 }}}
+
+替换其他地方的拿jobQueue的方法为
+
+job.getProfile().getQueueName() =》jobQueuesManager.getJobQueue(job)