Miou_unixThis module offers a re-implementation of the I/O according to Miou's model. This module is essentially concerned with reading and writing Unix.file_descr from sockets, pipes, fifos, terminals (and pseudo-terminals) and probably devices. For all these types of file_descr, reading/writing can block (waiting for bytes or waiting for the system's internal buffer to be free).
This is not generally the case for files and folders where read/write does not block. So, as far as files/folders are concerned, there is no point in using the suspend/resume mechanisms offered by Miou. These mechanisms (and the use of Unix.select) could actually degrade performance. It is therefore advisable to use the Unix module directly rather than Miou_unix for files/folders.
It should be noted, however, that reading/writing files can take a long time. So, in a cooperative context (with Miou.async), it may be worthwhile to increase the availability of other tasks to run with Miou.yield - so associate a Miou.yield with these operations. However, in the case of parallelization (Miou.call), it is not necessary to cooperate with the other tasks as they run in parallel. In this sense, and depending on the design of your application, these operations should, or should not, be associated with a Miou.yield.
val of_file_descr : ?non_blocking:bool -> Unix.file_descr -> file_descrof_file_descr ?non_blocking ?owner fd creates a new file_descr. Depending on non_blocking (defaults to true), we set the given fd to non-blocking mode or not.
val to_file_descr : file_descr -> Unix.file_descrto_file_descr fd returns the real Unix.file_descr.
val tcpv4 : unit -> file_descrtcpv4 () allocates a new IPv4 socket.
val tcpv6 : unit -> file_descrtcpv6 () allocates a new IPv6 socket.
val bind_and_listen :
?backlog:int ->
?reuseaddr:bool ->
?reuseport:bool ->
file_descr ->
Unix.sockaddr ->
unitbind_and_listen fd sockaddr binds the given socket to the given sockaddr and set up the given fd for receiving connection requests. backlog is the maximal number of pending requests. The optional argument reuseaddr (defaults to true) sets the REUSEADDR socket option on the given fd. The optional argument reuseport (defaults to true sets the REUSEPORT socket option on the given fd.
val accept : ?cloexec:bool -> file_descr -> file_descr * Unix.sockaddraccept ?cloexec fd is a Miou friendly Unix.accept which returns file descriptors in non-blocking mode.
val connect : file_descr -> Unix.sockaddr -> unitconnect fd sockaddr is a Miou friendly Unix.connect. The function accepts only file_descrs in non-blocking mode.
val read : file_descr -> ?off:int -> ?len:int -> bytes -> intread fd buf ~off ~len reads up to len bytes (defaults to Bytes.length buf - off from the given file-descriptor fd, storing them in byte sequence buf, starting at position off in buf (defaults to 0). It returns the actual number of characters read, between 0 and len (inclusive).
val really_read : file_descr -> ?off:int -> ?len:int -> bytes -> unitreally_read fd buf ~off ~len reads len bytes (defaults to Bytes.length buf - off) from the given file-descriptor fd, storing them in byte sequence buf, starting at position off in buf (defaults to 0). If len = 0, really_read does nothing.
val write : file_descr -> ?off:int -> ?len:int -> string -> unitwrite fd str ~off ~len writes len bytes (defaults to String.length str - off) from byte sequence buf, starting at offset off (defaults to 0), to the given file-descriptor fd.
val close : file_descr -> unitclose fd closes properly the given fd.
val run : ?g:Random.State.t -> ?domains:int -> (unit -> 'a) -> 'amodule Ownership : sig ... end/
val blocking_read : Unix.file_descr -> unitval blocking_write : Unix.file_descr -> unit