Skip to content

Commit 5c84843

Browse files
committed
[PDR-13294][fix(disk)]修复temp文件遇到error退出时不会删除的问题
1 parent d60f1b5 commit 5c84843

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)