.

wcfs/wcfs.go

@@ -1754,7 +1754,7 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T
 	}
 
 	// downgrade atMu.W -> atMu.R to let other clients to access the file.
-	// XXX there is no primitive to do Wlock->Rlock atomically, but we are
+	// NOTE there is no primitive to do Wlock->Rlock atomically, but we are
 	// ok with that since we prepared everything to handle simultaneous pins
 	// from other reads.
 	w.atMu.Unlock()
@@ -1817,7 +1817,7 @@ func (wlink *WatchLink) serve() {
 func (wlink *WatchLink) _serve() (err error) {
 	defer xerr.Contextf(&err, "wlink %d: serve rx", wlink.id)
 
-	ctx0 := context.TODO()	// XXX ctx = ? -> merge(ctx of wcfs running, ctx of wlink timeout)
+	ctx0 := context.TODO() // TODO ctx = merge(ctx of wcfs running, ctx of wlink timeout)
 
 	ctx, cancel := context.WithCancel(ctx0)
 	wg := xsync.NewWorkGroup(ctx)