.

wcfs/wcfs.go

@@ -429,6 +429,7 @@ import (
 	"sync"
 	"sync/atomic"
 	"syscall"
+	"time"
 
 	log "github.com/golang/glog"
 	"golang.org/x/sync/errgroup"
@@ -804,10 +805,12 @@ retry:
 	// XXX no indexMu lock needed because head is Locked
 	δF := bfdir.δFtail.Update(δZ, zhead)
 
-	//fmt.Printf("\n\nzδhandle: δF (#%d):\n", len(δF))
-	//for file := range δF {
-	//	fmt.Printf("\t- %s\n", file.zfile.POid())
-	//}
+	fmt.Printf("\n\nzδhandle: δF (#%d):\n", len(δF.Change))
+	for file := range δF.Change {
+		fmt.Printf("\t- %s\n", file.zfile.POid())
+	}
+	time.Sleep(1*time.Second)
+	fmt.Printf("\n\n")
 
 	wg, ctx := errgroup.WithContext(context.TODO())	// XXX ctx = ?
 	for file, δfile := range δF.Change {
@@ -1394,6 +1397,7 @@ func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.T
 	for blk, rev := range toPin {
 		blk := blk
 		rev := rev
+		fmt.Printf("S: watch: -> pin #%d @%s\n", blk, rev)
 		wg.Go(func() error {
 			return w.pin(ctx, blk, rev)
 		})