.

wcfs/__init__.py

@@ -137,7 +137,7 @@ class _Mapping(object):
 def connect(wc, at): # -> Conn
     wconn = Conn()
 
-    # XXX support !isolated mode
+    # TODO support !isolated mode
     wconn._wc       = wc
     wconn.at        = at
     wconn._wlink    = WatchLink(wc)
@@ -417,8 +417,8 @@ class WatchLink(object):
         wlink._wtx = os.fdopen(wh2, 'wb')
 
         # XXX vvv -> test only?
-        wlink.rx_eof = chan()   # becomes ready when wcfs closes its tx side
-        wlink.fatalv = []       # fatal messages received from wcfs
+        wlink.rx_eof = chan(dtype='C.structZ')  # becomes ready when wcfs closes its tx side
+        wlink.fatalv = []                       # fatal messages received from wcfs
 
         # inv.protocol message IO
         wlink._acceptq  = chan() # (stream, msg)    server originated messages go here
@@ -440,6 +440,7 @@ class WatchLink(object):
 
 
     def _closeTX(wlink):
+        # XXX -> sync.Once
         if wlink._txclosed:
             return
 
@@ -505,7 +506,7 @@ class WatchLink(object):
             msg = msg.rstrip('\n')
 
             if stream == 0: # control/fatal message from wcfs
-                # XXX print -> receive somewhere?
+                # XXX print -> receive somewhere?   XXX -> recvCtl ?
                 print('C: watch  : rx fatal: %r' % msg)
                 wlink.fatalv.append(msg)
                 continue