.

wcfs/wcfs_test.py

@@ -961,9 +961,9 @@ def test_wcfs():
 
     print('\n\n\n\nWATCH+COMMIT\n\n\n\n')
 
-    # watched + commit -> receive pin messages
+    # watched + commit -> read -> receive pin messages; read is stuck until pins are acknowledged
     wl = t.openwatch()
-    wl.watch(zf, t.head)
+    wl.watch(zf, at3); assert at3 == t.head
     f.assertCache([1,1,1,1])
     t.change(zf, {         2: '4c', 5: '4f'})   # FIXME + 4a after δbtree works
     at4 = t.commit()
@@ -973,7 +973,7 @@ def test_wcfs():
     wg = sync.WorkGroup(ctx)
 
     blk = 2
-    pinok = {2: at4}
+    pinok = {2: at3}
 
     blk_data = f.blk(blk)
     assert f.cached()[blk] == 0
@@ -1029,7 +1029,7 @@ def test_wcfs():
     wg.go(_)
 
     wg.wait()
-    assert ev == ['read pre', 'pin rx', 'pin ack pre', 'read']
+    assert ev == ['read pre', 'pin rx', 'pin ack pre', 'read 4']    # 4 - read @head
 
     assert f.cached()[blk] > 0
     f.assertBlk(blk, '4c')