mvcc/backend: remove db.tmp regardless of logger presence
parent
84ace97ad7
commit
7e0e6bf497
|
@ -240,13 +240,11 @@ func checkSuffix(lg *zap.Logger, names []string) []string {
|
||||||
func (s *Snapshotter) cleanupSnapdir(filenames []string) error {
|
func (s *Snapshotter) cleanupSnapdir(filenames []string) error {
|
||||||
for _, filename := range filenames {
|
for _, filename := range filenames {
|
||||||
if strings.HasPrefix(filename, "db.tmp") {
|
if strings.HasPrefix(filename, "db.tmp") {
|
||||||
if s.lg != nil {
|
|
||||||
s.lg.Info("found orphaned defragmentation file; deleting", zap.String("path", filename))
|
s.lg.Info("found orphaned defragmentation file; deleting", zap.String("path", filename))
|
||||||
if rmErr := os.Remove(filepath.Join(s.dir, filename)); rmErr != nil && !os.IsNotExist(rmErr) {
|
if rmErr := os.Remove(filepath.Join(s.dir, filename)); rmErr != nil && !os.IsNotExist(rmErr) {
|
||||||
return fmt.Errorf("failed to remove orphaned defragmentation file %s: %v", filename, rmErr)
|
return fmt.Errorf("failed to remove orphaned defragmentation file %s: %v", filename, rmErr)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue