From 679e156da2b799c378ca4c33ddb33de892e7f30b Mon Sep 17 00:00:00 2001
From: epickrram <mark@epickrram.com>
Date: Fri, 14 Jul 2017 13:21:56 +0100
Subject: [PATCH] skip key bytes when the replication entry is a delete

---
 .../openhft/chronicle/map/impl/stage/input/ReplicatedInput.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java b/src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java
index 2239dd6a4..e5b1dbb7b 100644
--- a/src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java
+++ b/src/main/java/net/openhft/chronicle/map/impl/stage/input/ReplicatedInput.java
@@ -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);