Commit eca92b6d authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 96fad146
...@@ -84,7 +84,7 @@ digraph { ...@@ -84,7 +84,7 @@ digraph {
headInv [label="#blk ← head/inv."] headInv [label="#blk ← head/inv."]
ZODB_go_inv [label="ZODB/go\ninvalidations"] ZODB_go_inv [label="ZODB/go\ninvalidations"]
fs1_go_inv [label="fs1/go\ninvalidations"] fs1_go_inv [label="fs1/go\ninvalidations", style=filled fillcolor=grey95]
zeo_go_inv [label="zeo/go\ninvalidations"] zeo_go_inv [label="zeo/go\ninvalidations"]
neo_go_inv [label="neo/go\ninvalidations"] neo_go_inv [label="neo/go\ninvalidations"]
// Btree_read [label="BTree read", style=filled fillcolor=lightyellow] // Btree_read [label="BTree read", style=filled fillcolor=lightyellow]
......
...@@ -224,7 +224,7 @@ ...@@ -224,7 +224,7 @@
<!-- fs1_go_inv --> <!-- fs1_go_inv -->
<g id="node12" class="node"> <g id="node12" class="node">
<title>fs1_go_inv</title> <title>fs1_go_inv</title>
<ellipse fill="none" stroke="#000000" cx="60.8112" cy="-98.8701" rx="60.623" ry="26.7407"/> <ellipse fill="#f2f2f2" stroke="#000000" cx="60.8112" cy="-98.8701" rx="60.623" ry="26.7407"/>
<text text-anchor="middle" x="60.8112" y="-102.6701" font-family="Times,serif" font-size="14.00" fill="#000000">fs1/go</text> <text text-anchor="middle" x="60.8112" y="-102.6701" font-family="Times,serif" font-size="14.00" fill="#000000">fs1/go</text>
<text text-anchor="middle" x="60.8112" y="-87.6701" font-family="Times,serif" font-size="14.00" fill="#000000">invalidations</text> <text text-anchor="middle" x="60.8112" y="-87.6701" font-family="Times,serif" font-size="14.00" fill="#000000">invalidations</text>
</g> </g>
......
...@@ -561,8 +561,7 @@ type blkLoadState struct { ...@@ -561,8 +561,7 @@ type blkLoadState struct {
/* /*
// XXX invalidation watcher // XXX invalidation watcher
// XXX naming func (sb *Root) zwatch(ctx context.Context) error {
func (sb *Super) main(ctx context.Context) error {
// XXX err ctx // XXX err ctx
// XXX unmount on error? -> always EIO? // XXX unmount on error? -> always EIO?
...@@ -581,7 +580,7 @@ func (sb *Super) main(ctx context.Context) error { ...@@ -581,7 +580,7 @@ func (sb *Super) main(ctx context.Context) error {
// zhandle1 handles 1 event from ZODB notification. // zhandle1 handles 1 event from ZODB notification.
// XXX something is locked // XXX something is locked
func (sb *Super) zhandle1(zevent *zodb.NotifyEvent) { func (sb *Root) zhandle1(zevent *zodb.NotifyEvent) {
toinvalidate = ... // [] of file/[]#blk toinvalidate = ... // [] of file/[]#blk
// zevent = (tid^, []oid) // zevent = (tid^, []oid)
...@@ -618,7 +617,7 @@ func (sb *Super) zhandle1(zevent *zodb.NotifyEvent) { ...@@ -618,7 +617,7 @@ func (sb *Super) zhandle1(zevent *zodb.NotifyEvent) {
// invalidateBlk invalidates 1 file block. XXX // invalidateBlk invalidates 1 file block. XXX
// XXX see "4. for all file/blk to in invalidate we do" // XXX see "4. for all file/blk to in invalidate we do"
func (f *file) invalidateBlk(ctx context.Context, blk int64) error { func (f *file) invalidateBlk(ctx context.Context, blk int64) error {
fsconn := f.super().fsconn fsconn := f.root().fsconn
off := blk*blksize off := blk*blksize
// try retrieve cache of current head/data[blk] // try retrieve cache of current head/data[blk]
......
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