Commit 5da740cd authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 31eb89c3
...@@ -429,6 +429,8 @@ class tFile: ...@@ -429,6 +429,8 @@ class tFile:
# #
# .sendReq()/.recvReq() provides raw IO in terms of wcfs invalidation protocol messages. # .sendReq()/.recvReq() provides raw IO in terms of wcfs invalidation protocol messages.
# .watch() setups a watch for a file and verifies ... XXX # .watch() setups a watch for a file and verifies ... XXX
#
# XXX -> tWatchLink ?
class tWatch: class tWatch:
def __init__(t, tdb): def __init__(t, tdb):
...@@ -847,9 +849,17 @@ def test_wcfs(): ...@@ -847,9 +849,17 @@ def test_wcfs():
# XXX invalid requests -> wcfs replies error # XXX invalid requests -> wcfs replies error
# XXX -> separate test? # XXX -> separate test?
w = t.openwatch() w = t.openwatch()
assert w.sendReq(context.background(), b'bla bla') == "" print('\n\nzzzzzzz\n\n')
try:
assert w.sendReq(context.background(), b'bla bla') == ""
except:
import traceback; traceback.print_exc()
raise
# assert w closed # assert w closed
print('\n\n0000000\n\n')
w.close() w.close()
print('\n\n1111111\n\n')
for zf in t.zfiles(): for zf in t.zfiles():
# watch going at_i -> at_j -> ... # watch going at_i -> at_j -> ...
...@@ -906,9 +916,24 @@ def test_wcfs(): ...@@ -906,9 +916,24 @@ def test_wcfs():
# setupWatch must send pins. # setupWatch must send pins.
@func
def test_wcfs_invproto(): def test_wcfs_invproto():
# XXX # XXX temp debug
pass
"""
def _():
print('BBB')
1/0
defer(_)
"""
#raise RuntimeError('zzz')
try:
print('\nAAA')
assert 1 == 2
finally:
2/0
# ---- misc --- # ---- misc ---
......
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