RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-31 07:22:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

pycephfs: add tests for open call

Browse Source 
Signed-off-by: Haomai Wang <haomaiwang@gmail.com>
This commit is contained in:
Haomai Wang 2015-05-05 00:07:18 +08:00
parent 6b81d5cbc6
commit 0b4315b96f
2 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/pybind/cephfs.py
View File

@ -342,9 +342,6 @@ class LibCephFS(object):
if ret < 0:
raise make_ex(ret, "chdir failed")
def isdir(self, dirent):
return dirent['d_type'] == 0x4
def opendir(self, path):
self.require_state("mounted")
if not isinstance(path, basestring):
@ -419,10 +416,11 @@ class LibCephFS(object):
cephfs_flags |= os.O_RDONLY
elif c == 'w':
cephfs_flags |= os.O_WRONLY | os.O_TRUNC | os.O_CREAT
elif c == 'a':
cephfs_flags |= os.O_APPEND | os.O_CREAT
elif c == '+':
cephfs_flags |= os.O_RDWR
else:
raise OperationNotSupported(
"open flags doesn't support %s" % c)
ret = self.libcephfs.ceph_open(self.cluster, c_char_p(path),
c_int(cephfs_flags), c_int(mode))

13
src/test/pybind/test_cephfs.py
View File

@ -65,10 +65,19 @@ def test_open():
assert_raises(libcephfs.ObjectNotFound, cephfs.open, 'file-1', 'r')
assert_raises(libcephfs.ObjectNotFound, cephfs.open, 'file-1', 'r+')
fd = cephfs.open('file-1', 'w')
cephfs.write(fd, "asdf", 0)
cephfs.close(fd)
fd = cephfs.open('file-1', 'r')
assert_equal(cephfs.read(fd, 0, 4), "asdf")
cephfs.close(fd)
fd = cephfs.open('file-2', 'a')
fd = cephfs.open('file-1', 'r+')
cephfs.write(fd, "zxcv", 4)
assert_equal(cephfs.read(fd, 4, 8), "zxcv")
cephfs.close(fd)
fd = cephfs.open('file-1', 'w+')
assert_equal(cephfs.read(fd, 0, 4), "")
cephfs.write(fd, "zxcv", 4)
assert_equal(cephfs.read(fd, 4, 8), "zxcv")
cephfs.close(fd)
assert_raises(libcephfs.OperationNotSupported, cephfs.open, 'file-1', 'a')
cephfs.unlink('file-1')
cephfs.unlink('file-2')