Skip to content

Commit

Permalink
change mtx orders
Browse files Browse the repository at this point in the history
  • Loading branch information
go-to-k committed Apr 13, 2024
1 parent c9630c8 commit 996c5d3
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions internal/wrapper/s3_wrapper.go
Original file line number Diff line number Diff line change
Expand Up @@ -92,6 +92,12 @@ func (s *S3Wrapper) ClearS3Objects(
if err != nil {
return err
}

deletedVersionsCountMtx.Lock()
deletedVersionsCount += len(versions)
fmt.Fprintf(writer, "Clearing... %d objects\n", deletedVersionsCount)
deletedVersionsCountMtx.Unlock()

if len(gotErrors) > 0 {
errorsMtx.Lock()
for _, error := range gotErrors {
Expand All @@ -103,11 +109,6 @@ func (s *S3Wrapper) ClearS3Objects(
errorsMtx.Unlock()
}

deletedVersionsCountMtx.Lock()
deletedVersionsCount += len(versions)
fmt.Fprintf(writer, "Clearing... %d objects\n", deletedVersionsCount)
deletedVersionsCountMtx.Unlock()

return nil
})

Expand Down

0 comments on commit 996c5d3

Please sign in to comment.