.

wcfs/wcfs_test.py

@@ -1332,13 +1332,7 @@ def test_wcfs_pintimeout_kill():
     wg = sync.WorkGroup(ctx)
     def _(ctx):
         # send watch. The pin handler won't be replying -> we should never get reply here.
-        rxq = wl._sendReq(ctx, b"watch %s @%s" % (h(zf._p_oid), h(at1)))
-        _, _rx = select(
-            ctx.done().recv,    # 0
-            rxq.recv,           # 1
-        )
-        if _ == 0:
-            raise ctx.err()
+        wl.sendReq(ctx, b"watch %s @%s" % (h(zf._p_oid), h(at1)))
         fail("watch request completed (should not as pin handler is stuck)")
     wg.go(_)
     def _(ctx):
@@ -1381,15 +1375,6 @@ def test_wcfs_watch_setup_ahead():
 
         wat = tidfromtime(tidtime(at1) + 1*dt)  # > at1, but < at2
         rx = wl.sendReq(ctx, b"watch %s @%s" % (h(zf._p_oid), h(wat)))
-        """
-        rxq = wl._sendReq(ctx, b"watch %s @%s" % (h(zf._p_oid), h(wat)))
-        _, _rx = select(
-            ctx.done().recv,    # 0
-            rxq.recv,           # 1
-        )
-        if _ == 0:
-            raise ctx.err()
-        """
         assert ready(committing)
         assert rx == b"ok"
     wg.go(_)