Commit 6f4c288b authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 193f7ae2
...@@ -1406,6 +1406,7 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T ...@@ -1406,6 +1406,7 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T
// XXX locking // XXX locking
// pin all tracked file blocks that were changed in (at, head] range // pin all tracked file blocks that were changed in (at, head] range
// XXX blk in w.pinned; blk not in δ -> unpin to head
f := w.file f := w.file
for _, δfile := range bfdir.δFtail.SliceByFileRev(f, at, headAt) { for _, δfile := range bfdir.δFtail.SliceByFileRev(f, at, headAt) {
for blk := range δfile.Blocks { for blk := range δfile.Blocks {
...@@ -1422,6 +1423,9 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T ...@@ -1422,6 +1423,9 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T
} }
} }
// XXX locking
w.at = at
wg, ctx := errgroup.WithContext(ctx) wg, ctx := errgroup.WithContext(ctx)
for blk, rev := range toPin { for blk, rev := range toPin {
blk := blk blk := blk
......
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