MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2024-12-24 22:25:54 -05:00
Code Issues Packages Projects Releases Wiki Activity

Update hourly tier-stats only on succesful tiering (#14330)

Browse Source
This commit is contained in:
Krishnan Parthasarathi 2022-02-16 17:29:12 -08:00 committed by GitHub
parent b88c57ba93
commit cdab4a3b85
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cmd/bucket-lifecycle.go
View File

@ -221,9 +221,7 @@ func (t *transitionState) worker(ctx context.Context, objectAPI ObjectLayer) {
var err error var err error
if tier, err = transitionObject(ctx, objectAPI, oi); err != nil { if tier, err = transitionObject(ctx, objectAPI, oi); err != nil {
logger.LogIf(ctx, fmt.Errorf("Transition failed for %s/%s version:%s with %w", oi.Bucket, oi.Name, oi.VersionID, err)) logger.LogIf(ctx, fmt.Errorf("Transition failed for %s/%s version:%s with %w", oi.Bucket, oi.Name, oi.VersionID, err))
} } else {
atomic.AddInt32(&t.activeTasks, -1)
ts := tierStats{ ts := tierStats{
TotalSize: uint64(oi.Size), TotalSize: uint64(oi.Size),
NumVersions: 1, NumVersions: 1,
@ -233,6 +231,9 @@ func (t *transitionState) worker(ctx context.Context, objectAPI ObjectLayer) {
} }
t.addLastDayStats(tier, ts) t.addLastDayStats(tier, ts)
} }
atomic.AddInt32(&t.activeTasks, -1)
}
} }
} }