Module Buffering.MakeSource

Parameters

module Fn : S.FN

Signature

Sourcetype 'a io = 'a Lwt.t
Sourcetype buffer = Cstruct.t
Sourcetype error = [
  1. | `Unix of Unix.error
]
Sourceval pp_error : Format.formatter -> [< `Unix of Unix.error ] -> unit
Sourcetype write_error = [
  1. | Mirage_flow.write_error
  2. | error
]
Sourceval pp_write_error : Format.formatter -> [< `Closed | `Unix of Unix.error ] -> unit
Sourcetype flow = {
  1. fd : RW.t;
  2. read_buffers_max : int;
  3. read_max : int;
  4. mutable read_buffers : Cstruct.t list;
  5. mutable read_buffers_len : int;
  6. read_buffers_m : Mutex.t;
  7. read_buffers_c : Condition.t;
  8. read_histogram : Histogram.t;
  9. mutable write_buffers : Cstruct.t list;
  10. mutable write_buffers_len : int;
  11. write_buffers_m : Mutex.t;
  12. write_buffers_c : Condition.t;
  13. write_buffers_max : int;
  14. write_max : int;
  15. mutable write_flushed : bool;
  16. write_histogram : Histogram.t;
  17. mutable closed : bool;
  18. mutable shutdown_read : bool;
  19. mutable read_thread_exit : bool;
  20. mutable shutdown_write : bool;
  21. mutable shutdown_write_complete : bool;
  22. mutable write_error : bool;
}
Sourceval connect : ?message_size:int -> ?buffer_size:int -> RW.t -> flow
Sourceval detach : ('a -> 'b) -> 'a -> 'b Lwt.t
Sourceval wait_write_flush : flow -> unit
Sourceval close : flow -> unit Lwt.t
Sourceval shutdown_read : 'a -> unit Lwt.t
Sourceval shutdown_write : flow -> unit Lwt.t
Sourceval wait_for_data_or_eof : flow -> int -> unit
Sourceval read : flow -> ([> `Data of Cstruct.t | `Eof ], 'a) result Lwt.t
Sourceval read_into : 'a -> 'b -> 'c
Sourceval wait_for_space : flow -> int -> unit
Sourceval writev : flow -> Cstruct.t list -> (unit, [> `Closed ]) result Lwt.t
Sourceval write : flow -> Cstruct.t -> (unit, [> `Closed ]) result Lwt.t