Skip to content

fix: Forward missing CLI flags to spawned server in async runner#141

Open
mcurrier2 wants to merge 1 commit into
mainfrom
fix/124-async-server-flag-forwarding
Open

fix: Forward missing CLI flags to spawned server in async runner#141
mcurrier2 wants to merge 1 commit into
mainfrom
fix/124-async-server-flag-forwarding

Conversation

@mcurrier2

Copy link
Copy Markdown
Collaborator

Summary

  • Forward --buffer-size so server uses matching transport config
  • Forward --shm-direct flag when direct memory mode is enabled
  • Forward --pmq-priority for POSIX message queue benchmarks
  • Forward --send-delay so server can enable precise timestamps
  • Forward -v verbose flags for server-side debugging

Context

The async runner's spawn_server_process was missing several CLI flags that the blocking runner already forwarded correctly. This caused the server to use default values while the client used user-specified or auto-computed values, leading to potential mismatches in buffer sizes, transport modes, and logging levels.

Fixes #124

Test plan

  • Full test suite passes (476 tests)
  • clippy clean, fmt clean, MSRV check passes

Made with Cursor

The async benchmark runner's spawn_server_process did not forward
several CLI flags that affect server behavior:

- --buffer-size: Server would use default buffer size instead of the
  user-specified or auto-computed size, causing client/server mismatch
- --shm-direct: Server wouldn't know to use direct memory mode
- --pmq-priority: PMQ priority mismatch between client and server
- --send-delay: Server couldn't enable precise timestamps for
  latency-focused SHM-direct benchmarks
- -v (verbose): Server logging was always at default level regardless
  of user's verbosity request

These flags were already correctly forwarded by the blocking runner's
spawn_server_process_with_latency_file. This commit brings the async
runner to parity.

Fixes #124

AI-assisted-by: Claude Opus 4.6
Co-authored-by: Cursor <cursoragent@cursor.com>
@coderabbitai

coderabbitai Bot commented Jul 1, 2026

Copy link
Copy Markdown

Warning

Review limit reached

@mcurrier2, you've reached your PR review limit, so we couldn't start this review.

Next review available in: 26 minutes

Enable usage-based reviews in Billing to review now. Otherwise, wait until the next included review is available.

How can I continue?

After more reviews become available, a review can be triggered using the @coderabbitai review command as a PR comment. Alternatively, push new commits to this PR.

To avoid repeated limits, reduce automatic review volume by pausing incremental auto-reviews earlier, using label-based review opt-in, excluding WIP or generated PR titles, or requesting reviews manually when the PR is ready. If your team needs uninterrupted high-volume reviews, an organization admin can enable usage-based reviews.

How do review limits work?

CodeRabbit enforces per-developer PR review limits for each organization. Most developers receive the normal plan review availability.

For paid Pro and Pro+ PR reviews, CodeRabbit uses adaptive limits for sustained high-volume activity. When a developer's recent PR review activity reaches the 95th percentile or higher among CodeRabbit users, additional reviews become available more gradually as earlier reviews age out of the rolling window.

Please refer docs for additional details.

Review details
⚙️ Run configuration

Configuration used: Organization UI

Review profile: CHILL

Plan: Enterprise

Run ID: 556dfab8-75b2-45d0-909f-753286d1bdc5

📥 Commits

Reviewing files that changed from the base of the PR and between d586320 and ecd6d5e.

📒 Files selected for processing (1)
  • src/benchmark.rs

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

Comment @coderabbitai help to get the list of available commands.

@github-actions

github-actions Bot commented Jul 1, 2026

Copy link
Copy Markdown

📈 Changed lines coverage: 69.23% (9/13)

🚨 Uncovered lines in this PR

  • src/benchmark.rs: 824, 830-831, 848

📊 Code Coverage Summary

