Commit a059779e authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 5feee2b8
...@@ -139,8 +139,13 @@ func (d *Storage) Close() (err error) { ...@@ -139,8 +139,13 @@ func (d *Storage) Close() (err error) {
errδ := d.δ.Close() errδ := d.δ.Close()
errBase := d.base.Close() errBase := d.base.Close()
d.watchCancel() d.watchCancel()
errWatch := d.watchWG.Wait() errWatch := d.watchWG.Wait()
if errors.Is(errWatch, context.Canceled) { // we canceled it
errWatch = nil
}
return xerr.Merge(errWatch, errδ, errBase) return xerr.Merge(errWatch, 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