ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-03-22 11:45:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

* fuse/runtests: added --catch-up-pause option

Browse Source 
On linux, write tests are failing because data written to fuse isn't showing
up in tahoe by the time it's checked.  it's not clear where this is originating,
since the fuse implementation [should be] waiting for completion of tahoe 
operations before returning from its calls.  This adds an option to control the
duration of a pause between the fuse write and the check of tahoe, which is by
default set to 2s on linux, which - somewhat inexplicably - seems to 'fix' the 
problem, in as far as it allows tests to complete.
This commit is contained in:
robk-tahoe 2008-10-20 17:29:02 -07:00
parent fafb584ef6
commit 06b05a868d
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
contrib/fuse/runtests.py
View File

@ -81,6 +81,10 @@ if sys.platform == 'darwin':
del implementations['impl_a']
del implementations['impl_b']
default_catch_up_pause = 0
if sys.platform == 'linux2':
default_catch_up_pause = 2
class FuseTestsOptions(usage.Options):
optParameters = [
["test-type", None, "both",
@ -102,6 +106,8 @@ class FuseTestsOptions(usage.Options):
# Note; this is '/tmp' because on leopard, tempfile.mkdtemp creates
# directories in a location which leads paths to exceed what macfuse
# can handle without leaking un-umount-able fuse processes.
["catch-up-pause", None, str(default_catch_up_pause),
"Pause between tahoe operations and fuse tests thereon"],
]
optFlags = [
["debug-wait", None,
@ -126,6 +132,7 @@ class FuseTestsOptions(usage.Options):
self.tests = map(str.strip, self['tests'].split(','))
else:
self.tests = None
self.catch_up_pause = float(self['catch-up-pause'])
### Main flow control:
def main(args):
@ -221,6 +228,9 @@ class SystemTest (object):
url += urllib.quote(where)
webbrowser.open(url)
def maybe_pause(self):
time.sleep(self.config.catch_up_pause)
def init_cli_layer(self):
'''This layer finds the appropriate tahoe executable.'''
#self.cliexec = os.path.join('.', 'bin', 'tahoe')
@ -524,6 +534,7 @@ class SystemTest (object):
tmpl = 'Could not write to file %r: %r'
raise TestFailure(tmpl, path, err)
self.maybe_pause()
self._check_write(testcap, name, body)
def _check_write(self, testcap, name, expected_body):
@ -557,6 +568,7 @@ class SystemTest (object):
tmpl = 'Could not write to file %r: %r'
raise TestFailure(tmpl, path, err)
self.maybe_pause()
self._check_write(testcap, name, body)
@ -597,6 +609,7 @@ class SystemTest (object):
tmpl = 'Could not write to file %r: %r'
raise TestFailure(tmpl, path, err)
self.maybe_pause()
self._check_write(testcap, name, body)
def test_write_partial_overwrite(self, testcap, testdir):
@ -631,6 +644,7 @@ class SystemTest (object):
cap = self.webapi_call('PUT', '/uri', body)
self.attach_node(testcap, cap, name)
self.maybe_pause()
contents = read_file(path)
if contents != body: