vbatts/registry
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Stop ErrFinishedWalk from escaping from Repositories walk

Browse source 
Signed-off-by: Edgar Lee <edgar.lee@docker.com>
This commit is contained in:
Edgar Lee 2016-08-05 17:21:48 -07:00 committed by Richard Scothern
parent 0567fa3c2a
commit fdc51bb1f2
1 changed files with 12 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
registry/storage/catalog.go
View file

@ -10,11 +10,6 @@ import (
"github.com/docker/distribution/registry/storage/driver" "github.com/docker/distribution/registry/storage/driver"
) )
// ErrFinishedWalk is used when the called walk function no longer wants
// to accept any more values. This is used for pagination when the
// required number of repos have been found.
var ErrFinishedWalk = errors.New("finished walk")
// Returns a list, or partial list, of repositories in the registry. // Returns a list, or partial list, of repositories in the registry.
// Because it's a quite expensive operation, it should only be used when building up // Because it's a quite expensive operation, it should only be used when building up
// an initial set of repositories. // an initial set of repositories.
@ -30,6 +25,10 @@ func (reg *registry) Repositories(ctx context.Context, repos []string, last stri
return 0, err return 0, err
} }
// errFinishedWalk signals an early exit to the walk when the current query
// is satisfied.
errFinishedWalk := errors.New("finished walk")
err = Walk(ctx, reg.blobStore.driver, root, func(fileInfo driver.FileInfo) error { err = Walk(ctx, reg.blobStore.driver, root, func(fileInfo driver.FileInfo) error {
filePath := fileInfo.Path() filePath := fileInfo.Path()
@ -49,7 +48,7 @@ func (reg *registry) Repositories(ctx context.Context, repos []string, last stri
// if we've filled our array, no need to walk any further // if we've filled our array, no need to walk any further
if len(foundRepos) == len(repos) { if len(foundRepos) == len(repos) {
return ErrFinishedWalk return errFinishedWalk
} }
return nil return nil
@ -57,9 +56,14 @@ func (reg *registry) Repositories(ctx context.Context, repos []string, last stri
n = copy(repos, foundRepos) n = copy(repos, foundRepos)
// Signal that we have no more entries by setting EOF switch err {
if len(foundRepos) <= len(repos) && (err == nil || err == ErrSkipDir) { case nil:
// nil means that we completed walk and didn't fill buffer. No more
// records are available.
err = io.EOF err = io.EOF
case errFinishedWalk:
// more records are available.
err = nil
} }
return n, err return n, err