.

wcfs/wcfs.go

@@ -1502,7 +1502,7 @@ func (wlink *WatchLink) _serveRX() (err error) {
 			return err
 		}
 
-		fmt.Printf("S: watch: rx: %q\n", l)
+		fmt.Printf("S: wlink %d: rx: %q\n", wlink.id, l)
 
 		stream, msg, err := parseWatchFrame(l)
 		if err != nil {
@@ -1605,7 +1605,7 @@ func (wlink *WatchLink) send(ctx context.Context, stream uint64, msg string) err
 
 	// XXX timeout write on ctx cancel
 	pkt := []byte(fmt.Sprintf("%d %s\n", stream, msg))
-	fmt.Printf("S: watch: tx: %q\n", pkt)
+	fmt.Printf("S: wlink %d: tx: %q\n", wlink.id, pkt)
 	_, err := wlink.sk.Write(pkt)
 	if err != nil {
 		return err

wcfs/wcfs_test.py

@@ -415,7 +415,7 @@ class tWatch:
         defer(t._serveDone.close)
         while 1:
             l = t.wrx.readline()
-            print('C: watch: rx: %r' % l)
+            print('C: watch  : rx: %r' % l)
             if len(l) == 0:
                 break   # closed
 
@@ -443,7 +443,7 @@ class tWatch:
         assert '\n' not in msg
         with t._txmu:
             pkt = b"%d %s\n" % (stream, msg)
-            print('C: watch: tx: %r' % pkt)
+            print('C: watch  : tx: %r' % pkt)
             t.wtx.write(pkt)
             t.wtx.flush()