From abe4297c9ec78d898e41d4e774a4b151e4252aa3 Mon Sep 17 00:00:00 2001 From: epickrram Date: Fri, 14 Jul 2017 12:18:37 +0100 Subject: [PATCH] skip over value bytes after reading replicated data --- .../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 ea64518d5..2239dd6a4 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 @@ -66,7 +66,7 @@ public abstract class ReplicatedInput implements RemoteOperationContext long valueSize = mh.m().valueSizeMarshaller.readSize(replicatedInputBytes); long valueOffset = replicatedInputBytes.readPosition(); Data value = q.wrapValueBytesAsData(replicatedInputBytes, valueOffset, valueSize); - + replicatedInputBytes.readSkip(valueSize); s.innerWriteLock.lock(); mh.m().remoteOperations.put(this, value); }