Commit 131662a9 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent aae77bfe
...@@ -1220,13 +1220,15 @@ func (f *BigFile) updateWatchers(ctx context.Context, blk int64, treepath []btre ...@@ -1220,13 +1220,15 @@ func (f *BigFile) updateWatchers(ctx context.Context, blk int64, treepath []btre
blkrev := blkrevMax blkrev := blkrevMax
blkrevRough := true blkrevRough := true
// XXX locking (f.watches)
wg, ctx := errgroup.WithContext(ctx) wg, ctx := errgroup.WithContext(ctx)
for w := range f.watches { for w := range f.watches {
w := w w := w
fmt.Printf("S: read -> update watchers: w @%s\n", w.at) fmt.Printf("S: read -> update watchers: w @%s\n", w.at)
// XXX locking // XXX locking (w)
// the block is already covered by @w.at database view // the block is already covered by @w.at database view
if blkrev <= w.at { if blkrev <= w.at {
......
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