Author: midon
Date: Thu Oct 15 03:17:20 2009
New Revision: 825380

URL: http://svn.apache.org/viewvc?rev=825380&view=rev
Log:
The enemy of my enemy is my friend

Modified:
    
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java

Modified: 
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java?rev=825380&r1=825379&r2=825380&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
 Thu Oct 15 03:17:20 2009
@@ -682,9 +682,9 @@
     }
 
     void enqueue(Job job) {
-        boolean outstanding = _outstandingJobs.putIfAbsent(job.jobId, 
job.schedDate) == null;
-        boolean processed = _processedSinceLastLoadTask.get(job.jobId) == null;
-        if (!outstanding && !processed) {
+        boolean not_outstanding = _outstandingJobs.putIfAbsent(job.jobId, 
job.schedDate) == null;
+        boolean not_processed = _processedSinceLastLoadTask.get(job.jobId) == 
null;
+        if (not_outstanding && not_processed) {
             if (job.schedDate <= System.currentTimeMillis()) {
                 runJob(job);
             } else {


Reply via email to