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 {