Commit 71c9ff72 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent eb2642fd
...@@ -160,8 +160,10 @@ func (d *Storage) Close() (err error) { ...@@ -160,8 +160,10 @@ func (d *Storage) Close() (err error) {
errδ := d.δ.Close() errδ := d.δ.Close()
errBase := d.base.Close() errBase := d.base.Close()
// cancel watcher. don't propagate its error to Close - watcher error
// goes to watchq and op errors.
d.watchCancel() d.watchCancel()
_ = d.watchWG.Wait() // ignore error - it goes to watchq and op errors _ = d.watchWG.Wait()
return xerr.Merge(errδ, errBase) return xerr.Merge(errδ, errBase)
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment