Skip to content

Commit

Permalink
Merge pull request #3119 from wy65701436/release/2.7-cp-2879
Browse files Browse the repository at this point in the history
[release/2.7] Fix s3 driver for supporting ceph radosgw
  • Loading branch information
dmcgowan committed Mar 11, 2020
2 parents bdf503a + e2f006a commit a45a401
Showing 1 changed file with 13 additions and 2 deletions.
15 changes: 13 additions & 2 deletions registry/storage/driver/s3-aws/s3.go
Expand Up @@ -970,8 +970,19 @@ func (d *driver) doWalk(parentCtx context.Context, objectCount *int64, path, pre
defer done("s3aws.ListObjectsV2Pages(%s)", path)
listObjectErr := d.S3.ListObjectsV2PagesWithContext(ctx, listObjectsInput, func(objects *s3.ListObjectsV2Output, lastPage bool) bool {

*objectCount += *objects.KeyCount
walkInfos := make([]walkInfoContainer, 0, *objects.KeyCount)
var count int64
// KeyCount was introduced with version 2 of the GET Bucket operation in S3.
// Some S3 implementations don't support V2 now, so we fall back to manual
// calculation of the key count if required
if objects.KeyCount != nil {
count = *objects.KeyCount
*objectCount += *objects.KeyCount
} else {
count = int64(len(objects.Contents) + len(objects.CommonPrefixes))
*objectCount += count
}

walkInfos := make([]walkInfoContainer, 0, count)

for _, dir := range objects.CommonPrefixes {
commonPrefix := *dir.Prefix
Expand Down

0 comments on commit a45a401

Please sign in to comment.