Commit 64d3132a authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent ca095828
...@@ -55,7 +55,7 @@ type DB struct { ...@@ -55,7 +55,7 @@ type DB struct {
δtail ΔTail // [](rev↑, []oid) δtail ΔTail // [](rev↑, []oid)
// openers waiting for δtail.Head to become covering their at. // openers waiting for δtail.Head to become covering their at.
δwait map[δwaiter]struct{} // set(at, ready) δwait map[δwaiter]struct{} // set{(at, ready)}
} }
// δwaiter represents someone waiting for δtail.Head to become ≥ at. // δwaiter represents someone waiting for δtail.Head to become ≥ at.
......
...@@ -205,6 +205,9 @@ func (s *storage) watcher() { ...@@ -205,6 +205,9 @@ func (s *storage) watcher() {
return return
} }
// XXX verify event.Tid ↑ (else e.g. δtail.Append will panic)
// if !↑ - stop the storage with error.
// deliver event to all watchers // deliver event to all watchers
for watchq := range s.watchTab { for watchq := range s.watchTab {
watchq <- event watchq <- event
......
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