forked from
anil.recoil.org/ocaml-conpool
TCP/TLS connection pooling for Eio
fix(lint): resolve E718 fuzz helper naming, E616 failf, and monopam cleanup
Update E718 rule and cram tests. Fix remaining E616 fail+Fmt.str
instances. Add gen_corpus.ml helpers for fuzz directories. Clean up
monopam import module.
+10
-17
+10
-17
test/stress_test.ml
+10
-17
test/stress_test.ml
···
439
439
(* Generate JavaScript arrays for comparison charts *)
440
440
let test_names =
441
441
String.concat ", "
442
-
(List.map
443
-
(fun r -> Fmt.str "\"%s\"" (js_escape r.test_name))
444
-
results)
442
+
(List.map (fun r -> Fmt.str "\"%s\"" (js_escape r.test_name)) results)
445
443
in
446
444
let throughputs =
447
-
String.concat ", "
448
-
(List.map (fun r -> Fmt.str "%.2f" r.throughput) results)
445
+
String.concat ", " (List.map (fun r -> Fmt.str "%.2f" r.throughput) results)
449
446
in
450
447
let avg_latencies =
451
448
String.concat ", "
···
914
911
(fun p ->
915
912
match List.find_opt (fun c -> c.name = p) presets with
916
913
| Some c -> mode := Single c
917
-
| None -> failwith (Fmt.str "Unknown preset: %s" p)),
914
+
| None -> Fmt.failwith "Unknown preset: %s" p),
918
915
"Use a named preset configuration" );
919
916
("-n", Arg.Set_string name, "Test name");
920
917
( "-s",
921
918
Arg.Set_int num_servers,
922
-
Fmt.str "Number of servers (default: %d)"
923
-
default_config.num_servers );
919
+
Fmt.str "Number of servers (default: %d)" default_config.num_servers );
924
920
( "-c",
925
921
Arg.Set_int num_clients,
926
-
Fmt.str "Clients per server (default: %d)"
927
-
default_config.num_clients );
922
+
Fmt.str "Clients per server (default: %d)" default_config.num_clients );
928
923
( "-m",
929
924
Arg.Set_int messages_per_client,
930
925
Fmt.str "Messages per client (default: %d)"
···
935
930
default_config.max_parallel_clients );
936
931
( "-b",
937
932
Arg.Set_int message_size,
938
-
Fmt.str "Message size (default: %d)" default_config.message_size
939
-
);
933
+
Fmt.str "Message size (default: %d)" default_config.message_size );
940
934
( "-P",
941
935
Arg.Set_int pool_size,
942
-
Fmt.str "Pool size per endpoint (default: %d)"
943
-
default_config.pool_size );
936
+
Fmt.str "Pool size per endpoint (default: %d)" default_config.pool_size
937
+
);
944
938
( "-o",
945
939
Arg.Set_string output_file,
946
940
"Output JSON file (default: stress_test_results.json)" );
···
973
967
Fmt.pr "Available presets:\n";
974
968
List.iter
975
969
(fun c ->
976
-
Fmt.pr
977
-
" %s: %d servers, %d clients, %d msgs/client, pool=%d\n" c.name
978
-
c.num_servers c.num_clients c.messages_per_client c.pool_size)
970
+
Fmt.pr " %s: %d servers, %d clients, %d msgs/client, pool=%d\n"
971
+
c.name c.num_servers c.num_clients c.messages_per_client c.pool_size)
979
972
presets
980
973
| Single config ->
981
974
let config = if config.name = "default" then custom_config else config in