This commit is contained in:
Michael Yang 2023-10-03 17:06:13 -07:00
parent 10199c5987
commit 0560b28a8d

View file

@ -308,17 +308,17 @@ func downloadBlob(ctx context.Context, opts downloadOpts) error {
return nil return nil
} }
value, ok := blobDownloadManager.LoadOrStore(opts.digest, &blobDownload{Name: fp, Digest: opts.digest}) data, ok := blobDownloadManager.LoadOrStore(opts.digest, &blobDownload{Name: fp, Digest: opts.digest})
blobDownload := value.(*blobDownload) download := data.(*blobDownload)
if !ok { if !ok {
requestURL := opts.mp.BaseURL() requestURL := opts.mp.BaseURL()
requestURL = requestURL.JoinPath("v2", opts.mp.GetNamespaceRepository(), "blobs", opts.digest) requestURL = requestURL.JoinPath("v2", opts.mp.GetNamespaceRepository(), "blobs", opts.digest)
if err := blobDownload.Prepare(ctx, requestURL, opts.regOpts); err != nil { if err := download.Prepare(ctx, requestURL, opts.regOpts); err != nil {
return err return err
} }
go blobDownload.Run(context.Background(), requestURL, opts.regOpts) go download.Run(context.Background(), requestURL, opts.regOpts)
} }
return blobDownload.Wait(ctx, opts.fn) return download.Wait(ctx, opts.fn)
} }