Commit aa2f3e0f authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent da48cbaf
...@@ -625,6 +625,11 @@ func (r *Root) zhandle1(zevent zodb.CommitEvent) { ...@@ -625,6 +625,11 @@ func (r *Root) zhandle1(zevent zodb.CommitEvent) {
} }
// XXX resync .zhead to zevent.tid // XXX resync .zhead to zevent.tid
// notify .wcfs/zhead
for fh := range gdebug.zhead.fhTab {
fh.Write(fmt.Sprintf("%s\n", zevent.tid)) // XXX -> fh = filesock
}
} }
// invalidateBlk invalidates 1 file block. XXX // invalidateBlk invalidates 1 file block. XXX
...@@ -1238,7 +1243,13 @@ func main() { ...@@ -1238,7 +1243,13 @@ func main() {
dotwcfs := nodefs.NewDefaultNode() dotwcfs := nodefs.NewDefaultNode()
mkdir(root, ".wcfs", dotwcfs) mkdir(root, ".wcfs", dotwcfs)
mkfile(dotwcfs, "zurl", NewStaticFile([]byte(zurl))) mkfile(dotwcfs, "zurl", NewStaticFile([]byte(zurl)))
// XXX zhead
// .wcfs/zhead - special file. If a user opens it, it will start to get
// tids of through whichzhead.at was, starting from the time when
// .wcfs/zhead was opened. There can be multiple openers. Once opened,
// the file must be read, as wcfs blocks waiting for data to be read.
// XXX text review.
mkfile(dotwcfs, "zhead", ...)
// TODO handle autoexit // TODO handle autoexit
_ = autoexit _ = autoexit
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment