.

wcfs/wcfs.go

@@ -1349,6 +1349,14 @@ retry:
 //
 // (see "7.2) for all registered client@at watchers ...")
 
+const _traceIso = true
+func traceIso(format string, argv ...interface{}) {
+	if !_traceIso {
+		return
+	}
+	log.InfoDepth(1, fmt.Sprintf(format, argv...))
+}
+
 // pin makes sure that file[blk] on client side is the same as of @rev state.
 //
 // rev = zodb.TidMax means @head; otherwise rev must be ≤ w.at and there must
@@ -1833,8 +1841,7 @@ func (wlink *WatchLink) _serve() (err error) {
 			}
 			return err
 		}
-
-		//fmt.Printf("S: wlink%d: rx: %q\n", wlink.id, l)
+		traceIso("S: wlink%d: rx: %q\n", wlink.id, l)
 
 		stream, msg, err := parseWatchFrame(l)
 		if err != nil {
@@ -1937,7 +1944,7 @@ func (wlink *WatchLink) send(ctx context.Context, stream uint64, msg string) err
 	defer wlink.txMu.Unlock()
 
 	pkt := []byte(fmt.Sprintf("%d %s\n", stream, msg))
-	//fmt.Printf("S: wlink%d: tx: %q\n", wlink.id, pkt)
+	traceIso("S: wlink%d: tx: %q\n", wlink.id, pkt)
 	_, err := wlink.sk.Write(ctx, pkt)
 	if err != nil {
 		return err