Function test_recursive_lock_acquisition

tests/test_read_write.py:296–304

(lock_file: str, mode: Literal["read", "write"])

)
@pytest.mark.timeout(_PROCESS_DEADLINE * 3)
def test_recursive_lock_acquisition(lock_file: str, mode: Literal["read", "write"]) -> None:
    success = Value("i", 0)
    worker = Process(target=recursive_lock, args=(lock_file, mode, success))

    with cleanup_processes([worker]):
        worker.start()
        worker.join(timeout=_PROCESS_DEADLINE)

    assert success.value == 1, "Recursive lock acquisition failed"


@pytest.mark.parametrize(