Commit f39029a0 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 559dc9bf
......@@ -689,27 +689,8 @@ def test_wcfs():
# XXX invalidation protocol ...
print('\n\n inv. protocol \n\n')
"""
w = t.openwatch()
ctx = context.background() # XXX stub
wg = sync.WorkGroup(ctx)
def _(ctx):
pinv = w.expectPin(ctx, zf, {2: at1, 3: at0})
for p in pinv:
p.reply(b"ack")
wg.go(_)
def _(ctx):
assert w.sendReq(ctx, b"watch %s @%s" % (h(zf._p_oid), h(at1))) == "ok"
wg.go(_)
wg.wait()
print('\nCCC\n')
"""
bg = context.background()
# checkSetupWatch verifies setting up new watch for zf@at.
def checkSetupWatch(zf, at):
print('\nC: check setup watch f<%s> %s' % (h(zf._p_oid), t.hat(at)))
......@@ -758,14 +739,11 @@ def test_wcfs():
for dF in t.dFtail:
checkSetupWatch(zf, dF.rev)
print()
return
# XXX test watch with all at variants
# XXX both from scratch and going e.g. at1 -> at2 -> at3
# XXX going not only up, but also down at1 <- at2 <- at3 ?
w = t.watch(zf, at1) # XXX <- pin @at2 @at3
#t.watch(zf, at1, {2: at1, 3: at1}) # XXX <- pin @at2 @at3
# XXX 2 (or more) opened watch for 1 file at the same time
# XXX watch for 2 files via single watch open
......
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