diff options
| author | 2026-03-04 12:53:00 +0800 | |
|---|---|---|
| committer | 2026-03-04 12:53:00 +0800 | |
| commit | b90b167cfbce785088c5236960515bc460e062d8 (patch) | |
| tree | bcec9ce9f7fe4a63b546c0433002017d05f6a5be /objectstore/loose/write_temp_object_file.go | |
| parent | refstore/chain: Split (diff) | |
| signature | No signature | |
objectstore/loose: Split
Diffstat (limited to 'objectstore/loose/write_temp_object_file.go')
| -rw-r--r-- | objectstore/loose/write_temp_object_file.go | 30 |
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") +} |
