feat(s3stream): optimization on crc calculation (#596)

Signed-off-by: Shichao Nie <[email protected]>
AutoMQ · Nov 8, 2023 · e4e79a8 · e4e79a8
1 parent 960631c
commit e4e79a8
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/wal/util/WALUtil.java b/s3stream/src/main/java/com/automq/stream/s3/wal/util/WALUtil.java
@@ -19,6 +19,7 @@
 
 import io.netty.buffer.ByteBuf;
 
+import java.nio.ByteBuffer;
 import java.util.zip.CRC32;
 
 public class WALUtil {
@@ -41,11 +42,10 @@ public static int crc32(ByteBuf buf) {
      */
     public static int crc32(ByteBuf buf, int length) {
         CRC32 crc32 = new CRC32();
-        buf.markReaderIndex();
-        for (int i = 0; i < length; i++) {
-            crc32.update(buf.readByte());
+        ByteBuf slice = buf.slice(buf.readerIndex(), length);
+        for (ByteBuffer buffer : slice.nioBuffers()) {
+            crc32.update(buffer);
         }
-        buf.resetReaderIndex();
         return (int) (crc32.getValue() & 0x7FFFFFFF);
     }