refstore: Improve interfaces, errors, and make batch work v0.1.92

1 files changed, 25 insertions, 0 deletions

diff --git a/refstore/files/update_lock.go b/refstore/files/update_lock.go
new file mode 100644
index 00000000..1ce9adbb
--- /dev/null
+++ b/refstore/files/update_lock.go
@@ -0,0 +1,25 @@
+package files
+
+import (
+	"os"
+	"path"
+)
+
+func (executor *refUpdateExecutor) createUpdateLock(name refPath) error {
+	root := executor.store.rootFor(name.root)
+	dir := path.Dir(name.path)
+
+	if dir != "." {
+		err := root.MkdirAll(dir, 0o755)
+		if err != nil {
+			return err
+		}
+	}
+
+	file, err := root.OpenFile(name.path+".lock", os.O_WRONLY|os.O_CREATE|os.O_EXCL, 0o644)
+	if err != nil {
+		return err
+	}
+
+	return file.Close()
+}