Commit 52e73d14 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 6ce6b134
......@@ -1382,7 +1382,8 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T
// XXX locking
// pin all tracked file blocks that were changed (at, head] range
for _, δfile := range f.δtail.SliceByRev(at, head.zconn.At()) {
fhead := tidmin(f.δtail.Head(), head.zconn.At())
for _, δfile := range f.δtail.SliceByRev(at, fhead) {
for _, blk := range δfile.Changev {
_, already := toPin[blk]
if already {
......
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