RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-11 02:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

cephfs/test_client_recovery: check fsync waits for unsafe requests

Browse Source 
make sure fsync wait for unsafe requests that created/modified the
file.

Signed-off-by: Yan, Zheng <zyan@redhat.com>
This commit is contained in:
Yan, Zheng 2015-11-26 15:01:40 +08:00
parent 30b64fd739
commit 375c53bb76
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
tasks/cephfs/test_client_recovery.py
View File

@ -366,7 +366,13 @@ class TestClientRecovery(CephFSTestCase):
# We killed it, so it raises an error
pass
def test_fsync(self):
def test_dir_fsync(self):
self._test_fsync(True);
def test_create_fsync(self):
self._test_fsync(False);
def _test_fsync(self, dirfsync):
"""
That calls to fsync guarantee visibility of metadata to another
client immediately after the fsyncing client dies.
@ -382,23 +388,25 @@ class TestClientRecovery(CephFSTestCase):
import os
import time
path = "{0}"
path = "{path}"
print "Starting creation..."
start = time.time()
os.mkdir(path)
f = open(os.path.join(path, "childfile"), "w")
f.close()
print "Finished creation in {0}s".format(time.time() - start)
dfd = os.open(path, os.O_DIRECTORY)
fd = os.open(path, os.O_DIRECTORY)
fd = open(os.path.join(path, "childfile"), "w")
print "Finished creation in {{0}}s".format(time.time() - start)
print "Starting fsync..."
start = time.time()
os.fsync(fd)
print "Finished fsync in {0}s".format(time.time() - start)
""".format(path))
if {dirfsync}:
os.fsync(dfd)
else:
os.fsync(fd)
print "Finished fsync in {{0}}s".format(time.time() - start)
""".format(path=path,dirfsync=str(dirfsync)))
)
# Immediately kill the MDS and then client A