diff options
Diffstat (limited to 'ref/store/files/update_prepare_lock.go')
| -rw-r--r-- | ref/store/files/update_prepare_lock.go | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/ref/store/files/update_prepare_lock.go b/ref/store/files/update_prepare_lock.go new file mode 100644 index 00000000..67db9628 --- /dev/null +++ b/ref/store/files/update_prepare_lock.go @@ -0,0 +1,29 @@ +package files + +import "slices" + +func (executor *refUpdateExecutor) prepareUpdateLocks(prepared []preparedUpdate) error { + lockNames := make([]string, 0, len(prepared)) + for _, item := range prepared { + lockNames = append(lockNames, updateTargetKey(item.target.loc)) + } + + slices.Sort(lockNames) + + for _, lockKey := range lockNames { + lockPath := refPathFromKey(lockKey) + + err := executor.createUpdateLock(lockPath) + if err != nil { + for _, item := range prepared { + if updateTargetKey(item.target.loc) == lockKey { + return wrapUpdateError(item.op.name, err) + } + } + + return err + } + } + + return nil +} |
