diff options
Diffstat (limited to 'refstore/files/update_prepare_lock.go')
| -rw-r--r-- | refstore/files/update_prepare_lock.go | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/refstore/files/update_prepare_lock.go b/refstore/files/update_prepare_lock.go new file mode 100644 index 00000000..d958fc0a --- /dev/null +++ b/refstore/files/update_prepare_lock.go @@ -0,0 +1,28 @@ +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 +} |
