.

wcfs/wcfs.go

@@ -430,7 +430,7 @@ import (
 	"sync"
 	"sync/atomic"
 	"syscall"
-	"time"
+//	"time"
 
 	log "github.com/golang/glog"
 	"golang.org/x/sync/errgroup"
@@ -818,12 +818,13 @@ retry:
 		}
 		fmt.Printf("\t- %s\t%s %v\n", file.zfile.POid(), size, blkv)
 	}
-	time.Sleep(1*time.Second)
+	//time.Sleep(1*time.Second)
 	fmt.Printf("\n\n")
 
 	wg, ctx := errgroup.WithContext(context.TODO())	// XXX ctx = ?
 	for file, δfile := range δF.Change {
 		// XXX needed?
+		// XXX even though δBtail is complete, not all ZBlk are present here
 		file.δtail.Append(δF.Rev, δfile.Blocks.Elements())
 
 		file := file

wcfs/wcfs_test.py

@@ -543,11 +543,14 @@ def test_wcfs():
     f.assertCache([0,0,0])  # initially not cached
     f.assertData ([b'',b'',b'alpha'], mtime=t.head)
 
+    print('000')
+
     # >>> (@at2) commit again -> we can see both latest and snapshotted states
     t.change(zf, {2: b'beta', 3: b'gamma'})
     at2 = t.commit()
 
     t.wcsync()
+    print('111')
 
     # f @head
     f.assertCache([1,1,0,0])
@@ -560,11 +563,13 @@ def test_wcfs():
 
 
     # >>> (@at3) commit again without changing zf size
+    print('222')
     f2 = t.open(zf, at=at2)
     t.change(zf, {2: b'kitty'})
     at3 = t.commit()
 
     t.wcsync()
+    print('333')
     f.assertCache([1,1,0,1])
 
     # f @head is opened again -> cache must not be lost
@@ -597,7 +602,7 @@ def test_wcfs():
     # >>> XXX commit data to not yet accessed f part - nothing happens
 
     # XXX invalidation protocol ...
-    print('\n\n')
+    print('\n\n inv. protocol \n\n')
     w = t.openwatch()
 
     done = chan()