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

remote: Fetch into temp files

Browse Source
This commit is contained in:
Łukasz Magiera 2020-07-24 16:54:00 +02:00
parent ff9ffddd57
commit 94e20ffee5
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
stores/remote.go
View File

@ -150,12 +150,18 @@ func (r *Remote) acquireFromRemote(ctx context.Context, s abi.SectorID, spt abi.
// TODO: see what we have local, prefer that // TODO: see what we have local, prefer that
for _, url := range info.URLs { for _, url := range info.URLs {
err := r.fetch(ctx, url, dest) tempDest := dest + ".fetch"
err := r.fetch(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, dest, err)) merr = multierror.Append(merr, xerrors.Errorf("fetch error %s (storage %s) -> %s: %w", url, info.ID, tempDest, err))
continue continue
} }
if err := move(tempDest, dest); err != nil {
return "", "", "", xerrors.Errorf("fetch move error (storage %s) %s -> %s: %w", info.ID, tempDest, dest, err)
}
if merr != nil { if merr != nil {
log.Warnw("acquireFromRemote encountered errors when fetching sector from remote", "errors", merr) log.Warnw("acquireFromRemote encountered errors when fetching sector from remote", "errors", merr)
} }