Loading tests/integration/data/test_data_integrity.py +0 −1 Original line number Original line Diff line number Diff line Loading @@ -47,7 +47,6 @@ def test_data_integrity(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! # test stat on existing dir # test stat on existing dir ret = gkfs_client.stat(topdir) ret = gkfs_client.stat(topdir) Loading tests/integration/data/test_truncate.py +0 −12 Original line number Original line Diff line number Diff line Loading @@ -37,11 +37,9 @@ def test_truncate(gkfs_daemon, gkfs_client): ret = gkfs_client.write_random(truncfile, buf_length) ret = gkfs_client.write_random(truncfile, buf_length) assert ret.retval == buf_length assert ret.retval == buf_length assert ret.errno == 115 # FIXME: Should be 0! ret = gkfs_client.stat(truncfile) ret = gkfs_client.stat(truncfile) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == buf_length assert ret.statbuf.st_size == buf_length # truncate it # truncate it Loading @@ -49,12 +47,10 @@ def test_truncate(gkfs_daemon, gkfs_client): trunc_size = buf_length // 2 trunc_size = buf_length // 2 ret = gkfs_client.truncate(truncfile, trunc_size) ret = gkfs_client.truncate(truncfile, trunc_size) assert ret.errno == 115 # FIXME: Should be 0! assert ret.retval == 0 assert ret.retval == 0 # check file length # check file length ret = gkfs_client.stat(truncfile) ret = gkfs_client.stat(truncfile) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == trunc_size assert ret.statbuf.st_size == trunc_size # verify contents by writing a new file (random content is seeded) and checksum both # verify contents by writing a new file (random content is seeded) and checksum both Loading @@ -69,30 +65,25 @@ def test_truncate(gkfs_daemon, gkfs_client): ret = gkfs_client.write_random(truncfile_verify, trunc_size) ret = gkfs_client.write_random(truncfile_verify, trunc_size) assert ret.retval == trunc_size assert ret.retval == trunc_size assert ret.errno == 115 # FIXME: Should be 0! ret = gkfs_client.stat(truncfile_verify) ret = gkfs_client.stat(truncfile_verify) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == trunc_size assert ret.statbuf.st_size == trunc_size ret = gkfs_client.file_compare(truncfile, truncfile_verify, trunc_size) ret = gkfs_client.file_compare(truncfile, truncfile_verify, trunc_size) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 # FIXME: Should be 0! # trunc at byte 712345 (middle of chunk) # trunc at byte 712345 (middle of chunk) # TODO feed chunksize into test to make sure it is always in the middle of the chunk # TODO feed chunksize into test to make sure it is always in the middle of the chunk trunc_size = 712345 trunc_size = 712345 ret = gkfs_client.truncate(truncfile, trunc_size) ret = gkfs_client.truncate(truncfile, trunc_size) assert ret.errno == 115 # FIXME: Should be 0! assert ret.retval == 0 assert ret.retval == 0 # check file length # check file length ret = gkfs_client.stat(truncfile) ret = gkfs_client.stat(truncfile) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == trunc_size assert ret.statbuf.st_size == trunc_size # verify contents by writing a new file (random content is seeded) and checksum both # verify contents by writing a new file (random content is seeded) and checksum both Loading @@ -107,14 +98,11 @@ def test_truncate(gkfs_daemon, gkfs_client): ret = gkfs_client.write_random(truncfile_verify_2, trunc_size) ret = gkfs_client.write_random(truncfile_verify_2, trunc_size) assert ret.retval == trunc_size assert ret.retval == trunc_size assert ret.errno == 115 # FIXME: Should be 0! ret = gkfs_client.stat(truncfile_verify_2) ret = gkfs_client.stat(truncfile_verify_2) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == trunc_size assert ret.statbuf.st_size == trunc_size ret = gkfs_client.file_compare(truncfile, truncfile_verify_2, trunc_size) ret = gkfs_client.file_compare(truncfile, truncfile_verify_2, trunc_size) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 # FIXME: Should be 0! tests/integration/directories/test_directories.py +0 −15 Original line number Original line Diff line number Diff line Loading @@ -42,19 +42,16 @@ def test_mkdir(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! # test stat on existing dir # test stat on existing dir ret = gkfs_client.stat(topdir) ret = gkfs_client.stat(topdir) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! assert stat.S_ISDIR(ret.statbuf.st_mode) assert stat.S_ISDIR(ret.statbuf.st_mode) # open topdir # open topdir ret = gkfs_client.open(topdir, os.O_DIRECTORY) ret = gkfs_client.open(topdir, os.O_DIRECTORY) assert ret.retval != -1 assert ret.retval != -1 assert ret.errno == 115 #FIXME: Should be 0! # read and write should be impossible on directories # read and write should be impossible on directories Loading @@ -77,19 +74,16 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.opendir(topdir) ret = gkfs_client.opendir(topdir) assert ret.dirp is not None assert ret.dirp is not None assert ret.errno == 115 #FIXME: Should be 0! ret = gkfs_client.readdir(topdir) ret = gkfs_client.readdir(topdir) # XXX: This might change in the future if we add '.' and '..' # XXX: This might change in the future if we add '.' and '..' assert len(ret.dirents) == 0 assert len(ret.dirents) == 0 assert ret.errno == 115 #FIXME: Should be 0! # close directory # close directory # TODO: disabled for now because we have no way to keep DIR* alive # TODO: disabled for now because we have no way to keep DIR* alive # between gkfs.io executions # between gkfs.io executions # ret = gkfs_client.opendir(XXX) # ret = gkfs_client.opendir(XXX) # assert ret.errno == 115 #FIXME: Should be 0! # populate top directory # populate top directory Loading @@ -99,14 +93,12 @@ def test_mkdir(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! ret = gkfs_client.open(file_a, ret = gkfs_client.open(file_a, os.O_CREAT, os.O_CREAT, stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval != -1 assert ret.retval != -1 assert ret.errno == 115 #FIXME: Should be 0! ret = gkfs_client.readdir(gkfs_daemon.mountdir) ret = gkfs_client.readdir(gkfs_daemon.mountdir) Loading @@ -114,7 +106,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): assert len(ret.dirents) == 1 assert len(ret.dirents) == 1 assert ret.dirents[0].d_name == 'top' assert ret.dirents[0].d_name == 'top' assert ret.dirents[0].d_type == 4 # DT_DIR assert ret.dirents[0].d_type == 4 # DT_DIR assert ret.errno == 115 #FIXME: Should be 0! expected = [ expected = [ ( dir_a.name, 4 ), # DT_DIR ( dir_a.name, 4 ), # DT_DIR Loading @@ -124,7 +115,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.readdir(topdir) ret = gkfs_client.readdir(topdir) assert len(ret.dirents) == len(expected) assert len(ret.dirents) == len(expected) assert ret.errno == 115 #FIXME: Should be 0! for d,e in zip(ret.dirents, expected): for d,e in zip(ret.dirents, expected): assert d.d_name == e[0] assert d.d_name == e[0] Loading @@ -141,7 +131,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! expected = [ expected = [ ( topdir.name, 4 ), # DT_DIR ( topdir.name, 4 ), # DT_DIR Loading @@ -150,7 +139,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.readdir(gkfs_daemon.mountdir) ret = gkfs_client.readdir(gkfs_daemon.mountdir) assert len(ret.dirents) == len(expected) assert len(ret.dirents) == len(expected) assert ret.errno == 115 #FIXME: Should be 0! for d,e in zip(ret.dirents, expected): for d,e in zip(ret.dirents, expected): assert d.d_name == e[0] assert d.d_name == e[0] Loading @@ -162,7 +150,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! expected = [ expected = [ ( topdir.name, 4 ), # DT_DIR ( topdir.name, 4 ), # DT_DIR Loading @@ -171,7 +158,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.readdir(gkfs_daemon.mountdir) ret = gkfs_client.readdir(gkfs_daemon.mountdir) assert len(ret.dirents) == len(expected) assert len(ret.dirents) == len(expected) assert ret.errno == 115 #FIXME: Should be 0! for d,e in zip(ret.dirents, expected): for d,e in zip(ret.dirents, expected): assert d.d_name == e[0] assert d.d_name == e[0] Loading @@ -184,7 +170,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.readdir(dir_a) ret = gkfs_client.readdir(dir_a) assert len(ret.dirents) == len(expected) assert len(ret.dirents) == len(expected) assert ret.errno == 115 #FIXME: Should be 0! for d,e in zip(ret.dirents, expected): for d,e in zip(ret.dirents, expected): assert d.d_name == e[0] assert d.d_name == e[0] Loading tests/integration/forwarding/test_map.py +0 −22 Original line number Original line Diff line number Diff line Loading @@ -44,14 +44,12 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = c00.write(file, buf, len(buf)) ret = c00.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = c00.open(file, ret = c00.open(file, Loading @@ -59,14 +57,12 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = c00.read(file, len(buf)) ret = c00.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! file = d01.mountdir / "file-c01" file = d01.mountdir / "file-c01" Loading @@ -77,14 +73,12 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = c01.write(file, buf, len(buf)) ret = c01.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = c01.open(file, ret = c01.open(file, Loading @@ -92,14 +86,12 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = c01.read(file, len(buf)) ret = c01.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! # both files should be there and accessible by the two clients # both files should be there and accessible by the two clients ret = c00.readdir(d00.mountdir) ret = c00.readdir(d00.mountdir) Loading @@ -108,11 +100,9 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_type == 8 # DT_REG assert ret.dirents[0].d_type == 8 # DT_REG assert ret.errno == 115 #FIXME: Should be 0! assert ret.dirents[1].d_name == 'file-c01' assert ret.dirents[1].d_name == 'file-c01' assert ret.dirents[1].d_type == 8 # DT_REG assert ret.dirents[1].d_type == 8 # DT_REG assert ret.errno == 115 #FIXME: Should be 0! with open(c00.log) as f: with open(c00.log) as f: lines = f.readlines() lines = f.readlines() Loading Loading @@ -149,14 +139,12 @@ def test_two_io_nodes_remap(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = c00.write(file, buf, len(buf)) ret = c00.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! with open(c00.log) as f: with open(c00.log) as f: lines = f.readlines() lines = f.readlines() Loading @@ -181,14 +169,12 @@ def test_two_io_nodes_remap(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file buf = b'24' buf = b'24' ret = c00.write(file, buf, len(buf)) ret = c00.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! with open(c00.log) as f: with open(c00.log) as f: lines = f.readlines() lines = f.readlines() Loading Loading @@ -216,14 +202,12 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = c00.write(file, buf, len(buf)) ret = c00.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = c00.open(file, ret = c00.open(file, Loading @@ -231,14 +215,12 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = c00.read(file, len(buf)) ret = c00.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = c01.open(file, ret = c01.open(file, Loading @@ -246,14 +228,12 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = c01.read(file, len(buf)) ret = c01.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! # the file should be there and accessible by the two clients # the file should be there and accessible by the two clients ret = c00.readdir(d00.mountdir) ret = c00.readdir(d00.mountdir) Loading @@ -262,7 +242,6 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_type == 8 # DT_REG assert ret.dirents[0].d_type == 8 # DT_REG assert ret.errno == 115 #FIXME: Should be 0! # the file should be there and accessible by the two clients # the file should be there and accessible by the two clients ret = c01.readdir(d01.mountdir) ret = c01.readdir(d01.mountdir) Loading @@ -271,7 +250,6 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_type == 8 # DT_REG assert ret.dirents[0].d_type == 8 # DT_REG assert ret.errno == 115 #FIXME: Should be 0! with open(c00.log) as f: with open(c00.log) as f: lines = f.readlines() lines = f.readlines() Loading tests/integration/operations/test_read_operations.py +1 −17 Original line number Original line Diff line number Diff line Loading @@ -35,14 +35,12 @@ def test_read(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = gkfs_client.write(file, buf, len(buf)) ret = gkfs_client.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = gkfs_client.open(file, ret = gkfs_client.open(file, Loading @@ -50,14 +48,12 @@ def test_read(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = gkfs_client.read(file, len(buf)) ret = gkfs_client.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! def test_pread(gkfs_daemon, gkfs_client): def test_pread(gkfs_daemon, gkfs_client): Loading @@ -69,14 +65,12 @@ def test_pread(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = gkfs_client.pwrite(file, buf, len(buf), 1024) ret = gkfs_client.pwrite(file, buf, len(buf), 1024) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = gkfs_client.open(file, ret = gkfs_client.open(file, Loading @@ -84,14 +78,12 @@ def test_pread(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file at offset 1024 # read the file at offset 1024 ret = gkfs_client.pread(file, len(buf), 1024) ret = gkfs_client.pread(file, len(buf), 1024) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! def test_readv(gkfs_daemon, gkfs_client): def test_readv(gkfs_daemon, gkfs_client): Loading @@ -103,7 +95,6 @@ def test_readv(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf_0 = b'42' buf_0 = b'42' Loading @@ -111,7 +102,6 @@ def test_readv(gkfs_daemon, gkfs_client): ret = gkfs_client.writev(file, buf_0, buf_1, 2) ret = gkfs_client.writev(file, buf_0, buf_1, 2) assert ret.retval == len(buf_0) + len(buf_1) # Return the number of written bytes assert ret.retval == len(buf_0) + len(buf_1) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = gkfs_client.open(file, ret = gkfs_client.open(file, Loading @@ -119,7 +109,6 @@ def test_readv(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = gkfs_client.readv(file, len(buf_0), len(buf_1)) ret = gkfs_client.readv(file, len(buf_0), len(buf_1)) Loading @@ -127,7 +116,6 @@ def test_readv(gkfs_daemon, gkfs_client): assert ret.buf_0 == buf_0 assert ret.buf_0 == buf_0 assert ret.buf_1 == buf_1 assert ret.buf_1 == buf_1 assert ret.retval == len(buf_0) + len(buf_1) # Return the number of read bytes assert ret.retval == len(buf_0) + len(buf_1) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! def test_preadv(gkfs_daemon, gkfs_client): def test_preadv(gkfs_daemon, gkfs_client): Loading @@ -139,7 +127,6 @@ def test_preadv(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf_0 = b'42' buf_0 = b'42' Loading @@ -147,7 +134,6 @@ def test_preadv(gkfs_daemon, gkfs_client): ret = gkfs_client.pwritev(file, buf_0, buf_1, 2, 1024) ret = gkfs_client.pwritev(file, buf_0, buf_1, 2, 1024) assert ret.retval == len(buf_0) + len(buf_1) # Return the number of written bytes assert ret.retval == len(buf_0) + len(buf_1) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = gkfs_client.open(file, ret = gkfs_client.open(file, Loading @@ -155,7 +141,6 @@ def test_preadv(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = gkfs_client.preadv(file, len(buf_0), len(buf_1), 1024) ret = gkfs_client.preadv(file, len(buf_0), len(buf_1), 1024) Loading @@ -163,4 +148,3 @@ def test_preadv(gkfs_daemon, gkfs_client): assert ret.buf_0 == buf_0 assert ret.buf_0 == buf_0 assert ret.buf_1 == buf_1 assert ret.buf_1 == buf_1 assert ret.retval == len(buf_0) + len(buf_1) # Return the number of read bytes assert ret.retval == len(buf_0) + len(buf_1) # Return the number of read bytes No newline at end of file assert ret.errno == 115 #FIXME: Should be 0! No newline at end of file Loading
tests/integration/data/test_data_integrity.py +0 −1 Original line number Original line Diff line number Diff line Loading @@ -47,7 +47,6 @@ def test_data_integrity(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! # test stat on existing dir # test stat on existing dir ret = gkfs_client.stat(topdir) ret = gkfs_client.stat(topdir) Loading
tests/integration/data/test_truncate.py +0 −12 Original line number Original line Diff line number Diff line Loading @@ -37,11 +37,9 @@ def test_truncate(gkfs_daemon, gkfs_client): ret = gkfs_client.write_random(truncfile, buf_length) ret = gkfs_client.write_random(truncfile, buf_length) assert ret.retval == buf_length assert ret.retval == buf_length assert ret.errno == 115 # FIXME: Should be 0! ret = gkfs_client.stat(truncfile) ret = gkfs_client.stat(truncfile) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == buf_length assert ret.statbuf.st_size == buf_length # truncate it # truncate it Loading @@ -49,12 +47,10 @@ def test_truncate(gkfs_daemon, gkfs_client): trunc_size = buf_length // 2 trunc_size = buf_length // 2 ret = gkfs_client.truncate(truncfile, trunc_size) ret = gkfs_client.truncate(truncfile, trunc_size) assert ret.errno == 115 # FIXME: Should be 0! assert ret.retval == 0 assert ret.retval == 0 # check file length # check file length ret = gkfs_client.stat(truncfile) ret = gkfs_client.stat(truncfile) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == trunc_size assert ret.statbuf.st_size == trunc_size # verify contents by writing a new file (random content is seeded) and checksum both # verify contents by writing a new file (random content is seeded) and checksum both Loading @@ -69,30 +65,25 @@ def test_truncate(gkfs_daemon, gkfs_client): ret = gkfs_client.write_random(truncfile_verify, trunc_size) ret = gkfs_client.write_random(truncfile_verify, trunc_size) assert ret.retval == trunc_size assert ret.retval == trunc_size assert ret.errno == 115 # FIXME: Should be 0! ret = gkfs_client.stat(truncfile_verify) ret = gkfs_client.stat(truncfile_verify) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == trunc_size assert ret.statbuf.st_size == trunc_size ret = gkfs_client.file_compare(truncfile, truncfile_verify, trunc_size) ret = gkfs_client.file_compare(truncfile, truncfile_verify, trunc_size) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 # FIXME: Should be 0! # trunc at byte 712345 (middle of chunk) # trunc at byte 712345 (middle of chunk) # TODO feed chunksize into test to make sure it is always in the middle of the chunk # TODO feed chunksize into test to make sure it is always in the middle of the chunk trunc_size = 712345 trunc_size = 712345 ret = gkfs_client.truncate(truncfile, trunc_size) ret = gkfs_client.truncate(truncfile, trunc_size) assert ret.errno == 115 # FIXME: Should be 0! assert ret.retval == 0 assert ret.retval == 0 # check file length # check file length ret = gkfs_client.stat(truncfile) ret = gkfs_client.stat(truncfile) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == trunc_size assert ret.statbuf.st_size == trunc_size # verify contents by writing a new file (random content is seeded) and checksum both # verify contents by writing a new file (random content is seeded) and checksum both Loading @@ -107,14 +98,11 @@ def test_truncate(gkfs_daemon, gkfs_client): ret = gkfs_client.write_random(truncfile_verify_2, trunc_size) ret = gkfs_client.write_random(truncfile_verify_2, trunc_size) assert ret.retval == trunc_size assert ret.retval == trunc_size assert ret.errno == 115 # FIXME: Should be 0! ret = gkfs_client.stat(truncfile_verify_2) ret = gkfs_client.stat(truncfile_verify_2) assert ret.errno == 115 # FIXME: Should be 0! assert ret.statbuf.st_size == trunc_size assert ret.statbuf.st_size == trunc_size ret = gkfs_client.file_compare(truncfile, truncfile_verify_2, trunc_size) ret = gkfs_client.file_compare(truncfile, truncfile_verify_2, trunc_size) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 # FIXME: Should be 0!
tests/integration/directories/test_directories.py +0 −15 Original line number Original line Diff line number Diff line Loading @@ -42,19 +42,16 @@ def test_mkdir(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! # test stat on existing dir # test stat on existing dir ret = gkfs_client.stat(topdir) ret = gkfs_client.stat(topdir) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! assert stat.S_ISDIR(ret.statbuf.st_mode) assert stat.S_ISDIR(ret.statbuf.st_mode) # open topdir # open topdir ret = gkfs_client.open(topdir, os.O_DIRECTORY) ret = gkfs_client.open(topdir, os.O_DIRECTORY) assert ret.retval != -1 assert ret.retval != -1 assert ret.errno == 115 #FIXME: Should be 0! # read and write should be impossible on directories # read and write should be impossible on directories Loading @@ -77,19 +74,16 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.opendir(topdir) ret = gkfs_client.opendir(topdir) assert ret.dirp is not None assert ret.dirp is not None assert ret.errno == 115 #FIXME: Should be 0! ret = gkfs_client.readdir(topdir) ret = gkfs_client.readdir(topdir) # XXX: This might change in the future if we add '.' and '..' # XXX: This might change in the future if we add '.' and '..' assert len(ret.dirents) == 0 assert len(ret.dirents) == 0 assert ret.errno == 115 #FIXME: Should be 0! # close directory # close directory # TODO: disabled for now because we have no way to keep DIR* alive # TODO: disabled for now because we have no way to keep DIR* alive # between gkfs.io executions # between gkfs.io executions # ret = gkfs_client.opendir(XXX) # ret = gkfs_client.opendir(XXX) # assert ret.errno == 115 #FIXME: Should be 0! # populate top directory # populate top directory Loading @@ -99,14 +93,12 @@ def test_mkdir(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! ret = gkfs_client.open(file_a, ret = gkfs_client.open(file_a, os.O_CREAT, os.O_CREAT, stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval != -1 assert ret.retval != -1 assert ret.errno == 115 #FIXME: Should be 0! ret = gkfs_client.readdir(gkfs_daemon.mountdir) ret = gkfs_client.readdir(gkfs_daemon.mountdir) Loading @@ -114,7 +106,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): assert len(ret.dirents) == 1 assert len(ret.dirents) == 1 assert ret.dirents[0].d_name == 'top' assert ret.dirents[0].d_name == 'top' assert ret.dirents[0].d_type == 4 # DT_DIR assert ret.dirents[0].d_type == 4 # DT_DIR assert ret.errno == 115 #FIXME: Should be 0! expected = [ expected = [ ( dir_a.name, 4 ), # DT_DIR ( dir_a.name, 4 ), # DT_DIR Loading @@ -124,7 +115,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.readdir(topdir) ret = gkfs_client.readdir(topdir) assert len(ret.dirents) == len(expected) assert len(ret.dirents) == len(expected) assert ret.errno == 115 #FIXME: Should be 0! for d,e in zip(ret.dirents, expected): for d,e in zip(ret.dirents, expected): assert d.d_name == e[0] assert d.d_name == e[0] Loading @@ -141,7 +131,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! expected = [ expected = [ ( topdir.name, 4 ), # DT_DIR ( topdir.name, 4 ), # DT_DIR Loading @@ -150,7 +139,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.readdir(gkfs_daemon.mountdir) ret = gkfs_client.readdir(gkfs_daemon.mountdir) assert len(ret.dirents) == len(expected) assert len(ret.dirents) == len(expected) assert ret.errno == 115 #FIXME: Should be 0! for d,e in zip(ret.dirents, expected): for d,e in zip(ret.dirents, expected): assert d.d_name == e[0] assert d.d_name == e[0] Loading @@ -162,7 +150,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 0 assert ret.retval == 0 assert ret.errno == 115 #FIXME: Should be 0! expected = [ expected = [ ( topdir.name, 4 ), # DT_DIR ( topdir.name, 4 ), # DT_DIR Loading @@ -171,7 +158,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.readdir(gkfs_daemon.mountdir) ret = gkfs_client.readdir(gkfs_daemon.mountdir) assert len(ret.dirents) == len(expected) assert len(ret.dirents) == len(expected) assert ret.errno == 115 #FIXME: Should be 0! for d,e in zip(ret.dirents, expected): for d,e in zip(ret.dirents, expected): assert d.d_name == e[0] assert d.d_name == e[0] Loading @@ -184,7 +170,6 @@ def test_mkdir(gkfs_daemon, gkfs_client): ret = gkfs_client.readdir(dir_a) ret = gkfs_client.readdir(dir_a) assert len(ret.dirents) == len(expected) assert len(ret.dirents) == len(expected) assert ret.errno == 115 #FIXME: Should be 0! for d,e in zip(ret.dirents, expected): for d,e in zip(ret.dirents, expected): assert d.d_name == e[0] assert d.d_name == e[0] Loading
tests/integration/forwarding/test_map.py +0 −22 Original line number Original line Diff line number Diff line Loading @@ -44,14 +44,12 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = c00.write(file, buf, len(buf)) ret = c00.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = c00.open(file, ret = c00.open(file, Loading @@ -59,14 +57,12 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = c00.read(file, len(buf)) ret = c00.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! file = d01.mountdir / "file-c01" file = d01.mountdir / "file-c01" Loading @@ -77,14 +73,12 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = c01.write(file, buf, len(buf)) ret = c01.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = c01.open(file, ret = c01.open(file, Loading @@ -92,14 +86,12 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = c01.read(file, len(buf)) ret = c01.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! # both files should be there and accessible by the two clients # both files should be there and accessible by the two clients ret = c00.readdir(d00.mountdir) ret = c00.readdir(d00.mountdir) Loading @@ -108,11 +100,9 @@ def test_two_io_nodes(gkfwd_daemon_factory, gkfwd_client_factory): assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_type == 8 # DT_REG assert ret.dirents[0].d_type == 8 # DT_REG assert ret.errno == 115 #FIXME: Should be 0! assert ret.dirents[1].d_name == 'file-c01' assert ret.dirents[1].d_name == 'file-c01' assert ret.dirents[1].d_type == 8 # DT_REG assert ret.dirents[1].d_type == 8 # DT_REG assert ret.errno == 115 #FIXME: Should be 0! with open(c00.log) as f: with open(c00.log) as f: lines = f.readlines() lines = f.readlines() Loading Loading @@ -149,14 +139,12 @@ def test_two_io_nodes_remap(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = c00.write(file, buf, len(buf)) ret = c00.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! with open(c00.log) as f: with open(c00.log) as f: lines = f.readlines() lines = f.readlines() Loading @@ -181,14 +169,12 @@ def test_two_io_nodes_remap(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file buf = b'24' buf = b'24' ret = c00.write(file, buf, len(buf)) ret = c00.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! with open(c00.log) as f: with open(c00.log) as f: lines = f.readlines() lines = f.readlines() Loading Loading @@ -216,14 +202,12 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = c00.write(file, buf, len(buf)) ret = c00.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = c00.open(file, ret = c00.open(file, Loading @@ -231,14 +215,12 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = c00.read(file, len(buf)) ret = c00.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = c01.open(file, ret = c01.open(file, Loading @@ -246,14 +228,12 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = c01.read(file, len(buf)) ret = c01.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! # the file should be there and accessible by the two clients # the file should be there and accessible by the two clients ret = c00.readdir(d00.mountdir) ret = c00.readdir(d00.mountdir) Loading @@ -262,7 +242,6 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_type == 8 # DT_REG assert ret.dirents[0].d_type == 8 # DT_REG assert ret.errno == 115 #FIXME: Should be 0! # the file should be there and accessible by the two clients # the file should be there and accessible by the two clients ret = c01.readdir(d01.mountdir) ret = c01.readdir(d01.mountdir) Loading @@ -271,7 +250,6 @@ def test_two_io_nodes_operations(gkfwd_daemon_factory, gkfwd_client_factory): assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_name == 'file-c00' assert ret.dirents[0].d_type == 8 # DT_REG assert ret.dirents[0].d_type == 8 # DT_REG assert ret.errno == 115 #FIXME: Should be 0! with open(c00.log) as f: with open(c00.log) as f: lines = f.readlines() lines = f.readlines() Loading
tests/integration/operations/test_read_operations.py +1 −17 Original line number Original line Diff line number Diff line Loading @@ -35,14 +35,12 @@ def test_read(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = gkfs_client.write(file, buf, len(buf)) ret = gkfs_client.write(file, buf, len(buf)) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = gkfs_client.open(file, ret = gkfs_client.open(file, Loading @@ -50,14 +48,12 @@ def test_read(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = gkfs_client.read(file, len(buf)) ret = gkfs_client.read(file, len(buf)) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! def test_pread(gkfs_daemon, gkfs_client): def test_pread(gkfs_daemon, gkfs_client): Loading @@ -69,14 +65,12 @@ def test_pread(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf = b'42' buf = b'42' ret = gkfs_client.pwrite(file, buf, len(buf), 1024) ret = gkfs_client.pwrite(file, buf, len(buf), 1024) assert ret.retval == len(buf) # Return the number of written bytes assert ret.retval == len(buf) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = gkfs_client.open(file, ret = gkfs_client.open(file, Loading @@ -84,14 +78,12 @@ def test_pread(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file at offset 1024 # read the file at offset 1024 ret = gkfs_client.pread(file, len(buf), 1024) ret = gkfs_client.pread(file, len(buf), 1024) assert ret.buf == buf assert ret.buf == buf assert ret.retval == len(buf) # Return the number of read bytes assert ret.retval == len(buf) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! def test_readv(gkfs_daemon, gkfs_client): def test_readv(gkfs_daemon, gkfs_client): Loading @@ -103,7 +95,6 @@ def test_readv(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf_0 = b'42' buf_0 = b'42' Loading @@ -111,7 +102,6 @@ def test_readv(gkfs_daemon, gkfs_client): ret = gkfs_client.writev(file, buf_0, buf_1, 2) ret = gkfs_client.writev(file, buf_0, buf_1, 2) assert ret.retval == len(buf_0) + len(buf_1) # Return the number of written bytes assert ret.retval == len(buf_0) + len(buf_1) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = gkfs_client.open(file, ret = gkfs_client.open(file, Loading @@ -119,7 +109,6 @@ def test_readv(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = gkfs_client.readv(file, len(buf_0), len(buf_1)) ret = gkfs_client.readv(file, len(buf_0), len(buf_1)) Loading @@ -127,7 +116,6 @@ def test_readv(gkfs_daemon, gkfs_client): assert ret.buf_0 == buf_0 assert ret.buf_0 == buf_0 assert ret.buf_1 == buf_1 assert ret.buf_1 == buf_1 assert ret.retval == len(buf_0) + len(buf_1) # Return the number of read bytes assert ret.retval == len(buf_0) + len(buf_1) # Return the number of read bytes assert ret.errno == 115 #FIXME: Should be 0! def test_preadv(gkfs_daemon, gkfs_client): def test_preadv(gkfs_daemon, gkfs_client): Loading @@ -139,7 +127,6 @@ def test_preadv(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # write a buffer we know # write a buffer we know buf_0 = b'42' buf_0 = b'42' Loading @@ -147,7 +134,6 @@ def test_preadv(gkfs_daemon, gkfs_client): ret = gkfs_client.pwritev(file, buf_0, buf_1, 2, 1024) ret = gkfs_client.pwritev(file, buf_0, buf_1, 2, 1024) assert ret.retval == len(buf_0) + len(buf_1) # Return the number of written bytes assert ret.retval == len(buf_0) + len(buf_1) # Return the number of written bytes assert ret.errno == 115 #FIXME: Should be 0! # open the file to read # open the file to read ret = gkfs_client.open(file, ret = gkfs_client.open(file, Loading @@ -155,7 +141,6 @@ def test_preadv(gkfs_daemon, gkfs_client): stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) stat.S_IRWXU | stat.S_IRWXG | stat.S_IRWXO) assert ret.retval == 10000 assert ret.retval == 10000 assert ret.errno == 115 #FIXME: Should be 0! # read the file # read the file ret = gkfs_client.preadv(file, len(buf_0), len(buf_1), 1024) ret = gkfs_client.preadv(file, len(buf_0), len(buf_1), 1024) Loading @@ -163,4 +148,3 @@ def test_preadv(gkfs_daemon, gkfs_client): assert ret.buf_0 == buf_0 assert ret.buf_0 == buf_0 assert ret.buf_1 == buf_1 assert ret.buf_1 == buf_1 assert ret.retval == len(buf_0) + len(buf_1) # Return the number of read bytes assert ret.retval == len(buf_0) + len(buf_1) # Return the number of read bytes No newline at end of file assert ret.errno == 115 #FIXME: Should be 0! No newline at end of file