.

wcfs/wcfs_test.py

@@ -683,6 +683,10 @@ def watch(w, zf, at):   # XXX -> ?
 
     # send watch request and check that we receive pins for in-cache blocks
     # changed > at. Use timeout to detect wcfs replying less pins than expected.
+    #
+    # XXX detect not sent pins with timeout, or better via ack'ing previous
+    # pins as they come in (not waiting for all of them) and then seeing that
+    # we did not received expeced pin when wcfs sends final ok?
     ctx, cancel = context.with_timeout(context.background(), 3*time.second)
     wg = sync.WorkGroup(ctx)