Skip to content

Commit

Permalink
Linter fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
aduffeck committed Jul 25, 2023
1 parent aceb543 commit 6283948
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/storage/utils/decomposedfs/tree/propagator/async.go
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ func NewAsyncPropagator(treeSizeAccounting, treeTimeAccounting bool, lookup look
if err != nil {
return
}
changesDirPath = changesDirPath + ".processing"
changesDirPath += ".processing"
}

log.Debug().Str("dir", changesDirPath).Msg("propagating stale .processing dir")
Expand Down Expand Up @@ -164,7 +164,7 @@ func (p AsyncPropagator) queuePropagation(ctx context.Context, spaceID, nodeID s
_ = os.MkdirAll(filepath.Dir(filepath.Dir(changePath)), 0700)
err = os.Mkdir(filepath.Dir(changePath), 0700)
triggerPropagation = err == nil || os.IsExist(err) // only the first goroutine, which succeeds to create the directory, is supposed to actually trigger the propagation
for retries := 0; retries <= 500; retries += 1 {
for retries := 0; retries <= 500; retries++ {
err := renameio.WriteFile(changePath, data, 0644)
if err == nil {
ready = true
Expand Down

0 comments on commit 6283948

Please sign in to comment.