diff options
| -rw-r--r-- | src/jvm/clojure/lang/LockingTransaction.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/jvm/clojure/lang/LockingTransaction.java b/src/jvm/clojure/lang/LockingTransaction.java index c2415367..c152546b 100644 --- a/src/jvm/clojure/lang/LockingTransaction.java +++ b/src/jvm/clojure/lang/LockingTransaction.java @@ -14,6 +14,7 @@ package clojure.lang; import java.util.*; import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.Callable; @SuppressWarnings({"SynchronizeOnNonFinalField"}) @@ -66,7 +67,7 @@ static class CFn{ } //total order on transactions //transactions will consume a point for init, for each retry, and on commit if writing -final private static AtomicInteger lastPoint = new AtomicInteger(); +final private static AtomicLong lastPoint = new AtomicLong(); void getReadPoint(){ readPoint = lastPoint.incrementAndGet(); |