Commit afef5ec0 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent e12a1c0c
...@@ -616,7 +616,7 @@ class tFile: ...@@ -616,7 +616,7 @@ class tFile:
# XXX assert individually for every block's page? (easier debugging?) # XXX assert individually for every block's page? (easier debugging?)
assert blkview == dataok assert blkview == dataok
# we just accessed the block - it has to be in OS cache # we just accessed the block in full - it has to be in OS cache completely
assert t.cached()[blk] == 1 assert t.cached()[blk] == 1
...@@ -649,7 +649,7 @@ class tWatch: ...@@ -649,7 +649,7 @@ class tWatch:
# tWatchLink provides testing environment for /head/watch link opened on wcfs. # tWatchLink provides testing environment for /head/watch link opened on wcfs.
# #
# .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/adjusts a watch for a file and verifies that wcfs sends correct initial pins.
class tWatchLink: class tWatchLink:
def __init__(t, tdb): def __init__(t, tdb):
...@@ -668,7 +668,7 @@ class tWatchLink: ...@@ -668,7 +668,7 @@ class tWatchLink:
t._wrx = os.fdopen(wh, 'rb') t._wrx = os.fdopen(wh, 'rb')
t._wtx = os.fdopen(wh2, 'wb') t._wtx = os.fdopen(wh2, 'wb')
t.rx_eof = chan() # .rx_eof becomes ready when wcfs closes its tx side t.rx_eof = chan() # becomes ready when wcfs closes its tx side
t.fatalv = [] # fatal messages received from wcfs t.fatalv = [] # fatal messages received from wcfs
# inv.protocol message IO # inv.protocol message IO
......
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