Commit bc4bb76c authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent f125140a
......@@ -1178,7 +1178,7 @@ func (f *BigFile) updateWatchers(ctx context.Context, blk int64, treepath []btre
return
}
fmt.Printf("S: read -> update watchers (#%d)\n", len(f.watches))
fmt.Printf("S: read #%d -> update watchers (#%d)\n", blk, len(f.watches))
// update δFtail index
bfdir := f.head.bfdir
......
......@@ -540,7 +540,7 @@ class tFile:
shouldPin = False # whether at least one wlink should receive a pin
# watches must be notified if access goes to @head/file; not if to @rev/file. XXX text
wpin = {} # tWatchLink -> (zf, pinok)
wpin = {} # tWatchLink -> pinok
for wlink in t.tdb._wlinks:
pinok = {}
if t.at is None: # @head/...
......@@ -1190,10 +1190,16 @@ def test_wcfs():
f.assertCache([1,1,0,1,0,0]) # FIXME a must be invalidated - see δbtree ^^^
f.assertBlk(2, '4c', {wl: {2: at3}})
f.assertBlk(5, '4f', {wl: {5: at0}}) # XXX at0 -> ø
print('000')
# blk4 is hole @head - the same as at earlier db view XXX or do not allow hole past .size ?
f.assertBlk(4, '', {wl: {}})
print('AAA')
f.assertBlk(5, '4f', {wl: {5: at0}}) # XXX at0 -> ø XXX also triggers access to #4 ?
# XXX 0, {0, at3} after δbtree works
print('BBB')
wl.close()
print('CCC')
# XXX commit after current file size -> watch
......
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