Skip to content

Commit fb2493a

Browse files
committed
simplify readFromCache
Signed-off-by: Kohei Tokunaga <[email protected]>
1 parent f13f534 commit fb2493a

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

fs/remote/blob.go

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -299,18 +299,18 @@ func (b *blob) prepareChunksForRead(allRegion region, offset int64, p []byte, fr
299299
// readFromCache attempts to read chunk data from cache
300300
func (b *blob) readFromCache(chunk region, dest []byte, offset int64, fr fetcher, opts *options) error {
301301
r, err := b.cache.Get(fr.genID(chunk), opts.cacheOpts...)
302-
if err == nil {
303-
defer r.Close()
304-
var n int
305-
n, err = r.ReadAt(dest, offset)
306-
if err == nil && int64(n) != int64(len(dest)) {
307-
return fmt.Errorf("incomplete read from cache: read %d bytes, expected %d bytes", n, len(dest))
308-
}
309-
if (err == nil || err == io.EOF) && int64(n) == int64(len(dest)) {
310-
return nil
311-
}
302+
if err != nil {
303+
return err
312304
}
313-
return err
305+
defer r.Close()
306+
n, err := r.ReadAt(dest, offset)
307+
if err != nil && err != io.EOF {
308+
return err
309+
}
310+
if int64(n) != int64(len(dest)) {
311+
return fmt.Errorf("incomplete read from cache: read %d bytes, expected %d bytes", n, len(dest))
312+
}
313+
return nil
314314
}
315315

316316
// fetchRegions fetches all specified chunks from remote blob and puts it in the local cache.

0 commit comments

Comments
 (0)