simon/tiny_httpd
1
0
Fork 0
mirror of https://github.com/c-cube/tiny_httpd.git synced 2025-12-06 03:05:29 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

echo: add --pool-size param

Browse source
This commit is contained in:
Simon Cruanes 2022-01-01 21:59:27 -05:00
parent 700f42a4d1
commit 326e1e2abd
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
examples/echo.ml
View file

@ -37,18 +37,22 @@ let middleware_stat () : S.Middleware.t * (unit -> string) =
let () = let () =
let port_ = ref 8080 in let port_ = ref 8080 in
let pool = ref false in let pool = ref false in
let pool_size = ref 0 in
let j = ref 32 in let j = ref 32 in
Arg.parse (Arg.align [ Arg.parse (Arg.align [
"--port", Arg.Set_int port_, " set port"; "--port", Arg.Set_int port_, " set port";
"-p", Arg.Set_int port_, " set port"; "-p", Arg.Set_int port_, " set port";
"--debug", Arg.Unit (fun () -> S._enable_debug true), " enable debug"; "--debug", Arg.Unit (fun () -> S._enable_debug true), " enable debug";
"--pool", Arg.Set pool, " use a thread pool"; "--pool", Arg.Set pool, " use a thread pool";
"--pool-size", Arg.Set_int pool_size, " size of thread pool if --pool is enabled";
"-j", Arg.Set_int j, " maximum number of connections"; "-j", Arg.Set_int j, " maximum number of connections";
]) (fun _ -> raise (Arg.Bad "")) "echo [option]*"; ]) (fun _ -> raise (Arg.Bad "")) "echo [option]*";
let new_thread = let new_thread =
if !pool then ( if !pool then (
let j = if !j > 64 then Some (!j/4) else None in let j =
if !pool_size > 0 then Some !pool_size
else if !j > 64 then Some (!j/4) else None in
let pool = Tiny_httpd_pool.create ?j () in let pool = Tiny_httpd_pool.create ?j () in
Some (fun f -> Tiny_httpd_pool.run pool f) Some (fun f -> Tiny_httpd_pool.run pool f)
) else None ) else None