diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java index 86e63bdd8..827a281c7 100644 --- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java @@ -919,12 +919,12 @@ public class ReplicatedChronicleMap extends VanillaChronicleMap context = iterationContext()) { + final long nextEntryPos = nextEntryPos(callback, chronicleId); + if (nextEntryPos == NOT_FOUND) + return false; + entryPos = nextEntryPos; + if (segmentIndex >= 0) { // we are in first tiers (aka "segments") context.initSegmentIndex(segmentIndex);