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

update example

Browse source
This commit is contained in:
Simon Cruanes 2025-05-07 09:52:36 -04:00
parent 604224d1cf
commit 9b2107ec7c
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 19 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
examples/fnv1_udp/client.ml
View file

@ -15,25 +15,26 @@ let main () : unit =
let n_tasks_done = Atomic.make 0 in let n_tasks_done = Atomic.make 0 in
let n_sent = Atomic.make 0 in let n_sent = Atomic.make 0 in
let n_recv = Atomic.make 0 in let n_recv = Atomic.make 0 in
ignore
(Thread.create
(fun () ->
while true do
Printf.printf "%stasks done: %d sent: %d recv: %d%!" reset_line
(Atomic.get n_tasks_done) (Atomic.get n_sent) (Atomic.get n_recv);
Trace.counter_int "task-done" (Atomic.get n_tasks_done); let remoteaddr = Unix.ADDR_INET (Unix.inet_addr_loopback, !port) in
Trace.counter_int "sent" (Atomic.get n_sent);
Trace.counter_int "recv" (Atomic.get n_recv);
Thread.delay 0.2
done)
()
: Thread.t);
(let@ pool = Moonpool.Ws_pool.with_ ~num_threads:!j () in (let@ pool = Moonpool.Ws_pool.with_ ~num_threads:!j () in
let remoteaddr = Unix.ADDR_INET (Unix.inet_addr_loopback, !port) in ignore
(Thread.create
(fun () ->
while true do
Printf.printf "%stasks done: %d sent: %d recv: %d%!" reset_line
(Atomic.get n_tasks_done) (Atomic.get n_sent) (Atomic.get n_recv);
Trace.counter_int "task-done" (Atomic.get n_tasks_done);
Trace.counter_int "sent" (Atomic.get n_sent);
Trace.counter_int "recv" (Atomic.get n_recv);
Thread.delay 0.2
done)
()
: Thread.t);
let task () = let task () =
let[@alert "-deprecated"] _sp = let[@alert "-deprecated"] _sp =
@ -64,6 +65,9 @@ let main () : unit =
done done
in in
if Random.float 1. > 0.992 then
Trace.counter_int "n-tasks" (Moonpool.Runner.num_tasks pool);
Picos.Fiber.(yield ()); Picos.Fiber.(yield ());
(* receive a response *) (* receive a response *)