diff --git a/src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java b/src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java index 465f4a1c0..8e0e16eec 100644 --- a/src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java +++ b/src/main/java/net/openhft/chronicle/map/impl/stage/iter/ReplicatedMapSegmentIteration.java @@ -134,8 +134,8 @@ public abstract class ReplicatedMapSegmentIteration extends MapSegmentI checkOnEachPublicOperation.checkOnEachPublicOperation(); if (e.entryDeleted()) { try { - e.innerDefaultReplaceValue(value); s.tierDeleted(s.tierDeleted() - 1); + e.innerDefaultReplaceValue(value); s.incrementModCount(); e.writeEntryPresent(); ru.updateChange(); diff --git a/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapAbsent.java b/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapAbsent.java index 86c77933e..2f86e0b22 100644 --- a/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapAbsent.java +++ b/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapAbsent.java @@ -52,9 +52,9 @@ public abstract class ReplicatedMapAbsent extends MapAbsent { ks.setSearchState(PRESENT); q.initPresenceOfEntry(EntryPresence.PRESENT); } else { + s.tierDeleted(s.tierDeleted() - 1); e.innerDefaultReplaceValue(value); e.updatedReplicationStateOnPresentEntry(); - s.tierDeleted(s.tierDeleted() - 1); } s.incrementModCount(); e.writeEntryPresent();