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

Conditional update of ReplicatedGlobalMutableState.modificationIteratorInitAt

Browse Source
This commit is contained in:
leventov
2016-01-03 04:01:17 +03:00
parent 7847675f6f
commit b4c97ced36
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
+2 -1
View File
@@ -326,7 +326,8 @@ public class ReplicatedChronicleMap<K, V, R> extends VanillaChronicleMap<K, V, R
globalMutableState().getModificationIteratorInitAt(remoteIdentifier);
final ModificationIterator modIter =
new ModificationIterator(remoteIdentifier, modificationIteratorInit);
globalMutableState().setModificationIteratorInitAt(remoteIdentifier, true);
if (!modificationIteratorInit)
globalMutableState().setModificationIteratorInitAt(remoteIdentifier, true);
//noinspection unchecked
assignedModificationIterators = Stream
.concat(Arrays.stream(assignedModificationIterators), Stream.of(modIter))