You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by sa...@apache.org on 2013/01/23 12:06:00 UTC

svn commit: r1437341 - in /ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple: JobComparatorByDate.java Task.java

Author: sathwik
Date: Wed Jan 23 11:06:00 2013
New Revision: 1437341

URL: http://svn.apache.org/viewvc?rev=1437341&view=rev
Log:
ODE-990: added a message coutner to the task

Modified:
    ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java
    ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java

Modified: ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java
URL: http://svn.apache.org/viewvc/ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java?rev=1437341&r1=1437340&r2=1437341&view=diff
==============================================================================
--- ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java (original)
+++ ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java Wed Jan 23 11:06:00 2013
@@ -32,7 +32,7 @@ class JobComparatorByDate implements Com
         long diff = o1.schedDate - o2.schedDate;
         if (diff < 0) return -1;
         if (diff > 0) return 1;
-        return 0;
+        return o1.taskSeqNum < o2.taskSeqNum ? -1 : 1;
     }
 
 }

Modified: ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java
URL: http://svn.apache.org/viewvc/ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java?rev=1437341&r1=1437340&r2=1437341&view=diff
==============================================================================
--- ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java (original)
+++ ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java Wed Jan 23 11:06:00 2013
@@ -19,6 +19,8 @@
 
 package org.apache.ode.scheduler.simple;
 
+import java.util.concurrent.atomic.AtomicLong;
+
 /**
  * The thing that we schedule.
  *
@@ -28,8 +30,11 @@ package org.apache.ode.scheduler.simple;
 class Task {
     /** Scheduled date/time. */
     public long schedDate;
+    public long taskSeqNum;
+    private static final AtomicLong counter = new AtomicLong();
 
     Task(long schedDate) {
         this.schedDate = schedDate;
+        this.taskSeqNum = counter.incrementAndGet();
     }
 }