lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-10-07 15:59:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Make ReadData a thin wrapper

Browse Source
This commit is contained in:
chrislu
2025-06-07 22:52:31 -07:00
parent b25f95df0a
commit 69df7a9182
1 changed files with 6 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
weed/storage/needle/needle_read.go
View File

@@ -96,21 +96,12 @@ func (n *Needle) ReadBytes(bytes []byte, offset int64, size Size, version Versio
}
// ReadData hydrates the needle from the file, with only n.Id is set.
func (n *Needle) ReadData(r backend.BackendStorageFile, offset int64, size Size, version Version) (err error) {
bytes, err := ReadNeedleBlob(r, offset, size, version)
if err != nil {
return err
}
err = n.ReadBytes(bytes, offset, size, version)
if err == ErrorSizeMismatch && OffsetSize == 4 {
offset = offset + int64(MaxPossibleVolumeSize)
bytes, err = ReadNeedleBlob(r, offset, size, version)
if err != nil {
return err
}
err = n.ReadBytes(bytes, offset, size, version)
}
return err
func (n *Needle) ReadData(r backend.BackendStorageFile, offset int64, size Size, version Version) error {
return n.ReadFromFile(r, offset, size, version, NeedleReadOptions{
ReadHeader: true,
ReadData: true,
ReadMeta: true,
})
}
func (n *Needle) ParseNeedleHeader(bytes []byte) {