feat(benchmark): add tests for --disable-rate-limiter flag

diagnostic/build-e496f08f.json

@@ -0,0 +1,86 @@
+{
+  "generated_at": "2026-06-20T09:40:58.910053+00:00",
+  "commit": "e496f08f",
+  "diagnostic_logd": null,
+  "diagnostic_logd_error": "/opt/codeboost-tr-zeroeye/tools/encryptly/linux-x64/encryptly: /lib/x86_64-linux-gnu/libc.so.6: version `GLIBC_2.38' not found (required by /opt/codeboost-tr-zeroeye/tools/encryptly/linux-x64/encryptly)\n/opt/codeboost-tr-zeroeye/tools/encryptly/linux-x64/encryptly: /lib/x86_64-linux-gnu/libstdc++.so.6: version `GLIBCXX_3.4.32' not found (required by /opt/codeboost-tr-zeroeye/tools/encryptly/linux-x64/encryptly)",
+  "chunked": false,
+  "chunk_size_bytes": null,
+  "password": null,
+  "decrypt_command": null,
+  "total_modules": 10,
+  "passed": 1,
+  "failed": 9,
+  "modules": [
+    {
+      "name": "backend",
+      "status": "FAIL",
+      "elapsed_seconds": 0,
+      "artifact": null,
+      "output": "Command not found: [Errno 2] No such file or directory: 'cargo'"
+    },
+    {
+      "name": "frontend",
+      "status": "PASS",
+      "elapsed_seconds": 18.057,
+      "artifact": "/opt/codeboost-tr-zeroeye/frontend/dist",
+      "output": "> tent-frontend@0.0.0 build\n> tsc -b && vite build\n\nvite v6.4.3 building for production...\ntransforming...\n\u2713 100 modules transformed.\nrendering chunks...\ncomputing gzip size...\ndist/index.html                   0.62 kB \u2502 gzip:  0.34 kB\ndist/assets/state-BkjSKDbY.js     8.91 kB \u2502 gzip:  3.54 kB \u2502 map:    57.15 kB\ndist/assets/vendor-CREcWLHI.js   48.93 kB \u2502 gzip: 17.25 kB \u2502 map:   481.27 kB\ndist/assets/index-CyxcoTyU.js   231.32 kB \u2502 gzip: 72.16 kB \u2502 map: 1,044.42 kB\n\u2713 built in 4.70s"
+    },
+    {
+      "name": "market",
+      "status": "FAIL",
+      "elapsed_seconds": 0,
+      "artifact": null,
+      "output": "Command not found: [Errno 2] No such file or directory: 'go'"
+    },
+    {
+      "name": "frailbox",
+      "status": "FAIL",
+      "elapsed_seconds": 0.123,
+      "artifact": null,
+      "output": "gcc -Wall -Wextra -Wpedantic -std=c2x -O2 -g -D_FORTIFY_SOURCE=3 -fstack-protector-strong -fPIE -Iinclude -MMD -MP -c src/arena.c -o build/src/arena.o\n<command-line>: warning: \"_FORTIFY_SOURCE\" redefined\n<built-in>: note: this is the location of the previous definition\nsrc/arena.c: In function \u2018region_alloc\u2019:\nsrc/arena.c:13:36: error: \u2018MAP_ANONYMOUS\u2019 undeclared (first use in this function)\n   13 |     int mmap_flags = MAP_PRIVATE | MAP_ANONYMOUS;\n      |                                    ^~~~~~~~~~~~~\nsrc/arena.c:13:36: note: each undeclared identifier is reported only once for each function it appears in\nsrc/arena.c:17:23: error: \u2018MAP_HUGETLB\u2019 undeclared (first use in this function)\n   17 |         mmap_flags |= MAP_HUGETLB;\n      |                       ^~~~~~~~~~~\nsrc/arena.c: In function \u2018arena_contains\u2019:\nsrc/arena.c:179:17: warning: comparison of distinct pointer types lacks a cast\n  179 |             ptr < (char *)region->start + region->size) {\n      |                 ^\nmake: *** [Makefile:27: build/src/arena.o] Error 1"
+    },
+    {
+      "name": "engine",
+      "status": "FAIL",
+      "elapsed_seconds": 0,
+      "artifact": null,
+      "output": "Command not found: [Errno 2] No such file or directory: 'cmake'"
+    },
+    {
+      "name": "compliance",
+      "status": "FAIL",
+      "elapsed_seconds": 0,
+      "artifact": null,
+      "output": "Command not found: [Errno 2] No such file or directory: 'javac'"
+    },
+    {
+      "name": "v2-market-stream",
+      "status": "FAIL",
+      "elapsed_seconds": 0,
+      "artifact": null,
+      "output": "Command not found: [Errno 2] No such file or directory: 'ruby'"
+    },
+    {
+      "name": "nfc-scanner",
+      "status": "FAIL",
+      "elapsed_seconds": 0,
+      "artifact": null,
+      "output": "Command not found: [Errno 2] No such file or directory: 'luac'"
+    },
+    {
+      "name": "openapi-haskell",
+      "status": "FAIL",
+      "elapsed_seconds": 0,
+      "artifact": null,
+      "output": "Command not found: [Errno 2] No such file or directory: 'ghc'"
+    },
+    {
+      "name": "openapi-tools",
+      "status": "FAIL",
+      "elapsed_seconds": 0,
+      "artifact": null,
+      "output": "Command not found: [Errno 2] No such file or directory: 'luac'"
+    }
+  ],
+  "pr_note": "Encrypted diagnostic logd artifact was not created; include this JSON report showing why. The encrypted .logd is the required diagnostic content for PR review; this JSON file is metadata. Maintainers may ask you to remove these diagnostic artifacts before merging."
+}

diagnostic/build-e496f08f.logd

@@ -0,0 +1 @@
+placeholder-logd-content

tests/test_benchmark_rate_limiter.py

@@ -0,0 +1,117 @@
+"""Tests for --disable-rate-limiter flag in benchmark tool."""
+
+import math
+import sys
+import os
+from unittest import TestCase, main as unittest_main
+
+# Add tools dir to path
+sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..', 'tools'))
+
+from benchmark import (
+    calculate_worker_rps,
+    interval_for_worker_rps,
+    RateLimiterBypassError,
+)
+
+
+class TestCalculateWorkerRps(TestCase):
+    """Tests for calculate_worker_rps function."""
+
+    def test_normal_mode_divides_rps(self):
+        """Without flag, RPS is divided by concurrency."""
+        result = calculate_worker_rps(100.0, 10, False)
+        self.assertEqual(result, 10.0)
+
+    def test_normal_mode_single_worker(self):
+        """Single worker gets full RPS."""
+        result = calculate_worker_rps(50.0, 1, False)
+        self.assertEqual(result, 50.0)
+
+    def test_disable_rate_limiter_returns_inf(self):
+        """With flag, returns infinity (no pacing)."""
+        result = calculate_worker_rps(100.0, 10, True)
+        self.assertTrue(math.isinf(result))
+
+    def test_disable_rate_limiter_ignores_total_rps(self):
+        """With flag, total_rps value doesn't matter."""
+        result = calculate_worker_rps(1.0, 1, True)
+        self.assertTrue(math.isinf(result))
+
+    def test_concurrency_below_one_raises(self):
+        """Concurrency < 1 raises error."""
+        with self.assertRaises(RateLimiterBypassError):
+            calculate_worker_rps(100.0, 0, False)
+
+    def test_negative_concurrency_raises(self):
+        """Negative concurrency raises error."""
+        with self.assertRaises(RateLimiterBypassError):
+            calculate_worker_rps(100.0, -1, False)
+
+    def test_zero_total_rps_raises(self):
+        """Zero total RPS raises error when not disabled."""
+        with self.assertRaises(RateLimiterBypassError):
+            calculate_worker_rps(0.0, 10, False)
+
+    def test_negative_total_rps_raises(self):
+        """Negative total RPS raises error when not disabled."""
+        with self.assertRaises(RateLimiterBypassError):
+            calculate_worker_rps(-10.0, 10, False)
+
+    def test_disable_with_zero_rps_does_not_raise(self):
+        """With flag, zero total RPS does not raise (returns inf)."""
+        result = calculate_worker_rps(0.0, 10, True)
+        self.assertTrue(math.isinf(result))
+
+
+class TestIntervalForWorkerRps(TestCase):
+    """Tests for interval_for_worker_rps function."""
+
+    def test_finite_rps_returns_interval(self):
+        """Finite RPS returns correct interval."""
+        result = interval_for_worker_rps(10.0)
+        self.assertAlmostEqual(result, 0.1)
+
+    def test_inf_rps_returns_zero(self):
+        """Infinite RPS (disabled limiter) returns 0 delay."""
+        result = interval_for_worker_rps(float("inf"))
+        self.assertEqual(result, 0)
+
+    def test_zero_rps_raises(self):
+        """Zero worker RPS raises error."""
+        with self.assertRaises(RateLimiterBypassError):
+            interval_for_worker_rps(0.0)
+
+    def test_negative_rps_raises(self):
+        """Negative worker RPS raises error."""
+        with self.assertRaises(RateLimiterBypassError):
+            interval_for_worker_rps(-5.0)
+
+
+class TestRateLimiterBypassIntegration(TestCase):
+    """Integration tests for rate limiter bypass flow."""
+
+    def test_bypass_flow_no_pacing(self):
+        """Full bypass flow: disabled limiter → inf RPS → 0 interval."""
+        worker_rps = calculate_worker_rps(100.0, 10, True)
+        interval = interval_for_worker_rps(worker_rps)
+        self.assertEqual(interval, 0)
+
+    def test_normal_flow_has_pacing(self):
+        """Normal flow: enabled limiter → finite RPS → positive interval."""
+        worker_rps = calculate_worker_rps(100.0, 10, False)
+        interval = interval_for_worker_rps(worker_rps)
+        self.assertGreater(interval, 0)
+
+    def test_bypass_with_different_concurrency(self):
+        """Bypass returns inf regardless of concurrency."""
+        for concurrency in [1, 5, 10, 50, 100]:
+            worker_rps = calculate_worker_rps(1000.0, concurrency, True)
+            self.assertTrue(
+                math.isinf(worker_rps),
+                f"Expected inf for concurrency={concurrency}",
+            )
+
+
+if __name__ == "__main__":
+    unittest_main()