mirror of
https://github.com/trapexit/mergerfs.git
synced 2026-10-19 16:16:48 +00:00
Antonio SJ Musumeci
84e4cdeb7e
- Add mergerfs_mount() context manager in posix_parity.py that creates temporary branch dirs in tests/.test_tmp/, mounts an ephemeral mergerfs instance, and cleans up after use. - Add find_mergerfs(), find_fusermount(), mount_mergerfs(), unmount_mergerfs() helpers. - Update run-tests to invoke each TEST_* script without a mountpoint arg. - Update README.md to document the new `python3 tests/run-tests` invocation. - Fix 44 tests to use mergerfs_mount() instead of expecting a pre-mounted path. - Add tempfile import to 10 tests that were missing it. - Fix TEST_mount_lifecycle to use mergerfs_mount() context manager. - Fix TEST_posix_tmpfile missing join import. - Fix TEST_cfg_xattr_modes error message framing (no "(known bug)"). - Fix TEST_posix_copy_file_range: loop-copy full size, compare st_size and SHA256 hash; add NativeTmp for space management; route native temp to tests/.test_tmp/ to avoid ENOSPC on /tmp. - Fix TEST_posix_getattr_fgetattr: st_cmp skips st_size for dirs; add compare_ino param for safe inode comparison when inodecalc=passthrough. - Fix TEST_unlink_rename, TEST_use_* tests: namespace cleanup, consistent variable naming, None check for cmpfunc. - Fix TEST_readlink_semantics: remove type annotations to support older Python; wrap in mergerfs_mount() try/except. - Add flush=True to run-tests print so test names show immediately.
74 lines
1.9 KiB
Python
Executable File
74 lines
1.9 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
|
|
import tempfile
|
|
import ctypes
|
|
import mmap
|
|
import os
|
|
import resource
|
|
import sys
|
|
|
|
from posix_parity import mergerfs_mount
|
|
|
|
|
|
libc = ctypes.CDLL(None, use_errno=True)
|
|
libc.read.argtypes = [ctypes.c_int, ctypes.c_void_p, ctypes.c_size_t]
|
|
libc.read.restype = ctypes.c_ssize_t
|
|
|
|
|
|
def aligned_read(fd, size):
|
|
buf = mmap.mmap(-1, size)
|
|
ptr = ctypes.addressof(ctypes.c_char.from_buffer(buf))
|
|
ctypes.set_errno(0)
|
|
rv = libc.read(fd, ctypes.c_void_p(ptr), size)
|
|
if rv < 0:
|
|
err = ctypes.get_errno()
|
|
buf.close()
|
|
raise OSError(err, os.strerror(err))
|
|
data = buf[:rv]
|
|
buf.close()
|
|
return data
|
|
|
|
|
|
def main():
|
|
try:
|
|
with mergerfs_mount() as (mount, _):
|
|
(fd, filepath) = tempfile.mkstemp(dir=mount)
|
|
|
|
os.close(fd)
|
|
|
|
fd = os.open(filepath, os.O_RDWR|os.O_DIRECT|os.O_TRUNC)
|
|
|
|
os.unlink(filepath)
|
|
|
|
size = resource.getpagesize()
|
|
pattern = (b"mergerfs-o-direct" * ((size // 16) + 1))[:size]
|
|
buf = mmap.mmap(-1, size)
|
|
buf.write(pattern)
|
|
buf.seek(0)
|
|
|
|
try:
|
|
written = os.write(fd, buf)
|
|
if written != size:
|
|
print(f"O_DIRECT short write: wrote {written}, expected {size}", end="")
|
|
return 1
|
|
os.lseek(fd, 0, os.SEEK_SET)
|
|
data = aligned_read(fd, size)
|
|
if len(data) != size:
|
|
print(f"O_DIRECT short read: read {len(data)}, expected {size}", end="")
|
|
return 1
|
|
if data != pattern:
|
|
print("O_DIRECT data mismatch", end="")
|
|
return 1
|
|
finally:
|
|
buf.close()
|
|
os.close(fd)
|
|
|
|
return 0
|
|
except RuntimeError as exc:
|
|
print(str(exc), end="")
|
|
return 77
|
|
|
|
|
|
if __name__ == "__main__":
|
|
raise SystemExit(main())
|