mirror/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-06-07 17:43:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge c004d8b907 into ea70d17c5f

Browse Source
This commit is contained in:
Konstantin Lebedev 2025-05-25 20:57:20 +08:00 committed by GitHub
commit 0a7bc7335e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
weed/storage/volume_vacuum.go
View File

@ -161,11 +161,18 @@ func (v *Volume) CommitCompact() error {
}
}
var e error
if e = os.Rename(v.FileName(".cpd"), v.FileName(".dat")); e != nil {
return fmt.Errorf("rename %s: %v", v.FileName(".cpd"), e)
cpdFile := v.FileName(".cpd")
if _, err := os.Stat(cpdFile); err == nil {
if e = os.Rename(cpdFile, v.FileName(".dat")); e != nil {
return fmt.Errorf("rename %s: %v", v.FileName(".cpd"), e)
}
}
if e = os.Rename(v.FileName(".cpx"), v.FileName(".idx")); e != nil {
return fmt.Errorf("rename %s: %v", v.FileName(".cpx"), e)
cpxFile := v.FileName(".cpx")
if _, err := os.Stat(cpdFile); err == nil {
if e = os.Rename(cpxFile, v.FileName(".idx")); e != nil {
return fmt.Errorf("rename %s: %v", v.FileName(".cpx"), e)
}
}
}