Commit daa44019 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 9ba6db5e
...@@ -1161,7 +1161,7 @@ def test_wcfs(): ...@@ -1161,7 +1161,7 @@ def test_wcfs():
# >>> XXX commit data to not yet accessed f part - nothing happens # >>> XXX commit data to not yet accessed f part - nothing happens
# """ """
# >>> invalidation protocol # >>> invalidation protocol
print('\n\n inv. protocol \n\n') print('\n\n inv. protocol \n\n')
...@@ -1209,7 +1209,7 @@ def test_wcfs(): ...@@ -1209,7 +1209,7 @@ def test_wcfs():
for at in revv[1:]: for at in revv[1:]:
wl.watch(zf, at) wl.watch(zf, at)
wl.close() wl.close()
# """ """
print('\n\n\n\nWATCH+COMMIT\n\n\n\n') print('\n\n\n\nWATCH+COMMIT\n\n\n\n')
...@@ -1221,17 +1221,23 @@ def test_wcfs(): ...@@ -1221,17 +1221,23 @@ def test_wcfs():
at4 = t.commit() at4 = t.commit()
f.assertCache([1,1,0,1,0,0]) # FIXME a must be invalidated - see δbtree ^^^ f.assertCache([1,1,0,1,0,0]) # FIXME a must be invalidated - see δbtree ^^^
f.assertBlk(0, '', {wl: {}}) # XXX 0, {0, at3} after δbtree works
f.assertBlk(1, '', {wl: {}})
f.assertBlk(2, '4c', {wl: {2: at3}}) f.assertBlk(2, '4c', {wl: {2: at3}})
print('000') # blk4 is hole @head - the same as at earlier db view - not pinned
# blk4 is hole @head - the same as at earlier db view XXX or do not allow hole past .size ? # XXX or do not allow hole past .size ?
f.assertBlk(4, '', {wl: {}}) f.assertBlk(4, '', {wl: {}})
print('AAA')
f.assertBlk(5, '4f', {wl: {5: at0}}) # XXX at0 -> ø XXX also triggers access to #4 ? f.assertBlk(5, '4f', {wl: {5: at0}}) # XXX at0 -> ø XXX also triggers access to #4 ?
# XXX 0, {0, at3} after δbtree works
print('BBB')
# XXX watch "-" -> watch no longer notified
# XXX close -> watch no longer notified
# XXX watch with at="-" -> stop watching
# XXX watch for 2 files via single watch open
# XXX 2 (or more) opened watch for 1 file at the same time
wl.close() wl.close()
print('CCC')
# XXX commit after current file size -> watch # XXX commit after current file size -> watch
...@@ -1247,11 +1253,7 @@ def test_wcfs(): ...@@ -1247,11 +1253,7 @@ def test_wcfs():
# XXX going not only up, but also down at1 <- at2 <- at3 ? -> forbid? # XXX going not only up, but also down at1 <- at2 <- at3 ? -> forbid?
# XXX 2 (or more) opened watch for 1 file at the same time
# XXX watch for 2 files via single watch open
# XXX watch with @at > head - must wait for head to become >= at # XXX watch with @at > head - must wait for head to become >= at
# XXX watch with at="-" -> stop watching
# XXX drop file[blk] from cache, access again -> no pin message sent the second time # XXX drop file[blk] from cache, access again -> no pin message sent the second time
......
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