cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

fix: storage: Remove temp fetching files after failed fetch

Browse Source
This commit is contained in:
Łukasz Magiera 2023-04-12 16:05:01 -07:00
parent a7379e2cce
commit 7a4f69721c
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
storage/paths/remote.go
View File

@ -236,6 +236,10 @@ func (r *Remote) acquireFromRemote(ctx context.Context, s abi.SectorID, fileType
err = r.fetchThrottled(ctx, url, tempDest) err = r.fetchThrottled(ctx, url, tempDest)
if err != nil { if err != nil {
merr = multierror.Append(merr, xerrors.Errorf("fetch error %s (storage %s) -> %s: %w", url, info.ID, tempDest, err)) merr = multierror.Append(merr, xerrors.Errorf("fetch error %s (storage %s) -> %s: %w", url, info.ID, tempDest, err))
// fetching failed, remove temp file
if rerr := os.RemoveAll(tempDest); rerr != nil {
merr = multierror.Append(merr, xerrors.Errorf("removing temp dest (post-err cleanup): %w", rerr))
}
continue continue
} }