Commit 035cce1f authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 55dc0056
...@@ -45,7 +45,7 @@ from thread import get_ident as gettid ...@@ -45,7 +45,7 @@ from thread import get_ident as gettid
from time import gmtime from time import gmtime
from errno import EINVAL, ENOTCONN from errno import EINVAL, ENOTCONN
from resource import setrlimit, getrlimit, RLIMIT_MEMLOCK from resource import setrlimit, getrlimit, RLIMIT_MEMLOCK
from golang import go, chan, select, func, defer, default, error, b from golang import go, chan, select, func, defer, error, b
from golang import context, errors, sync, time from golang import context, errors, sync, time
from zodbtools.util import ashex as h, fromhex from zodbtools.util import ashex as h, fromhex
import pytest; xfail = pytest.mark.xfail import pytest; xfail = pytest.mark.xfail
...@@ -170,7 +170,7 @@ def test_join_autostart(): ...@@ -170,7 +170,7 @@ def test_join_autostart():
assert os.path.isdir(wc.mountpoint + "/head/bigfile") assert os.path.isdir(wc.mountpoint + "/head/bigfile")
# verify that join successfully starts wcfs if previous wcfs exited uncleanly. # verify that join successfully starts wcfs if previous wcfs exited uncleanly.
@func @func
def test_join_after_crash(): def test_join_after_crash():
zurl = testzurl zurl = testzurl
...@@ -198,7 +198,7 @@ def test_join_after_crash(): ...@@ -198,7 +198,7 @@ def test_join_after_crash():
procmounts_lookup_wcfs(zurl) procmounts_lookup_wcfs(zurl)
# verify that start successfuly starts server if previous wcfs exited uncleanly. # verify that start successfully starts server if previous wcfs exited uncleanly.
@func @func
def test_start_after_crash(): def test_start_after_crash():
zurl = testzurl zurl = testzurl
...@@ -345,7 +345,7 @@ class DFile: ...@@ -345,7 +345,7 @@ class DFile:
# #
# tDB must be explicitly closed once no longer used. # tDB must be explicitly closed once no longer used.
# #
# XXX print -> t.trace/debug() + t.verbose depending on py.test -v -v ? # TODO(?) print -> t.trace/debug() + t.verbose depending on py.test -v -v ?
class tWCFS(_tWCFS): class tWCFS(_tWCFS):
@func @func
def __init__(t): def __init__(t):
...@@ -420,7 +420,7 @@ class tDB(tWCFS): ...@@ -420,7 +420,7 @@ class tDB(tWCFS):
# whether head/ ZBigFile(s) blocks were ever accessed via wcfs. # whether head/ ZBigFile(s) blocks were ever accessed via wcfs.
# this is updated only explicitly via ._blkheadaccess() . # this is updated only explicitly via ._blkheadaccess() .
t._blkaccessedViaHead = {} # ZBigFile -> set(blk) XXX ZF -> foid ? (threads) t._blkaccessedViaHead = {} # ZBigFile -> set(blk)
# tracked opened tFiles & tWatchLinks # tracked opened tFiles & tWatchLinks
t._files = set() t._files = set()
...@@ -558,7 +558,7 @@ class tDB(tWCFS): ...@@ -558,7 +558,7 @@ class tDB(tWCFS):
# XXX locking needed? or we do everything serially? # XXX locking needed? or we do everything serially?
t._blkaccessed(zf).add(blk) t._blkaccessed(zf).add(blk)
# _blkaccessed returns set describing whether head/zf blocks were ever accessed. # _blkaccessed returns set describing which head/zf blocks were ever accessed.
def _blkaccessed(t, zf): # set(blk) def _blkaccessed(t, zf): # set(blk)
return t._blkaccessedViaHead.setdefault(zf, set()) return t._blkaccessedViaHead.setdefault(zf, set())
...@@ -583,7 +583,7 @@ class tFile: ...@@ -583,7 +583,7 @@ class tFile:
t.fmmap = None t.fmmap = None
tdb._files.add(t) tdb._files.add(t)
# make sure that wcfs reports zf.blksize as preffered block size for IO. # make sure that wcfs reports zf.blksize as preferred block size for IO.
# wcfs.py also uses .st_blksize in blk -> byte offset computation. # wcfs.py also uses .st_blksize in blk -> byte offset computation.
st = os.fstat(t.f.fileno()) st = os.fstat(t.f.fileno())
assert st.st_blksize == t.blksize assert st.st_blksize == t.blksize
...@@ -886,7 +886,7 @@ class tWatchLink(wcfs.WatchLink): ...@@ -886,7 +886,7 @@ class tWatchLink(wcfs.WatchLink):
w.pinned = {} w.pinned = {}
t._watching = {} t._watching = {}
# XXX just wrap req.at with tAt inpace # XXX just wrap req.at with tAt inplace
""" """
# recvReq is the same as WatchLink.recvReq but returns tSrvReq instead of PinReq. # recvReq is the same as WatchLink.recvReq but returns tSrvReq instead of PinReq.
def recvReq(t, ctx): # -> tSrvReq | None when EOF def recvReq(t, ctx): # -> tSrvReq | None when EOF
......
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