safesight/edge/agent/internal/files/atomic.go
tian 29d9ef5d0d refactor: 项目结构梳理 - 设备端/管理端对称布局
仓库结构:
  edge/     设备端(原根目录设备端代码整体移入)
  control/  管理端(清理后)
  docs/     文档(PRD 移入 design/)
  README.md 根导航(新增)

清理:
- control/.brainstorm 临时草稿删除
- control 根级重复文档(API表/PRD_04)并入 docs/design/
- control/plan.md -> docs/implementation/control-plan.md
- control/safesightd-linux-arm64 二进制取消版本控制(.gitignore)
- edge/transform 模型转换产物归入 models/,onnx/pt 大源文件取消跟踪(.gitignore)
- Readme.md(PRD) -> docs/design/PRD_Product_v1.2.md(避开 README 大小写冲突)

更新:
- 根 README.md 导航、docs/README.md 文档索引
- deployment.md/检查表路径加 edge/ 前缀
- .gitignore 重写(edge/control 分区规则)
2026-08-02 11:39:54 +08:00

68 lines
1.4 KiB
Go

package files
import (
"fmt"
"os"
"path/filepath"
"runtime"
)
func EnsureDir(path string, perm os.FileMode) error {
if err := os.MkdirAll(path, perm); err != nil {
return fmt.Errorf("mkdir %s: %w", path, err)
}
return nil
}
func WriteFileAtomic(path string, data []byte, perm os.FileMode) error {
dir := filepath.Dir(path)
if err := EnsureDir(dir, 0o755); err != nil {
return err
}
f, err := os.CreateTemp(dir, ".tmp-*")
if err != nil {
return fmt.Errorf("create temp: %w", err)
}
tmp := f.Name()
ok := false
defer func() {
_ = f.Close()
if !ok {
_ = os.Remove(tmp)
}
}()
if _, err := f.Write(data); err != nil {
return fmt.Errorf("write temp: %w", err)
}
if err := f.Chmod(perm); err != nil {
return fmt.Errorf("chmod temp: %w", err)
}
if err := f.Sync(); err != nil {
return fmt.Errorf("fsync temp: %w", err)
}
if err := f.Close(); err != nil {
return fmt.Errorf("close temp: %w", err)
}
if err := ReplaceFile(tmp, path); err != nil {
return err
}
ok = true
return nil
}
func ReplaceFile(tmpPath, dstPath string) error {
if err := os.Rename(tmpPath, dstPath); err == nil {
return nil
} else if runtime.GOOS == "windows" {
_ = os.Remove(dstPath)
if err2 := os.Rename(tmpPath, dstPath); err2 != nil {
return fmt.Errorf("rename %s -> %s: %w", tmpPath, dstPath, err2)
}
return nil
} else {
return fmt.Errorf("rename %s -> %s: %w", tmpPath, dstPath, err)
}
}