mirror of
https://github.com/SCST-project/scst.git
synced 2026-10-22 14:12:33 +00:00
Gleb Chesnokov
e69138598e
Run one fio profile with concurrent 4K, 64K and 128K jobs in disjoint regions. Cover buffered fileio with 512-byte sectors and direct blockio with 4K sectors. Verify CRC32C data and completed byte counts, and follow buffered I/O with direct verification to bypass the initiator page cache. Reuse the SCSI fixtures and exported-device checks for both transports. Require an explicit target block device and check its use and signatures before exporting it. Configure the per-job region size and I/O timeout, and retain rendered job files, JSON reports and stderr. Cover job rendering and report validation with framework tests. Document fio prerequisites, destructive scope and label selection through the common Make targets.
38 lines
1.3 KiB
Python
38 lines
1.3 KiB
Python
# SPDX-License-Identifier: GPL-2.0-only
|
|
"""Carry binary sg output and fio job text over the existing argv transport.
|
|
|
|
The caller supervises the entire process group, including the child. A child
|
|
signal is propagated so that the command runner latches uncertain execution.
|
|
"""
|
|
import base64
|
|
import json
|
|
import os
|
|
import signal
|
|
import subprocess
|
|
import sys
|
|
import tempfile
|
|
|
|
|
|
def main():
|
|
request = json.loads(sys.argv[1])
|
|
with tempfile.TemporaryDirectory(prefix="scst-dataio-") as directory:
|
|
argv = request["argv"]
|
|
if "fio_config" in request:
|
|
path = os.path.join(directory, "verify.fio")
|
|
with open(path, "w", encoding="ascii") as output:
|
|
output.write(request["fio_config"])
|
|
argv = ["fio", "--output-format=json", "--eta=never", path]
|
|
result = subprocess.run(
|
|
argv, input=base64.b64decode(request.get("input", "")),
|
|
stdout=subprocess.PIPE, stderr=subprocess.PIPE, cwd=directory,
|
|
env=dict(os.environ, LC_ALL="C"))
|
|
if result.returncode < 0:
|
|
os.kill(os.getpid(), signal.SIGKILL)
|
|
print(json.dumps({"exit_code": result.returncode,
|
|
"data": base64.b64encode(result.stdout).decode("ascii"),
|
|
"stderr": result.stderr.decode("utf-8", errors="replace")}))
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|