File Line Coverage Uncovered Lines
src/benchmark.rs 83.82%
(518/618)
75, 78, 89, 93, 102, 105, 107, 124, 424, 429-434, 441-446, 513-516, 621, 705, 717-719, 739, 808-810, 815, 824, 830-831, 848, 864, 869, 887, 993, 997-1000, 1002, 1011-1014, 1016, 1092, 1123, 1126, 1128-1129, 1138-1139, 1281, 1294, 1311, 1434, 1443, 1445-1446, 1449-1450, 1456-1457, 1462-1463, 1465, 1470-1471, 1475-1477, 1482-1483, 1486-1487, 1519, 1577-1581, 1583-1589, 1591, 1594, 1751, 1766
src/benchmark_blocking.rs 74.32%
(327/440)
97, 111, 127, 263, 369, 380-382, 402, 434, 495, 594, 607, 621, 651-654, 739-742, 761, 765, 780, 822, 824-826, 830, 833-835, 837, 840, 842-846, 848-849, 857-861, 863-867, 870-871, 875-876, 911, 960, 1042, 1053, 1083, 1086, 1151-1156, 1158, 1216-1219, 1224, 1237, 1240-1243, 1247, 1249-1252, 1254, 1256-1257, 1259-1260, 1263, 1265-1270, 1272, 1276-1277, 1279, 1281, 1305, 1317-1322, 1324, 1344-1347
src/cli.rs 92.39%
(85/92)
691, 790, 830, 832, 853-855
src/execution_mode.rs 100.00%
(14/14)
``
src/ipc/mod.rs 63.64%
(49/77)
134, 458, 460-463, 773-774, 789-790, 808-809, 840, 843, 846, 851, 878-879, 893, 895, 915, 917, 1040-1042, 1231-1233
src/ipc/posix_message_queue.rs 46.09%
(59/128)
139-140, 213-215, 217, 224, 229, 332-335, 337, 345, 437, 441-442, 446, 449-452, 454-458, 539, 679, 782, 789-790, 807-808, 819-820, 831-832, 849-850, 906, 910-911, 914-919, 921-923, 927, 929-931, 933, 935-937, 941-943, 945-947, 994-995, 1017
src/ipc/posix_message_queue_blocking.rs 72.16%
(127/176)
172, 182, 221, 251-255, 274, 325, 368, 387-390, 416-418, 422-423, 425-426, 436, 455, 457-458, 460-461, 474-475, 477-478, 484, 486-491, 493-495, 497-498, 503, 505-506, 508-509
src/ipc/shared_memory.rs 69.36%
(163/235)
69, 152, 156, 257-258, 268-269, 273, 401-402, 428-430, 432, 450-452, 454-455, 457-461, 478, 485, 491, 494-495, 499, 503, 507-508, 513-514, 677-678, 681-682, 685, 687, 692-693, 720-721, 724-725, 732-734, 736, 738-743, 745-746, 749-750, 752-756, 763, 793, 795-796, 798, 802
src/ipc/shared_memory_blocking.rs 77.35%
(222/287)
199-201, 203-204, 207-209, 212-213, 215, 220, 222, 226-228, 233, 241-243, 246-248, 251-252, 254, 257, 260-261, 264-265, 269-270, 272, 276-277, 279, 315-316, 403-404, 428-432, 544, 552, 602, 619, 706, 772, 805-806, 808-809, 816, 833, 835-836, 838, 871, 880, 890, 912
src/ipc/shared_memory_direct.rs 83.25%
(159/191)
400-403, 472-479, 483, 511, 536-539, 543-544, 590-591, 603, 633, 640-641, 697-698, 704, 726, 731-732
src/ipc/tcp_socket.rs 59.43%
(63/106)
31-32, 61, 96, 113-114, 118, 124-125, 129, 136-137, 141, 147-148, 152, 171-172, 175-177, 184-185, 188, 362-363, 366-367, 370-371, 376-377, 422, 429, 447-449, 478, 480-482, 484, 487
src/ipc/tcp_socket_blocking.rs 94.23%
(98/104)
145, 170, 322-325
src/ipc/unix_domain_socket.rs 59.43%
(63/106)
29-30, 58, 93, 103, 122-123, 127, 133-134, 138, 145-146, 150, 156-157, 161, 180-181, 184-186, 193-194, 197, 346-347, 350-351, 354-355, 360-361, 412-414, 443, 445-447, 449, 452, 468
src/ipc/unix_domain_socket_blocking.rs 92.06%
(116/126)
287-288, 294-296, 298, 363-366
src/logging.rs 100.00%
(13/13)
``
src/main.rs 45.76%
(162/354)
85-87, 89, 130-131, 141-145, 149-151, 153-154, 156-157, 177-180, 204-208, 216, 222, 225, 230-233, 238-239, 245, 251, 253-255, 257, 263-264, 270, 275, 278-279, 283, 285-286, 290-291, 293, 299, 303-304, 306-311, 313-314, 317, 326, 329-330, 333, 380-383, 390, 392-396, 399-402, 404-405, 407-408, 410, 412-418, 422, 424-427, 430, 434-436, 440, 442, 445, 449, 454-457, 463-464, 470-471, 477, 479-480, 484, 486, 491-493, 497, 500-501, 503-504, 509, 511-513, 517-518, 520, 527, 532-533, 535-540, 542-543, 547, 556, 559-560, 563, 565, 584, 591, 595-597, 599, 627-628, 636, 669, 704, 729, 733, 736-739, 795-796, 803-804, 807, 834-835, 838, 875, 896-897, 901-904, 926, 953, 962, 967, 972-973
src/metrics.rs 84.04%
(158/188)
455-460, 493-494, 552, 558, 579-582, 732-734, 736, 768, 833, 838, 881, 904, 952, 980, 984, 1005, 1007-1008, 1013
src/results.rs 56.60%
(253/447)
726, 735-737, 739-740, 743-744, 747, 769, 772-773, 776, 778, 781, 785-790, 800-801, 804-809, 826, 838-839, 841, 843, 846-847, 849, 853, 880, 904-906, 909-910, 914-916, 919, 945, 950, 955, 961, 980, 982-983, 985, 987-991, 993, 995-996, 1030, 1071-1072, 1075, 1081-1082, 1086, 1090-1092, 1094-1095, 1119-1123, 1126-1129, 1132-1141, 1151-1152, 1171-1172, 1174-1178, 1180, 1197-1198, 1200-1205, 1207, 1225, 1227-1232, 1250, 1253, 1269-1270, 1285-1287, 1289-1291, 1293-1294, 1296-1297, 1299-1300, 1302, 1304-1305, 1307-1310, 1312-1314, 1316-1318, 1321, 1325-1326, 1334-1339, 1341-1342, 1346-1347, 1351-1353, 1355, 1359-1360, 1369-1372, 1376-1378, 1382, 1384-1385, 1393-1394, 1399, 1406-1410, 1412, 1610-1611, 1831-1832, 1834-1835
src/results_blocking.rs 95.51%
(298/312)
489-490, 492-493, 544, 769, 774, 779, 815, 818-819, 827-828, 886
src/standalone_client.rs 84.57%
(636/752)
40, 68-69, 79, 84-85, 87, 96-99, 109-111, 113, 117, 133, 154, 256, 276, 320, 361, 365, 396, 414, 513, 531, 542, 549, 614, 617-618, 626-646, 648-649, 651, 675, 682, 698, 736, 739, 761-763, 768-769, 857, 877, 893, 921, 924-925, 962, 966, 997, 1001, 1015, 1022, 1105, 1123, 1134, 1141, 1144, 1201, 1204-1205, 1213-1233, 1235-1236, 1238, 1262, 1269, 1272, 1284, 1321, 1324
src/standalone_server.rs 77.97%
(400/513)
138, 161, 187, 204-205, 207, 217-219, 221, 260, 285-286, 309-311, 335-336, 421-422, 425-426, 446-447, 457-458, 461, 463, 465, 475-478, 485, 493-496, 521, 553-554, 569-570, 580-581, 584, 586, 588, 598-601, 608, 619-622, 668, 747-748, 766-768, 772-774, 824-826, 830-831, 834-835, 851-852, 859-862, 871, 876-877, 880, 882, 884, 894, 901-904, 926, 956-958, 962-963, 975-976, 983-986, 995, 1000-1001, 1004, 1006, 1008, 1018, 1027-1030
src/utils.rs 75.00%
(42/56)
143, 147-148, 153, 159, 198-202, 239-242
Total 75.45%
(4025/5335)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Async server spawn missing CLI flag forwarding (buffer-size, send-delay, etc.)

1 participant