Commit ff6572aa authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 32f5f4a1
...@@ -117,7 +117,7 @@ func (d *Storage) watcher(ctx context.Context) error { ...@@ -117,7 +117,7 @@ func (d *Storage) watcher(ctx context.Context) error {
} }
d.shutdown(edown) d.shutdown(edown)
ev := &zodb.EventError{edown} // XXX + context ev := &zodb.EventError{&zodb.OpError{URL: d.URL(), Op: "watch", Err: edown}}
if d.watchq != nil { if d.watchq != nil {
d.watchq <- ev // XXX + select on close ? d.watchq <- ev // XXX + select on close ?
} }
......
...@@ -238,7 +238,7 @@ func TestWatchLoad_vs_BaseMutate(t *testing.T) { ...@@ -238,7 +238,7 @@ func TestWatchLoad_vs_BaseMutate(t *testing.T) {
baseAt0: 0, baseAt0: 0,
baseHead: tid, baseHead: tid,
} }
evErrOk := &zodb.EventError{Err: errBaseMutated} evErrOk := &zodb.EventError{&zodb.OpError{URL: ddrv.URL(), Op: "watch", Err: errBaseMutated}}
if !reflect.DeepEqual(evErr, evErrOk) { if !reflect.DeepEqual(evErr, evErrOk) {
t.Fatalf("after base mutate: unexpected event:\nhave: %s\nwant: %s", evErr, evErrOk) t.Fatalf("after base mutate: unexpected event:\nhave: %s\nwant: %s", evErr, evErrOk)
} }
......
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