github/distribution
1
0
Fork 0
mirror of https://github.com/distribution/distribution.git synced 2025-08-21 16:24:00 +00:00
Code Issues Projects Releases Wiki Activity

Replaced usage of storagedriver.Walk with storagedriver.WalkFiles for linked/blobstore

Browse Source
This commit is contained in:
Collin Shoop 2021-06-24 14:48:20 -04:00
parent f31195b2e8
commit c83e9ae10a
2 changed files with 2 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
registry/storage/blobstore.go
View File

@ -93,12 +93,7 @@ func (bs *blobStore) Enumerate(ctx context.Context, ingester func(dgst digest.Di
return err return err
} }
return bs.driver.Walk(ctx, specPath, func(fileInfo driver.FileInfo) error { return bs.driver.WalkFiles(ctx, specPath, func(fileInfo driver.FileInfo) error {
// skip directories
if fileInfo.IsDir() {
return nil
}
currentPath := fileInfo.Path() currentPath := fileInfo.Path()
// we only want to parse paths that end with /data // we only want to parse paths that end with /data
_, fileName := path.Split(currentPath) _, fileName := path.Split(currentPath)

6
registry/storage/linkedblobstore.go
View File

@ -247,11 +247,7 @@ func (lbs *linkedBlobStore) Enumerate(ctx context.Context, ingestor func(digest.
if err != nil { if err != nil {
return err return err
} }
return lbs.driver.Walk(ctx, rootPath, func(fileInfo driver.FileInfo) error { return lbs.driver.WalkFiles(ctx, rootPath, func(fileInfo driver.FileInfo) error {
// exit early if directory...
if fileInfo.IsDir() {
return nil
}
filePath := fileInfo.Path() filePath := fileInfo.Path()
// check if it's a link // check if it's a link