aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-08-11 20:59:32 -0700
committerchrislu <chris.lu@gmail.com>2024-08-11 20:59:32 -0700
commitc055ee733435147f01d1d61ac00ad63f1d917087 (patch)
treedabfcda9e6a1b37843836eec16f0b3649efa6be6
parent270e91b0beb0fce59946cbbf10d80e58612ebec7 (diff)
downloadseaweedfs-c055ee733435147f01d1d61ac00ad63f1d917087.tar.xz
seaweedfs-c055ee733435147f01d1d61ac00ad63f1d917087.zip
fix reading chunk length calculation
-rw-r--r--other/java/client/src/main/java/seaweedfs/client/SeaweedRead.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedRead.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedRead.java
index 23fb14ebb..cac85d186 100644
--- a/other/java/client/src/main/java/seaweedfs/client/SeaweedRead.java
+++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedRead.java
@@ -103,7 +103,7 @@ public class SeaweedRead {
chunkCache.setChunk(chunkView.fileId, chunkData);
}
- int len = (int) chunkView.size;
+ int len = (int) chunkView.size - (int) (startOffset - chunkView.logicOffset);
LOG.debug("readChunkView fid:{} chunkData.length:{} chunkView.offset:{} chunkView[{};{}) startOffset:{}",
chunkView.fileId, chunkData.length, chunkView.offset, chunkView.logicOffset, chunkView.logicOffset + chunkView.size, startOffset);
buf.put(chunkData, (int) (startOffset - chunkView.logicOffset + chunkView.offset), len);