diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java index b30590c47..b765b6f1a 100644 --- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java @@ -351,33 +351,6 @@ final class ReplicatedChronicleMap buffer = new ThreadLocal() { - @Override - protected IByteBufferBytes initialValue() { - return ByteBufferBytes.wrap(ByteBuffer.allocateDirect(1024)); - } - }; - - private Bytes threadlocalBuffer(long requiredSize) { - - final IByteBufferBytes bytes = buffer.get(); - bytes.clear(); - bytes.buffer().clear(); - - if (bytes.buffer().remaining() < requiredSize) { - - if (requiredSize > Integer.MAX_VALUE) - throw new IllegalStateException("entry is too large"); - - IByteBufferBytes result = ByteBufferBytes.wrap(ByteBuffer.allocateDirect((int) requiredSize)); - buffer.set(result); - return result; - } - - return bytes; - - } - @Override public void put(final Bytes key, final Bytes value, final byte id, final long timestamp) {