mirror of https://github.com/restic/restic.git
cache: fix race condition in cache cleanup
Fix multiple restic processes executing concurrently and racing to remove obsolete snapshots. Co-authored-by: Michael Eischer <michael.eischer@fau.de>
This commit is contained in:
parent
c1532179d4
commit
4795143d6d
|
@ -0,0 +1,7 @@
|
||||||
|
Bugfix: Fix possible error on concurrent cache cleanup
|
||||||
|
|
||||||
|
Fix for multiple restic processes executing concurrently and racing to
|
||||||
|
remove obsolete snapshots from the local backend cache. Restic now suppresses the `no
|
||||||
|
such file or directory` error.
|
||||||
|
|
||||||
|
https://github.com/restic/restic/pull/5047
|
|
@ -210,6 +210,10 @@ func (c *Cache) list(t restic.FileType) (restic.IDSet, error) {
|
||||||
dir := filepath.Join(c.path, cacheLayoutPaths[t])
|
dir := filepath.Join(c.path, cacheLayoutPaths[t])
|
||||||
err := filepath.Walk(dir, func(name string, fi os.FileInfo, err error) error {
|
err := filepath.Walk(dir, func(name string, fi os.FileInfo, err error) error {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
// ignore ErrNotExist to gracefully handle multiple processes clearing the cache
|
||||||
|
if errors.Is(err, os.ErrNotExist) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
return errors.Wrap(err, "Walk")
|
return errors.Wrap(err, "Walk")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue