Function _run_simd_tests

ci/autoresearch/phases.py:1345–1425

Run SIMD test suite via RPC.

(ctx: RunContext)

async def _run_simd_tests(ctx: RunContext) -> int:
    """Run SIMD test suite via RPC."""
    upload_port = ctx.upload_port
    assert upload_port is not None
    serial_iface = ctx.serial_iface

    print()
    print("=" * 60)
    print("SIMD TEST MODE - Comprehensive Test Suite")
    print("=" * 60)
    print()

    client: RpcClient | None = None
    try:
        print("   Connecting to device...", end="", flush=True)
        client = RpcClient(upload_port, timeout=30.0, serial_interface=serial_iface)
        await client.connect(boot_wait=1.0)
        print(f" {Fore.GREEN}ok{Style.RESET_ALL}")

        print("   Sending testSimd RPC...", end="", flush=True)
        response = await client.send_and_match(
            "testSimd", match_key="passed", retries=3
        )
        print(f" {Fore.GREEN}ok{Style.RESET_ALL}")
        print()

        total = response.get("totalTests", 0)
        passed_count = response.get("passedTests", 0)
        failed_count = response.get("failedTests", 0)
        failures = response.get("failures", [])

        print(f"   Results: {passed_count}/{total} passed", end="")
        if failed_count > 0:
            print(f", {failed_count} FAILED")
        else:
            print()

        if failures:
            print()
            print(f"   {Fore.RED}Failed tests:{Style.RESET_ALL}")
            for name in failures:
                print(f"     - {name}")

        print()
        simd_passed = response.get("passed", False)

        print("   Sending testSimdBenchmark RPC...", end="", flush=True)
        bench = await client.send_and_match(
            "testSimdBenchmark", match_key="success", retries=2
        )
        print(f" {Fore.GREEN}ok{Style.RESET_ALL}")
        print()

        print(json.dumps(bench.data, indent=2))
        print()

        if simd_passed:
            print(f"{Fore.GREEN}SIMD TEST PASSED ({total} tests){Style.RESET_ALL}")