package riot

  1. Overview
  2. Docs
An actor-model multi-core scheduler for OCaml 5

Install

Dune Dependency

Authors

Maintainers

Sources

riot-0.0.5.tbz
sha256=01b7b82ccc656b12b7315960d9df17eb4682b8f1af68e9fee33171fee1f9cf88
sha512=d8831d8a75fe43a7e8d16d2c0bb7d27f6d975133e17c5dd89ef7e575039c59d27c1ab74fbadcca81ddfbc0c74d1e46c35baba35ef825b36ac6c4e49d7a41d0c2

doc/riot.net/Net/Io/index.html

Module Net.IoSource

Sourcetype t
Sourcetype accept = [
  1. | `Abort of Unix.error
  2. | `Connected of Socket.stream_socket * Addr.stream_addr
  3. | `Retry
]
Sourcetype read = [
  1. | `Abort of Unix.error
  2. | `Read of int
  3. | `Retry
]
Sourcetype write = [
  1. | `Abort of Unix.error
  2. | `Retry
  3. | `Wrote of int
]
Sourceval create : unit -> t
Sourceval pp : Format.formatter -> t -> unit
Sourceval register : t -> Core.Process.t -> [ `r | `rw | `w ] -> Util.Fd.t -> unit
Sourceval unregister_process : t -> Core.Process.t -> unit
Sourceval poll : t -> ((Core.Process.t * Util.Fd.Mode.t) -> unit) -> unit
Sourceval close : t -> Util.Fd.t -> unit
Sourceval getaddrinfo : string -> string -> [> `Abort of Unix.error | `Ok of Unix.addr_info list | `Retry ]
Sourceval listen : t -> reuse_addr:bool -> reuse_port:bool -> backlog:int -> Addr.stream_addr -> (Util.Fd.t, 'a) result
Sourceval connect : t -> Addr.stream_addr -> [> `Abort of Unix.error | `Connected of Util.Fd.t | `In_progress of Util.Fd.t | `Retry ]
Sourceval accept : t -> Util.Fd.t -> accept
Sourceval read : Socket.stream_socket -> bytes -> int -> int -> read
Sourceval write : Socket.stream_socket -> bytes -> int -> int -> write
OCaml

Innovation. Community. Security.