.

wcfs/wcfs_test.py

@@ -1353,6 +1353,23 @@ def test_wcfs_watch_robust():
     wl.close()
 
 
+# verify that wcfs kills slow/faulty client who does not reply to pin in time.
+# XXX place -> after normal tests? (yes, seems better - together with watch_robust)
+@func
+def test_wcfs_pintimeout_kill():
+    t = tDB(); zf = t.zfile     # XXX wcfs arg: lower kill timeout
+    defer(t.close)
+
+    # XXX move into subprocess not to kill whole testing
+
+    at1 = t.commit(zf, {2:'c1'})
+    at2 = t.commit(zf, {2:'c2'})
+    f = t.open(zf)
+    f.assertData(['','','c2'])
+
+    wl = 
+
+
 # verify that watch setup/update sends correct pins.
 @func
 def test_wcfs_watch_setup():
@@ -1632,7 +1649,6 @@ def test_wcfs_watch_2files():
 
 
     # XXX watch with @at > head - must wait for head to become >= at
-    # XXX no reply to pin - killed
 
 
     # XXX watch @at when file did not existed -> error