Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

updateChange() should always be called after replicationStateUpdate(), because updateChange() uses the new timestamp

Browse Source
This commit is contained in:
leventov
2015-12-20 18:33:47 +03:00
parent dd4fa03bfe
commit 60de795949
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java
+2 -2
View File
@@ -74,8 +74,8 @@ public abstract class ReplicatedMapSegmentIteration<K, V, R> extends MapSegmentI
checkOnEachPublicOperation.checkOnEachPublicOperation();
try {
entry.innerDefaultReplaceValue(newValue);
ru.updateChange();
e.updatedReplicationStateOnPresentEntry();
ru.updateChange();
} finally {
s.innerWriteLock.unlock();
}
@@ -138,8 +138,8 @@ public abstract class ReplicatedMapSegmentIteration<K, V, R> extends MapSegmentI
e.innerDefaultReplaceValue(value);
s.incrementModCount();
e.writeEntryPresent();
ru.updateChange();
e.updatedReplicationStateOnPresentEntry();
ru.updateChange();
} finally {
s.innerWriteLock.unlock();
}
src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java
+1 -1
View File
@@ -95,7 +95,7 @@ public abstract class ReplicatedMapQuery<K, V, R> extends MapQuery<K, V, R>
@Override
public void doReplaceValue(Data<V> newValue) {
super.doReplaceValue(newValue);
ru.updateChange();
e.updatedReplicationStateOnPresentEntry();
ru.updateChange();
}
}