aboutsummaryrefslogtreecommitdiff
path: root/objectstore/loose/write_temp_object_file.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-04 12:53:00 +0800
committerGravatar Runxi Yu2026-03-04 12:53:00 +0800
commitb90b167cfbce785088c5236960515bc460e062d8 (patch)
treebcec9ce9f7fe4a63b546c0433002017d05f6a5be /objectstore/loose/write_temp_object_file.go
parentrefstore/chain: Split (diff)
signatureNo signature
objectstore/loose: Split
Diffstat (limited to 'objectstore/loose/write_temp_object_file.go')
-rw-r--r--objectstore/loose/write_temp_object_file.go30
1 files changed, 30 insertions, 0 deletions
diff --git a/objectstore/loose/write_temp_object_file.go b/objectstore/loose/write_temp_object_file.go
new file mode 100644
index 00000000..1a78db48
--- /dev/null
+++ b/objectstore/loose/write_temp_object_file.go
@@ -0,0 +1,30 @@
+package loose
+
+import (
+ "crypto/rand"
+ "errors"
+ "io/fs"
+ "os"
+ "path/filepath"
+)
+
+// createTempObjectFile creates a unique temporary object file within dir.
+// The returned path is relative to the objects root.
+func (store *Store) createTempObjectFile(dir string) (string, *os.File, error) {
+ for range 16 {
+ relPath := filepath.Join(dir, tempObjectFilePrefix+rand.Text())
+
+ file, err := store.root.OpenFile(relPath, os.O_CREATE|os.O_EXCL|os.O_WRONLY, 0o644)
+ if err == nil {
+ return relPath, file, nil
+ }
+
+ if errors.Is(err, fs.ErrExist) {
+ continue
+ }
+
+ return "", nil, err
+ }
+
+ return "", nil, errors.New("objectstore/loose: failed to create temporary object file")
+}