Skip to content

Commit 6911d16

Browse files
author
liukai2012
authored
Merge pull request #1154 from PapaPiya/fix_backup
[PDR-13294][fix(disk)]修复temp文件遇到error退出时不会删除的问题
2 parents 8c249fe + 5c84843 commit 6911d16

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

queue/disk.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -559,6 +559,12 @@ func (d *diskQueue) persistMetaData() error {
559559
return err
560560
}
561561

562+
defer func() {
563+
if err := os.RemoveAll(tmpFileName); err != nil {
564+
log.Errorf("DISKQUEUE(%s): remove temp file %s failed, error: %v", d.name, tmpFileName, err)
565+
}
566+
}()
567+
562568
_, err = fmt.Fprintf(f, "%d\n%d,%d\n%d,%d\n",
563569
atomic.LoadInt64(&d.depth),
564570
d.readFileNum, d.readPos,

0 commit comments

Comments
 (0)