.

wcfs/wcfs_test.py

@@ -438,14 +438,14 @@ class tWatch:
         # XXX we can get stuck here if wcfs does not behave as we want.
         # XXX in particular if there is a silly - e.g. syntax or type error in
         #     test code - we curently get stuck here.
-        print('# serveDone.recv() ...')
+        #
+        # XXX -> better pthread_kill(SIGINT) instead of relying on wcfs proper behaviour?
         try:
             t._serveWG.wait()
         except Exception as e:
             # canceled is expected and ok
             if e != context.canceled:
                 reraise(e, None, e.__traceback__)
-        print('# serveDone ready')
 
         t.wtx.close()
         t.wrx.close()
@@ -462,7 +462,7 @@ class tWatch:
     @func
     def _serveRecv(t, ctx):
         while 1:
-            print('C: watch  : rx wait ...')
+            # NOTE: .close() makes sure .wrx.read*() will wake up
             l = t.wrx.readline()
             print('C: watch  : rx: %r' % l)
             if len(l) == 0:
@@ -565,7 +565,6 @@ class tWatch:
                 req = t.recvReq(ctx)
             except Exception as e:
                 raise RuntimeError("%s\nnot all pin missages received - pending:\n%s" % (e, expected))
-            assert False    # XXX temp
             assert req is not None  # channel not closed
             assert req.msg in expected
             expected.remove(req.msg)