Commit c42f0040 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 3526986d
...@@ -1522,7 +1522,7 @@ func (f *BigFile) readPinWatchers(ctx context.Context, blk int64, treepath []btr ...@@ -1522,7 +1522,7 @@ func (f *BigFile) readPinWatchers(ctx context.Context, blk int64, treepath []btr
// revision to pin is the same on all clients, and so file cache is shared. // revision to pin is the same on all clients, and so file cache is shared.
pinrev, _ := w.file.LastBlkRev(ctx, blk, w.at) // XXX move into go? pinrev, _ := w.file.LastBlkRev(ctx, blk, w.at) // XXX move into go?
fmt.Printf("S: read #%d: watch @%s: pin -> @%s\n", blk, w.at, pinrev) //fmt.Printf("S: read #%d: watch @%s: pin -> @%s\n", blk, w.at, pinrev)
wg.Go(func() error { wg.Go(func() error {
defer w.atMu.RUnlock() defer w.atMu.RUnlock()
// XXX close watcher on any error // XXX close watcher on any error
......
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