Module Flow_shutdown.Make

A Mirage FLOW over a hypervisor socket with an additional protocol layer to workaround bugs where in-flight data is lost after a shutdown_write or a close.

Parameters

module Time : Mirage_time.S
module Fn : S.FN

Signature

type error = [
| `Unix of Unix.error
]
include Mirage_flow_combinators.SHUTDOWNABLE with type error := error
val pp_error : error Fmt.t
type nonrec write_error = private [>
| Mirage_flow.write_error
]
val pp_write_error : write_error Fmt.t
type flow
val read : flow -> ( Cstruct.t Mirage_flow.or_eof, error ) Stdlib.result Lwt.t
val write : flow -> Cstruct.t -> ( unit, write_error ) Stdlib.result Lwt.t
val writev : flow -> Cstruct.t list -> ( unit, write_error ) Stdlib.result Lwt.t
val close : flow -> unit Lwt.t
val shutdown_write : flow -> unit Lwt.t
val shutdown_read : flow -> unit Lwt.t
val read_into : flow -> Cstruct.t -> ( unit Mirage_flow.or_eof, error ) Stdlib.result Lwt.t
val connect : Socket.t -> flow