.

wcfs/wcfs_test.py

@@ -1367,7 +1367,22 @@ def test_wcfs_pintimeout_kill():
     f = t.open(zf)
     f.assertData(['','','c2'])
 
-    wl = 
+    wl = t.openwatch()
+    wg = sync.WorkGroup(XXX)
+    def _(ctx):
+        # XXX assert?
+        wl.sendReq(ctx, b"watch %s @%s" % (h(zf._p_oid), h(at1)))
+    wg.go(_)
+    def _(ctx):
+        req = wl.recvReq(ctx)
+        assert req is not None
+        assert req.msg == b"pin %s #%d @%s" % (h(zf._p_oid), 2, h(at1))
+
+        # XXX sleep > wcfs pin timeout - wcfs must kill us
+        assert False, "wcfs did not killed stuck client"
+    wg.go(_)
+    wg.wait()
+
 
 
 # verify that watch setup/update sends correct pins.