mirror of
https://github.com/pgsty/minio.git
synced 2026-07-23 22:16:15 +03:00
fix: track object and bucket for exipreAll (#21241)
This commit is contained in:
@@ -997,7 +997,16 @@ func (ri *batchJobInfo) updateAfter(ctx context.Context, api ObjectLayer, durati
|
|||||||
// a single action. e.g batch-expire has an option to expire all versions of an
|
// a single action. e.g batch-expire has an option to expire all versions of an
|
||||||
// object which matches the given filters.
|
// object which matches the given filters.
|
||||||
func (ri *batchJobInfo) trackMultipleObjectVersions(info expireObjInfo, success bool) {
|
func (ri *batchJobInfo) trackMultipleObjectVersions(info expireObjInfo, success bool) {
|
||||||
|
if ri == nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
ri.mu.Lock()
|
||||||
|
defer ri.mu.Unlock()
|
||||||
|
|
||||||
if success {
|
if success {
|
||||||
|
ri.Bucket = info.Bucket
|
||||||
|
ri.Object = info.Name
|
||||||
ri.Objects += int64(info.NumVersions) - info.DeleteMarkerCount
|
ri.Objects += int64(info.NumVersions) - info.DeleteMarkerCount
|
||||||
ri.DeleteMarkers += info.DeleteMarkerCount
|
ri.DeleteMarkers += info.DeleteMarkerCount
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Reference in New Issue
Block a user