From c448293788fe9a4ae8c3efc43439ae3b6a192c50 Mon Sep 17 00:00:00 2001 From: leventov Date: Wed, 23 Dec 2015 16:26:28 +0300 Subject: [PATCH] Fix a bug -- drop changes in doRemoveCompetely() --- .../map/impl/stage/iter/ReplicatedMapSegmentIteration.java | 1 + .../chronicle/map/impl/stage/query/ReplicatedMapQuery.java | 1 + 2 files changed, 2 insertions(+) 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 90675d930..3645f5bee 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 @@ -126,6 +126,7 @@ public abstract class ReplicatedMapSegmentIteration extends MapSegmentI public void doRemoveCompletely() { boolean wasDeleted = e.entryDeleted(); super.doRemove(); + ru.dropChange(); if (wasDeleted) s.tierDeleted(s.tierDeleted() - 1); } diff --git a/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java b/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java index 8f3dd3f49..e54669038 100644 --- a/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java +++ b/src/main/java/net/openhft/chronicle/map/impl/stage/query/ReplicatedMapQuery.java @@ -88,6 +88,7 @@ public abstract class ReplicatedMapQuery extends MapQuery public void doRemoveCompletely() { boolean wasDeleted = e.entryDeleted(); super.doRemove(); + ru.dropChange(); if (wasDeleted) s.tierDeleted(s.tierDeleted() - 1L); }