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

feat(tiny_httpd): adjust buffer pool size to number of connections

Browse source
This commit is contained in:
Simon Cruanes 2025-05-01 11:39:00 -04:00
parent 4c3c53ee16
commit 26bdb34cba
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/tiny_httpd/nanoev_tiny_httpd.ml
View file

@ -281,7 +281,7 @@ end
open struct open struct
let get_max_connection_ ?(max_connections = 2048) () : int = let get_max_connection_ ?(max_connections = 2048) () : int =
let max_connections = max 4 max_connections in let max_connections = min (max 4 @@ EV.max_fds ()) max_connections in
max_connections max_connections
let clear_slice (slice : Slice.t) = let clear_slice (slice : Slice.t) =
@ -294,12 +294,13 @@ let create ?(masksigpipe = not Sys.win32) ?max_connections ?(timeout = 0.0)
?buf_size ?(get_time_s = Unix.gettimeofday) ?(addr = "127.0.0.1") ?buf_size ?(get_time_s = Unix.gettimeofday) ?(addr = "127.0.0.1")
?(port = 8080) ?sock ?middlewares ~new_thread () : TH.Server.t = ?(port = 8080) ?sock ?middlewares ~new_thread () : TH.Server.t =
let max_connections = get_max_connection_ ?max_connections () in let max_connections = get_max_connection_ ?max_connections () in
let max_pool_size = max_connections * 2 in
let server = let server =
{ {
Unix_tcp_server_.addr; Unix_tcp_server_.addr;
new_thread; new_thread;
buf_pool = buf_pool =
Pool.create ~clear:Buf.clear_and_zero Pool.create ~clear:Buf.clear_and_zero ~max_size:max_pool_size
~mk_item:(fun () -> Buf.create ?size:buf_size ()) ~mk_item:(fun () -> Buf.create ?size:buf_size ())
(); ();
slice_pool = slice_pool =