.

wcfs/test.sh

@@ -8,5 +8,5 @@ if test -z "$qrun_loglevel"; then
 fi
 
 # executed under qemu-runlinux
-#export WENDELIN_CORE_WCFS_OPTIONS="-d -alsologtostderr -v=1"
+export WENDELIN_CORE_WCFS_OPTIONS="-d -alsologtostderr -v=1"
 py.test -vsx -k test_wcfs

wcfs/wcfs.go

@@ -1421,15 +1421,23 @@ func (wlink *WatchLink) _serveRX() (err error) {
 
 		ctx := context.TODO()	// XXX ctx = ?
 
+		fmt.Printf("S: watch: AAA\n")
+
+		if false {
 		err = wlink.setupWatch(ctx, foid, at)
 		if err != nil {
 			return fmt.Errorf("%d: %s", stream, err)
 		}
+	}
+
+		fmt.Printf("S: watch: BBB\n")
 
 		err = wlink.send(ctx, stream, "ok")
 		if err != nil {
 			panic(err)	// XXX
 		}
+
+		fmt.Printf("S: watch: CCC\n")
 	}
 }
 

wcfs/wcfs_test.py

@@ -413,9 +413,10 @@ class tWatch:
             if len(l) == 0:
                 break   # closed
 
-            # <stream> ...
+            # <stream> ... \n
             stream, msg = l.split(' ', 1)
             stream = int(stream)
+            msg = msg.rstrip('\n')
 
             reply = bool(stream % 2)
             if reply: