KurlesHS/restic
1
0
Fork 0
forked from TrueCloudLab/restic
Code Pull requests Activity

fuse: switch to use bloblru.GetOrCompute

Browse source
This commit is contained in:
Michael Eischer 2024-05-05 11:38:17 +02:00
parent bd03af2feb
commit 7cce667f92
1 changed files with 3 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
internal/fuse/file.go
View file

@ -96,20 +96,14 @@ func (f *file) Open(_ context.Context, _ *fuse.OpenRequest, _ *fuse.OpenResponse
} }
func (f *openFile) getBlobAt(ctx context.Context, i int) (blob []byte, err error) { func (f *openFile) getBlobAt(ctx context.Context, i int) (blob []byte, err error) {
blob, err = f.root.blobCache.GetOrCompute(f.node.Content[i], func() ([]byte, error) {
blob, ok := f.root.blobCache.Get(f.node.Content[i]) return f.root.repo.LoadBlob(ctx, restic.DataBlob, f.node.Content[i], nil)
if ok { })
return blob, nil
}
blob, err = f.root.repo.LoadBlob(ctx, restic.DataBlob, f.node.Content[i], nil)
if err != nil { if err != nil {
debug.Log("LoadBlob(%v, %v) failed: %v", f.node.Name, f.node.Content[i], err) debug.Log("LoadBlob(%v, %v) failed: %v", f.node.Name, f.node.Content[i], err)
return nil, unwrapCtxCanceled(err) return nil, unwrapCtxCanceled(err)
} }
f.root.blobCache.Add(f.node.Content[i], blob)
return blob, nil return blob, nil
} }