Fixed a bug in ReplicatedChronicleMap -- forgot to drop relocated entry

mod iter bits
This commit is contained in:
leventov
2015-02-09 06:25:36 +07:00
parent 289179a08d
commit 2b8d58466c
3 changed files with 7 additions and 2 deletions
@@ -429,6 +429,11 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
}
}
@Override
void beforeRelocation() {
m().dropChange(segmentIndex, pos);
}
@Override
boolean freeListBitsSet() {
// As of now, ReplicatedChMap's remove() never clear the bits
@@ -1367,8 +1367,9 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
}
}
}
} else
} else {
externalizable.readExternalEntry(context, out);
}
out.limit(limit);
@@ -31,7 +31,6 @@ import java.util.Random;
import java.util.Set;
import static net.openhft.chronicle.map.Builder.newTcpSocketShmBuilder;
import static net.openhft.chronicle.map.TCPSocketReplication4WayMapTest.newTcpSocketShmIntString;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;