CHANGES.md

@@ -1,3 +0,0 @@
-# 0.1
-
-initial release, with poll and select backends.

dune-project

@@ -1,11 +1,16 @@
 (lang dune 2.7)
+
 (name nanoev)
+
 (generate_opam_files true)
+
 (source
  (github c-cube/nanoev))
+
 (authors "Simon Cruanes")
+
 (maintainers "Simon Cruanes")
-(version 0.1)
+
 (license MIT)
 
 ;(documentation https://url/to/documentation)

examples/fnv1_udp/client.ml

@@ -15,26 +15,25 @@ let main () : unit =
   let n_tasks_done = Atomic.make 0 in
   let n_sent = 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);
 
-  let remoteaddr = Unix.ADDR_INET (Unix.inet_addr_loopback, !port) in
+           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@ pool = Moonpool.Ws_pool.with_ ~num_threads:!j () 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 remoteaddr = Unix.ADDR_INET (Unix.inet_addr_loopback, !port) in
 
    let task () =
      let[@alert "-deprecated"] _sp =
@@ -65,9 +64,6 @@ let main () : unit =
          done
        in
 
-       if Random.float 1. > 0.992 then
-         Trace.counter_int "n-tasks" (Moonpool.Runner.num_tasks pool);
-
        Picos.Fiber.(yield ());
 
        (* receive a response *)

nanoev-picos.opam

@@ -1,6 +1,5 @@
 # This file is generated by dune, edit dune-project instead
 opam-version: "2.0"
-version: "0.1"
 synopsis: "Use nanoev from picos"
 maintainer: ["Simon Cruanes"]
 authors: ["Simon Cruanes"]

nanoev-posix.opam

@@ -1,6 +1,5 @@
 # This file is generated by dune, edit dune-project instead
 opam-version: "2.0"
-version: "0.1"
 synopsis: "Use mtime+iomux (posix compliant) as a backend for nanoev"
 maintainer: ["Simon Cruanes"]
 authors: ["Simon Cruanes"]

nanoev.opam

@@ -1,6 +1,5 @@
 # This file is generated by dune, edit dune-project instead
 opam-version: "2.0"
-version: "0.1"
 synopsis: "Tiny event loop abstraction"
 maintainer: ["Simon Cruanes"]
 authors: ["Simon Cruanes"]

nanoev_tiny_httpd.opam

@@ -1,6 +1,5 @@
 # This file is generated by dune, edit dune-project instead
 opam-version: "2.0"
-version: "0.1"
 synopsis: "Use nanoev as a basis for tiny_httpd"
 maintainer: ["Simon Cruanes"]
 authors: ["Simon Cruanes"]