Skip to content

Commit

Permalink
UPSTREAM distribution/distribution: 4485: avoid appending directory a…
Browse files Browse the repository at this point in the history
…s file path in s3 driver Walk

when a directory is empty, the s3 api lists it with a trailing slash.
this causes the path to be appended twice to the walkInfo slice, causing
purge uploads path transformations to panic when the `_uploads` is
emtpy.

this adds a check for file paths ending on slash, and do not append
those as regular files to the walkInfo slice.

fixes distribution#4358

Signed-off-by: Flavian Missi <fmissi@redhat.com>
  • Loading branch information
flavianmissi committed Oct 18, 2024
1 parent 2799294 commit 46744fd
Showing 1 changed file with 10 additions and 2 deletions.
12 changes: 10 additions & 2 deletions registry/storage/driver/s3-aws/s3.go
Original file line number Diff line number Diff line change
Expand Up @@ -1153,6 +1153,16 @@ func (d *driver) doWalk(parentCtx context.Context, objectCount *int64, path, pre
}
}

// in some cases the _uploads dir might be empty. when this happens, it would
// be appended twice to the walkInfos slice, once as [...]/_uploads and
// once more erroneously as [...]/_uploads/. the easiest way to avoid this is
// to skip appending filePath to walkInfos if it ends in "/". the loop through
// dirs will already have handled it in that case, so it's safe to continue this
// loop.
if strings.HasSuffix(filePath, "/") {
continue
}

walkInfos = append(walkInfos, storagedriver.FileInfoInternal{
FileInfoFields: storagedriver.FileInfoFields{
IsDir: false,
Expand Down Expand Up @@ -1427,8 +1437,6 @@ func (w *writer) Size() int64 {
return w.size
}

// Close flushes any remaining data in the buffer and releases the buffer back
// to the pool.
func (w *writer) Close() error {
if w.closed {
return fmt.Errorf("already closed")
Expand Down

0 comments on commit 46744fd

Please sign in to comment.