aboutsummaryrefslogtreecommitdiff
path: root/refstore/files/transaction_write_loose.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-23 03:25:44 +0000
committerGravatar Runxi Yu2026-03-23 03:27:52 +0000
commit4a796e64ac576d6a3e3f2fe6174c4aa476ea0c5c (patch)
tree44d72a20076ceab0981d0b553693d26ca36cc0be /refstore/files/transaction_write_loose.go
parentreceivepack: Lifecycle/ownership docs (diff)
refstore: Improve interfaces, errors, and make batch work v0.1.92
Diffstat (limited to 'refstore/files/transaction_write_loose.go')
-rw-r--r--refstore/files/transaction_write_loose.go59
1 files changed, 0 insertions, 59 deletions
diff --git a/refstore/files/transaction_write_loose.go b/refstore/files/transaction_write_loose.go
deleted file mode 100644
index b2a0e5d6..00000000
--- a/refstore/files/transaction_write_loose.go
+++ /dev/null
@@ -1,59 +0,0 @@
-package files
-
-import (
- "fmt"
- "os"
- "path"
- "strings"
-)
-
-func (tx *Transaction) writeLoose(item preparedTxOp) error {
- root := tx.store.rootFor(item.target.loc.root)
- lockName := item.target.loc.path + ".lock"
-
- lock, err := root.OpenFile(lockName, os.O_WRONLY|os.O_TRUNC, 0o644)
- if err != nil {
- return err
- }
-
- var content string
-
- switch item.op.kind {
- case txCreate, txUpdate:
- content = item.op.newID.String() + "\n"
- case txCreateSymbolic, txUpdateSymbolic:
- content = "ref: " + strings.TrimSpace(item.op.newTarget) + "\n"
- case txDelete, txVerify, txDeleteSymbolic, txVerifySymbolic:
- default:
- _ = lock.Close()
-
- return fmt.Errorf("refstore/files: unsupported write operation %d", item.op.kind)
- }
-
- _, err = lock.WriteString(content)
- if err != nil {
- _ = lock.Close()
-
- return err
- }
-
- err = lock.Close()
- if err != nil {
- return err
- }
-
- dir := path.Dir(item.target.loc.path)
- if dir != "." {
- err = root.MkdirAll(dir, 0o755)
- if err != nil {
- return err
- }
- }
-
- err = tx.removeEmptyDirTree(item.target.loc)
- if err != nil {
- return err
- }
-
- return root.Rename(lockName, item.target.loc.path)
-}