diff --git a/compact.go b/compact.go index ca646a084..7799b640f 100644 --- a/compact.go +++ b/compact.go @@ -300,6 +300,8 @@ func (c *compactor) write(uid ulid.ULID, blocks ...Block) (err error) { if err != nil { return errors.Wrap(err, "sync block dir") } + defer df.Close() + if err := fileutil.Fsync(df); err != nil { return errors.Wrap(err, "sync block dir") } @@ -583,6 +585,8 @@ func renameFile(from, to string) error { if err != nil { return err } + defer pdir.Close() + if err = fileutil.Fsync(pdir); err != nil { return err } diff --git a/db.go b/db.go index fe35a348d..e0e8ff173 100644 --- a/db.go +++ b/db.go @@ -386,6 +386,8 @@ func retentionCutoff(dir string, mint int64) (bool, error) { if err != nil { return false, errors.Wrapf(err, "open directory") } + defer df.Close() + dirs, err := blockDirs(dir) if err != nil { return false, errors.Wrapf(err, "list block dirs %s", dir)