diff options
| author | chrislu <chris.lu@gmail.com> | 2025-06-07 22:52:31 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-06-07 22:52:31 -0700 |
| commit | 69df7a9182c4cd517566b93f6e901dfc548b3117 (patch) | |
| tree | d71286b64c4770c2330d64008b423725929e086a | |
| parent | b25f95df0a49d22e111dbb0fb42e60a937bb97ce (diff) | |
| download | seaweedfs-69df7a9182c4cd517566b93f6e901dfc548b3117.tar.xz seaweedfs-69df7a9182c4cd517566b93f6e901dfc548b3117.zip | |
Make ReadData a thin wrapper
| -rw-r--r-- | weed/storage/needle/needle_read.go | 21 |
1 files changed, 6 insertions, 15 deletions
diff --git a/weed/storage/needle/needle_read.go b/weed/storage/needle/needle_read.go index 905969e36..69c510e08 100644 --- a/weed/storage/needle/needle_read.go +++ b/weed/storage/needle/needle_read.go @@ -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) { |
