.

wcfs/wcfs_test.py

@@ -894,6 +894,7 @@ def _pinAt(twlink, zf, at):  # -> pin = {} blk -> rev
 #
 # During setup it verifies that wcfs sends correct initial pins.
 #
+# pinok: {} blk -> rev
 # pinok can be None - in that case it is computed automatically.
 @func(tWatchLink)
 def watch(twlink, zf, at, pinok=None):   # XXX -> ?
@@ -1338,19 +1339,25 @@ def test_wcfs():
     f.assertBlk(5, 'f4', {wl3: {},                      wl3_: {}})
     w_assertPin(               {2:at3, 3:at2, 5:at0})
 
-    # XXX advance watch - receives new pins/unpins to @head
-    # XXX this is already tested ^^^ in at_i -> at_j -> ...
+    # advance watch - receives new pins/unpins to @head.
+    # this is also tested ^^^ in `at_i -> at_j -> ...` watch setup/adjust.
+    wl3.watch(zf, at4, {2:at4, 5:None})     # at3 -> at4
+    w_assertPin(       {2:at4, 3:at2})
+
+    wl3.watch(zf, at5, {2:None, 3:None})    # at4 -> at5
+    w_assertPin(       {})
 
     wl3.close()
 
+    # XXX access to block not previously accessed but invalidated in ZODB
+
 
     # XXX watch with @at > head - must wait for head to become >= at
-    # XXX access to block not previously accessed but invalidated in ZODB
     # XXX drop file[blk] from cache, access again -> no pin message sent the second time
 
-
     # XXX no reply to pin - killed
 
+
     # XXX blk not initially covered by f.δtail (blk never accessed - f.δtail
     # not updated on invalidation). then blk is accessed - what happens with
     # watch that should be triggerring for this blk?