diff options
| author | chrislu <chris.lu@gmail.com> | 2024-08-11 20:59:32 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-08-11 20:59:32 -0700 |
| commit | c055ee733435147f01d1d61ac00ad63f1d917087 (patch) | |
| tree | dabfcda9e6a1b37843836eec16f0b3649efa6be6 | |
| parent | 270e91b0beb0fce59946cbbf10d80e58612ebec7 (diff) | |
| download | seaweedfs-c055ee733435147f01d1d61ac00ad63f1d917087.tar.xz seaweedfs-c055ee733435147f01d1d61ac00ad63f1d917087.zip | |
fix reading chunk length calculation
| -rw-r--r-- | other/java/client/src/main/java/seaweedfs/client/SeaweedRead.java | 2 |
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); |
