Commit 38b20311 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 10470536
...@@ -1412,7 +1412,7 @@ func (w *Watch) _pin(ctx context.Context, blk int64, rev zodb.Tid) (err error) { ...@@ -1412,7 +1412,7 @@ func (w *Watch) _pin(ctx context.Context, blk int64, rev zodb.Tid) (err error) {
} }
w.pinnedMu.Unlock() w.pinnedMu.Unlock()
<-blkpin.ready // XXX + ctx ? (or just keep ready ?) <-blkpin.ready // TODO +ctx cancel
if blkpin.rev == rev { if blkpin.rev == rev {
// already pinned // already pinned
...@@ -1701,7 +1701,7 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T ...@@ -1701,7 +1701,7 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T
// wcfs tests also verify that only blocks that were previously // wcfs tests also verify that only blocks that were previously
// explicitly accessed are included into watch setup pins. // explicitly accessed are included into watch setup pins.
OnlyExplicitlyTracked: true, OnlyExplicitlyTracked: true,
}) // XXX locking δFtail })
if err != nil { if err != nil {
panic(err) // XXX panic(err) // XXX
} }
......
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