Commit 05be8f76 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 71c9ff72
...@@ -120,7 +120,7 @@ func (d *Storage) watcher(ctx context.Context) error { ...@@ -120,7 +120,7 @@ func (d *Storage) watcher(ctx context.Context) error {
d.shutdown(edown) d.shutdown(edown)
ev := &zodb.EventError{edown} // XXX + context ev := &zodb.EventError{edown} // XXX + context
if d.watchq != nil { if d.watchq != nil {
d.watchq <- ev d.watchq <- ev // XXX + select on close ?
} }
return edown return edown
...@@ -133,7 +133,7 @@ func (d *Storage) watcher(ctx context.Context) error { ...@@ -133,7 +133,7 @@ func (d *Storage) watcher(ctx context.Context) error {
} }
// XXX +select on close // XXX +select on close
d.watchq <- event // !nil becase d.δWatchq != nil d.watchq <- event // !nil because d.δWatchq != nil
} }
} }
} }
......
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