.

wcfs/internal/_wcfs.pyx

@@ -159,7 +159,6 @@ cdef class PyWatchLink:
 
             raise RuntimeError(err.Error())     # XXX -> Xpy(err) ? pyraiseIf(err) ?
 
-        #printf("pyxsendReq: reply -> ok\n")
         return reply
 
 

wcfs/wcfs_test.py

@@ -1380,6 +1380,8 @@ def test_wcfs_watch_setup_ahead():
         defer(wl.close)
 
         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
@@ -1387,8 +1389,9 @@ def test_wcfs_watch_setup_ahead():
         )
         if _ == 0:
             raise ctx.err()
+        """
         assert ready(committing)
-        assert _rx == b"ok"
+        assert rx == b"ok"
     wg.go(_)
 
     # T2: sleep(10·dt); commit