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

skip key bytes when the replication entry is a delete

Browse Source
This commit is contained in:
epickrram
2017-07-14 13:21:56 +01:00
parent abe4297c9e
commit 679e156da2
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java
+1 -1
View File
@@ -58,11 +58,11 @@ public abstract class ReplicatedInput<K, V, R> implements RemoteOperationContext
long keyOffset = replicatedInputBytes.readPosition();
q.initInputKey(q.getInputKeyBytesAsData(replicatedInputBytes, keyOffset, keySize));
replicatedInputBytes.readSkip(keySize);
if (isDeleted) {
s.innerUpdateLock.lock();
mh.m().remoteOperations.remove(this);
} else {
replicatedInputBytes.readSkip(keySize);
long valueSize = mh.m().valueSizeMarshaller.readSize(replicatedInputBytes);
long valueOffset = replicatedInputBytes.readPosition();
Data<V> value = q.wrapValueBytesAsData(replicatedInputBytes, valueOffset, valueSize);