aboutsummaryrefslogtreecommitdiff
path: root/refstore/files/update_cleanup.go
diff options
context:
space:
mode:
Diffstat (limited to 'refstore/files/update_cleanup.go')
-rw-r--r--refstore/files/update_cleanup.go39
1 files changed, 39 insertions, 0 deletions
diff --git a/refstore/files/update_cleanup.go b/refstore/files/update_cleanup.go
new file mode 100644
index 00000000..5df2d967
--- /dev/null
+++ b/refstore/files/update_cleanup.go
@@ -0,0 +1,39 @@
+package files
+
+import (
+ "errors"
+ "os"
+ "slices"
+)
+
+func (executor *refUpdateExecutor) cleanupPreparedUpdates(prepared []preparedUpdate) error {
+ var firstErr error
+
+ lockNames := make([]string, 0, len(prepared)+1)
+ for _, item := range prepared {
+ lockNames = append(lockNames, updateTargetKey(item.target.loc))
+ }
+
+ lockNames = append(lockNames, updateTargetKey(refPath{root: rootCommon, path: "packed-refs"}))
+ slices.Sort(lockNames)
+ lockNames = slices.Compact(lockNames)
+
+ for _, lockKey := range lockNames {
+ lockPath := refPathFromKey(lockKey)
+ lockName := lockPath.path + ".lock"
+ root := executor.store.rootFor(lockPath.root)
+
+ err := root.Remove(lockName)
+ if err == nil || errors.Is(err, os.ErrNotExist) {
+ executor.tryRemoveEmptyParentPaths(lockPath.root, lockName)
+
+ continue
+ }
+
+ if firstErr == nil {
+ firstErr = err
+ }
+ }
+
+ return firstErr
+}