octoleo/restic
2
2
Fork 0
mirror of https://github.com/octoleo/restic.git synced 2024-12-27 12:42:49 +00:00
Code Issues Releases Wiki Activity

Close backend files in case of errors

Browse Source
This commit is contained in:
Alexander Neumann 2018-01-25 21:05:57 +01:00
parent d62a664bb7
commit 909d9273cc
3 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/cache/backend.go vendored
View File

@ -127,6 +127,7 @@ func (b *Backend) cacheFile(ctx context.Context, h restic.Handle) error {
} }
if err = b.Cache.Save(h, rd); err != nil { if err = b.Cache.Save(h, rd); err != nil {
_ = rd.Close()
return err return err
} }

2
internal/checker/checker.go
View File

@ -637,6 +637,7 @@ func checkPack(ctx context.Context, r restic.Repository, id restic.ID) error {
packfile, err := fs.TempFile("", "restic-temp-check-") packfile, err := fs.TempFile("", "restic-temp-check-")
if err != nil { if err != nil {
_ = rd.Close()
return errors.Wrap(err, "TempFile") return errors.Wrap(err, "TempFile")
} }
@ -648,6 +649,7 @@ func checkPack(ctx context.Context, r restic.Repository, id restic.ID) error {
hrd := hashing.NewReader(rd, sha256.New()) hrd := hashing.NewReader(rd, sha256.New())
size, err := io.Copy(packfile, hrd) size, err := io.Copy(packfile, hrd)
if err != nil { if err != nil {
_ = rd.Close()
return errors.Wrap(err, "Copy") return errors.Wrap(err, "Copy")
} }

1
internal/repository/repack.go
View File

@ -40,6 +40,7 @@ func Repack(ctx context.Context, repo restic.Repository, packs restic.IDSet, kee
hrd := hashing.NewReader(beRd, sha256.New()) hrd := hashing.NewReader(beRd, sha256.New())
packLength, err := io.Copy(tempfile, hrd) packLength, err := io.Copy(tempfile, hrd)
if err != nil { if err != nil {
_ = beRd.Close()
return nil, errors.Wrap(err, "Copy") return nil, errors.Wrap(err, "Copy")
} }