Fix

Tim-Brooks · May 2, 2024 · 769292d · 769292d
1 parent c766939
commit 769292d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/x-pack/plugin/blob-cache/src/main/java/org/elasticsearch/blobcache/shared/SharedBytes.java b/x-pack/plugin/blob-cache/src/main/java/org/elasticsearch/blobcache/shared/SharedBytes.java
@@ -204,12 +204,13 @@ public static int copyToCacheFileAligned(IO fc, InputStream input, int fileChann
             if (bytesRead <= 0) {
                 break;
             }
-            bytesCopied = copyToCacheFileAligned(fc, fileChannelPos + bytesCopied, progressUpdater, buffer);
+            bytesCopied += copyToCacheFileAligned(fc, fileChannelPos + bytesCopied, buffer);
+            progressUpdater.accept(bytesCopied);
         }
         return bytesCopied;
     }
 
-    public static int copyToCacheFileAligned(IO fc, int fileChannelPos, IntConsumer progressUpdater, ByteBuffer buffer)
+    public static int copyToCacheFileAligned(IO fc, int fileChannelPos, ByteBuffer buffer)
         throws IOException {
         if (buffer.hasRemaining()) {
             // ensure that last write is aligned on 4k boundaries (= page size)
@@ -218,7 +219,6 @@ public static int copyToCacheFileAligned(IO fc, int fileChannelPos, IntConsumer
             buffer.position(buffer.position() + adjustment);
         }
         int bytesCopied = positionalWrite(fc, fileChannelPos, buffer);
-        progressUpdater.accept(bytesCopied);
         return bytesCopied;
     }