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

cleanup eio

Browse source
This commit is contained in:
Simon Cruanes 2023-06-05 22:18:40 -04:00
parent d2b89eee50
commit 6c499584b8
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 4 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
src/eio/tiny_httpd_eio.ml
View file

@ -46,28 +46,6 @@ let ic_of_flow (flow : Eio.Net.stream_socket) : IO.In_channel.t =
let close () = flow#shutdown `Receive in let close () = flow#shutdown `Receive in
{ IO.In_channel.input; close } { IO.In_channel.input; close }
(*
let output buf i len =
let i = ref i in
let len = ref len in
while !len > 0 do
let available = Cstruct.length cstruct - !offset in
let n = min !len available in
Cstruct.blit_from_bytes buf !i cstruct !offset n;
offset := !offset + n;
i := !i + n;
len := !len - n;
if !offset = Cstruct.length cstruct then (
flow#write [ cstruct ];
offset := 0
)
done
in
*)
let oc_of_flow (flow : Eio.Net.stream_socket) : IO.Out_channel.t = let oc_of_flow (flow : Eio.Net.stream_socket) : IO.Out_channel.t =
(* write buffer *) (* write buffer *)
let wbuf = Bytes.create buf_size in let wbuf = Bytes.create buf_size in
@ -144,7 +122,10 @@ let io_backend ?(addr = "127.0.0.1") ?(port = 8080) ?max_connections
let tcp_server : IO.TCP_server.t = let tcp_server : IO.TCP_server.t =
{ {
running = (fun () -> Atomic.get running); running = (fun () -> Atomic.get running);
stop = (fun () -> Atomic.set running false); stop =
(fun () ->
Atomic.set running false;
Eio.Switch.fail sw Exit);
endpoint = endpoint =
(fun () -> (fun () ->
(* TODO: find the real port *) (* TODO: find the real port *)