fix replication healing on list to consider all versions (#16496)

This commit is contained in:
Poorna 2023-01-27 12:43:28 -08:00 committed by GitHub
parent 820d94447c
commit eaa65b7ade
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -377,10 +377,15 @@ func applyBucketActions(ctx context.Context, o listPathOptions, in <-chan metaCa
case <-ctx.Done():
return
case out <- obj:
if fiv, err := obj.fileInfoVersions(o.Bucket); err == nil {
for _, version := range fiv.Versions {
objInfo := version.ToObjectInfo(o.Bucket, obj.name, versioned)
queueReplicationHeal(ctx, o.Bucket, objInfo, o.Replication)
}
}
}
}
}
func (z *erasureServerPools) listAndSave(ctx context.Context, o *listPathOptions) (entries metaCacheEntriesSorted, err error) {
// Use ID as the object name...