Do not copy bytes when deserializing

[controller.git] / atomix-storage / src / main / java / io / atomix / storage / journal / JournalSerdes.java

diff --git a/atomix-storage/src/main/java/io/atomix/storage/journal/JournalSerdes.java b/atomix-storage/src/main/java/io/atomix/storage/journal/JournalSerdes.java
index ffdc9858271ba9d79ec598e5128d7cfea15e1aad..9d6d6ee9927b817f56f528725692a4c2e4a28044 100644 (file)
--- a/atomix-storage/src/main/java/io/atomix/storage/journal/JournalSerdes.java
+++ b/atomix-storage/src/main/java/io/atomix/storage/journal/JournalSerdes.java
@@ -20,7 +20,6 @@ import com.google.common.annotations.Beta;
 import com.google.common.annotations.VisibleForTesting;
 import io.atomix.utils.serializer.KryoJournalSerdesBuilder;
 import io.netty.buffer.ByteBuf;
-import io.netty.buffer.ByteBufUtil;
 import io.netty.buffer.Unpooled;
 import java.io.IOException;
 import java.io.InputStream;
@@ -127,8 +126,7 @@ public interface JournalSerdes {
 
             @Override
             public T bytesToObject(final ByteBuf buf) {
-                // FIXME: ByteBufUtil creates a copy -- we do not want to do that!
-                return deserialize(ByteBufUtil.getBytes(buf));
+                return deserialize(buf.nioBuffer());
             }
         };
     }