only flush the buffer if necessary

apache · Nov 13, 2024 · 3f21cd0 · 3f21cd0
1 parent dd096a8
commit 3f21cd0
Showing 1 changed file with 12 additions and 4 deletions.
diff --git a/lucene/core/src/java/org/apache/lucene/store/BufferedChecksum.java b/lucene/core/src/java/org/apache/lucene/store/BufferedChecksum.java
@@ -83,13 +83,21 @@ void updateLong(long val) {
   }
 
   void updateLongs(long[] vals, int offset, int len) {
-    flush();
+    if (upto > 0) {
+      int remainingCapacityInLong = Math.min((buffer.length - upto) / Long.BYTES, len);
+      for (int i = 0; i < remainingCapacityInLong; i++, offset++, len--) {
+        updateLong(vals[offset]);
+      }
+      if (0 == len) return;
+    }
+
     LongBuffer b = ByteBuffer.wrap(buffer).order(ByteOrder.LITTLE_ENDIAN).asLongBuffer();
-    final int bufferSizeInLongs = buffer.length / Long.BYTES;
+    final int capacityInLong = buffer.length / Long.BYTES;
     while (len > 0) {
-      int l = Math.min(bufferSizeInLongs, len);
+      flush();
+      int l = Math.min(capacityInLong, len);
       b.put(0, vals, offset, l);
-      in.update(buffer, 0, l * Long.BYTES);
+      upto += l * Long.BYTES;
       offset += l;
       len -= l;
     }