.

wcfs/wcfs.go

@@ -1513,7 +1513,9 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T
 	w := wlink.byfile[foid]	// XXX locking
 	if w == nil {
 		// watch was not previously established - set it up anew
-		f := bfdir.fileTab[foid]	// XXX locking
+		bfdir.fileMu.Lock()
+		f := bfdir.fileTab[foid]
+		bfdir.fileMu.Unlock()
 		if f == nil {
 			// by "invalidation protocol" watch is setup after data file was opened
 			return fmt.Errorf("file not yet known to wcfs or is not a ZBigFile")