GithubFollow/One-KVM
1
0
Fork 0
mirror of https://github.com/mofeng-git/One-KVM.git synced 2026-07-29 12:41:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feta: 更新测试套件中的虚拟媒体部分测试

Browse Source
This commit is contained in:
mofeng-git
2026-07-12 17:04:37 +08:00
parent 54e0cbc84e
commit 139064de35
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
test/okvm-test/okvm_testctl.py
View File

@@ -160,6 +160,9 @@ class ApiClient:
def post(self, path: str, payload: dict[str, Any] | None = None) -> Any: def post(self, path: str, payload: dict[str, Any] | None = None) -> Any:
return self.request("POST", path, json=payload or {}) return self.request("POST", path, json=payload or {})
def delete(self, path: str) -> Any:
return self.request("DELETE", path)
def patch(self, path: str, payload: dict[str, Any]) -> Any: def patch(self, path: str, payload: dict[str, Any]) -> Any:
return self.request("PATCH", path, json=payload) return self.request("PATCH", path, json=payload)
@@ -1780,7 +1783,7 @@ echo "$BACKUP"
snapshot = await self.agent.command("msd_snapshot", {}, timeout=10) snapshot = await self.agent.command("msd_snapshot", {}, timeout=10)
known = [d["root"] for d in snapshot.get("drives", [])] known = [d["root"] for d in snapshot.get("drives", [])]
self.api.post("/msd/drive/init", {"size_mb": self.args.msd_size_mb}) self.api.post("/msd/drive/init", {"size_mb": self.args.msd_size_mb})
self.api.post("/msd/connect", {"mode": "drive"}) self.api.post("/msd/drive/mount", {})
drive = await self.agent.command("msd_wait_new", {"known": known, "timeout_ms": 60000}, timeout=70) drive = await self.agent.command("msd_wait_new", {"known": known, "timeout_ms": 60000}, timeout=70)
root = drive.get("root") root = drive.get("root")
verify = await self.agent.command( verify = await self.agent.command(
@@ -1794,12 +1797,12 @@ echo "$BACKUP"
self.reporter.metric("msd_read_mib_s", round(float(verify["read_mib_s"]), 2), "MiB/s") self.reporter.metric("msd_read_mib_s", round(float(verify["read_mib_s"]), 2), "MiB/s")
if "cached_read_mib_s" in verify: if "cached_read_mib_s" in verify:
self.reporter.metric("msd_cached_read_mib_s", round(float(verify["cached_read_mib_s"]), 2), "MiB/s") self.reporter.metric("msd_cached_read_mib_s", round(float(verify["cached_read_mib_s"]), 2), "MiB/s")
self.api.post("/msd/disconnect", {}) self.api.delete("/msd/drive/mount")
await self.agent.command("msd_wait_removed", {"root": root, "timeout_ms": 60000}, timeout=70) await self.agent.command("msd_wait_removed", {"root": root, "timeout_ms": 60000}, timeout=70)
self.reporter.add("msd", "PASS", "Windows detected virtual drive and read/write verification passed", drive=drive, verify=verify) self.reporter.add("msd", "PASS", "Windows detected virtual drive and read/write verification passed", drive=drive, verify=verify)
except Exception as exc: except Exception as exc:
try: try:
self.api.post("/msd/disconnect", {}) self.api.delete("/msd/drive/mount")
except Exception: except Exception:
pass pass
status = "SKIP" if is_msd_environment_error(str(exc)) else "FAIL" status = "SKIP" if is_msd_environment_error(str(exc)) else "FAIL"