.

wcfs/wcfs.go

@@ -1550,14 +1550,13 @@ func (f *BigFile) readPinWatchers(ctx context.Context, blk int64, blkrevMax zodb
 		// and most of them would be on different w.at - cache of the file will
 		// be lost. Via pinning to particular block revision, we make sure the
 		// revision to pin is the same on all clients, and so file cache is shared.
-		pinrev, _, err := δFtail.BlkRevAt(ctx, f.zfile, blk, w.at) // XXX move into go?
-		if err != nil {
-			return err
-		}
-
-		//fmt.Printf("S: read #%d: watch @%s: pin -> @%s\n", blk, w.at, pinrev)
 		wg.Go(func(ctx context.Context) error {
 			defer w.atMu.RUnlock()
+			pinrev, _, err := δFtail.BlkRevAt(ctx, f.zfile, blk, w.at)
+			if err != nil {
+				return err
+			}
+			//fmt.Printf("S: read #%d: watch @%s: pin -> @%s\n", blk, w.at, pinrev)
 			// XXX close watcher on any error
 			return w.pin(ctx, blk, pinrev)
 		})