diff options
| author | Christophe Grand <christophe@cgrand.net> | 2009-08-03 11:40:58 +0200 |
|---|---|---|
| committer | Rich Hickey <richhickey@gmail.com> | 2009-08-03 07:52:58 -0400 |
| commit | 309161d5d20ae9af2907cf9bc07a8647398e0289 (patch) | |
| tree | ee5dff02fc871949a7d5eec4850d5724c78905ca /src | |
| parent | a1b4a33bb8ccf739c481754fc563117ed3604c75 (diff) | |
fixes commute after set
Signed-off-by: Rich Hickey <richhickey@gmail.com>
Diffstat (limited to 'src')
| -rw-r--r-- | src/jvm/clojure/lang/LockingTransaction.java | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/src/jvm/clojure/lang/LockingTransaction.java b/src/jvm/clojure/lang/LockingTransaction.java index 4976d169..a067987c 100644 --- a/src/jvm/clojure/lang/LockingTransaction.java +++ b/src/jvm/clojure/lang/LockingTransaction.java @@ -240,6 +240,8 @@ Object run(Callable fn) throws Exception{ for(Map.Entry<Ref, ArrayList<CFn>> e : commutes.entrySet()) { Ref ref = e.getKey(); + if(sets.contains(ref)) continue; + ref.lock.writeLock().lock(); locked.add(ref); Info refinfo = ref.tinfo; @@ -249,8 +251,7 @@ Object run(Callable fn) throws Exception{ throw retryex; } Object val = ref.tvals == null ? null : ref.tvals.val; - if(!sets.contains(ref)) - vals.put(ref, val); + vals.put(ref, val); for(CFn f : e.getValue()) { vals.put(ref, f.fn.applyTo(RT.cons(vals.get(ref), f.args))); @@ -258,11 +259,8 @@ Object run(Callable fn) throws Exception{ } for(Ref ref : sets) { - if(!commutes.containsKey(ref)) - { - ref.lock.writeLock().lock(); - locked.add(ref); - } + ref.lock.writeLock().lock(); + locked.add(ref); } //validate and enqueue notifications |