aboutsummaryrefslogtreecommitdiff
path: root/refstore/files/update_prepare_lock.go
diff options
context:
space:
mode:
Diffstat (limited to 'refstore/files/update_prepare_lock.go')
-rw-r--r--refstore/files/update_prepare_lock.go28
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
+}