.

wcfs/wcfs.go

@@ -655,6 +655,10 @@ func (root *Root) zδhandle1(zevent zodb.CommitEvent) {
 				return file.invalidateBlk(ctx, blk)
 			})
 		}
+
+		// invalidate kernel cache for attributes
+		// XXX we need to do it only if we see topoligy (i.e. btree) change
+		wg.Go(file.invalidateAttr)
 	}
 	err := wg.Wait()
 	if err != nil {
@@ -668,6 +672,7 @@ func (root *Root) zδhandle1(zevent zodb.CommitEvent) {
 	// XXX dir.mu locking (not needed bcause zconnMu locked)
 	for _, file := range bfdir.fileTab {
 		file.zbf.PDeactivate()
+		// XXX we need to reread size only for files in toinvalidate
 		file.zbfSize = -1 // just in case
 	}
 
@@ -705,7 +710,7 @@ func (root *Root) zδhandle1(zevent zodb.CommitEvent) {
 	}
 }
 
-// invalidateBlk invalidates 1 file block.	XXX
+// invalidateBlk invalidates 1 file block in kernel cache.
 //
 // see "4.4) for all file/blk to in invalidate we do"
 //
@@ -746,6 +751,15 @@ func (f *BigFile) invalidateBlk(ctx context.Context, blk int64) error {
 	panic("TODO")
 }
 
+// invalidateAttr invalidates file attributes in kernel cache.
+func (f *BigFile) invalidateAttr() error {
+	fsconn := gfsconn
+	st := fsconn.FileNotify(f.Inode(), -1, -1) // metadata only
+	// st != ok
+	_ = st
+	panic("TODO")
+}
+
 
 // mkrevfile makes sure inode ID of /@<rev>/bigfile/<fid> is known to kernel.
 //
@@ -1344,7 +1358,7 @@ func main() {
 	mkdir(root, "head", head)
 	mkdir(head, "bigfile", bfdir)
 	mkfile(head, "at", NewSmallFile(head.readAt))   // TODO mtime(at) = tidtime(at)
-	// XXX ^^^ invalidate cache or direct io
+	// XXX ^^^ invalidate cache or direct io XXX no FOPEN_KEEP_CACHE -> direct io
 
 	// for debugging/testing
 	_wcfs := newDefaultNode()

wcfs/wcfs_test.py

@@ -204,6 +204,8 @@ def test_wcfs():
     s   = b"hello world"
     memcpy(vma, s)
 
+    print("\n\n\n")
+    #import time; time.sleep(2)
     commit()
     wcsync()    # sync wcfs to ZODB