Module Async_unix__.Writer0

module Core_unix = Core.Unix
module Unix = Async_unix__.Unix_syscalls
module IOVec = Core.Unix.IOVec
module Id : sig ... end
val io_stats : Async_unix.Io_stats.t
val debug : bool
module Line_ending : sig ... end
module Check_buffer_age' : sig ... end
module Open_flags = Unix.Open_flags
type open_flags = (Open_flags.t, exn) Core.Result.t
val sexp_of_open_flags : open_flags -> Ppx_sexp_conv_lib.Sexp.t
module Backing_out_channel = Async_unix__.Backing_out_channel
module Destroy_or_keep : sig ... end
module Scheduled : sig ... end
type t = {
id : Id.t;
mutable fd : Async_unix.Fd.t;
monitor : Async_unix__.Import.Monitor.t;
inner_monitor : Async_unix__.Import.Monitor.t;
mutable background_writer_state : [ `Running | `Not_running | `Stopped_permanently ];
background_writer_stopped : unit Async_unix__.Import.Ivar.t;
syscall : [ `Per_cycle | `Periodic of Async_unix.Require_explicit_time_source.Time.Span.t ];
mutable bytes_received : Core.Int63.t;
mutable bytes_written : Core.Int63.t;
scheduled : Scheduled.t;
mutable scheduled_bytes : int;
mutable buf : Core.Bigstring.t;
mutable scheduled_back : int;
mutable back : int;
time_source : Async_unix__.Import.Time_source.t;
flushes : (Async_unix.Require_explicit_time_source.Time_ns.t Async_unix__.Import.Ivar.t * Core.Int63.t) Core.Queue.t;
mutable close_state : [ `Open | `Closed_and_flushing | `Closed ];
close_finished : unit Async_unix__.Import.Ivar.t;
close_started : unit Async_unix__.Import.Ivar.t;
producers_to_flush_at_close : (unit -> unit Async_unix__.Import.Deferred.t) Core.Bag.t;
mutable flush_at_shutdown_elt : t Core.Bag.Elt.t option;
mutable check_buffer_age : t Check_buffer_age'.t Core.Bag.Elt.t option;
consumer_left : unit Async_unix__.Import.Ivar.t;
mutable raise_when_consumer_leaves : bool;
open_flags : open_flags Async_unix__.Import.Deferred.t;
line_ending : Line_ending.t;
mutable backing_out_channel : Backing_out_channel.t option;
}
val backing_out_channel : t -> Backing_out_channel.t option
val set_backing_out_channel : t -> Backing_out_channel.t option -> unit
val line_ending : t -> Line_ending.t
val open_flags : t -> open_flags Async_unix__.Import.Deferred.t
val raise_when_consumer_leaves : t -> bool
val set_raise_when_consumer_leaves : t -> bool -> unit
val consumer_left : t -> unit Async_unix__.Import.Ivar.t
val check_buffer_age : t -> t Check_buffer_age'.t Core.Bag.Elt.t option
val set_check_buffer_age : t -> t Check_buffer_age'.t Core.Bag.Elt.t option -> unit
val flush_at_shutdown_elt : t -> t Core.Bag.Elt.t option
val set_flush_at_shutdown_elt : t -> t Core.Bag.Elt.t option -> unit
val producers_to_flush_at_close : t -> (unit -> unit Async_unix__.Import.Deferred.t) Core.Bag.t
val close_started : t -> unit Async_unix__.Import.Ivar.t
val close_finished : t -> unit Async_unix__.Import.Ivar.t
val close_state : t -> [ `Closed | `Closed_and_flushing | `Open ]
val set_close_state : t -> [ `Closed | `Closed_and_flushing | `Open ] -> unit
val flushes : t -> (Async_unix.Require_explicit_time_source.Time_ns.t Async_unix__.Import.Ivar.t * Core.Int63.t) Core.Queue.t
val time_source : t -> Async_unix__.Import.Time_source.t
val back : t -> int
val set_back : t -> int -> unit
val scheduled_back : t -> int
val set_scheduled_back : t -> int -> unit
val buf : t -> Core.Bigstring.t
val set_buf : t -> Core.Bigstring.t -> unit
val scheduled_bytes : t -> int
val set_scheduled_bytes : t -> int -> unit
val scheduled : t -> Scheduled.t
val bytes_written : t -> Core.Int63.t
val set_bytes_written : t -> Core.Int63.t -> unit
val bytes_received : t -> Core.Int63.t
val set_bytes_received : t -> Core.Int63.t -> unit
val syscall : t -> [ `Per_cycle | `Periodic of Async_unix.Require_explicit_time_source.Time.Span.t ]
val background_writer_stopped : t -> unit Async_unix__.Import.Ivar.t
val background_writer_state : t -> [ `Not_running | `Running | `Stopped_permanently ]
val set_background_writer_state : t -> [ `Not_running | `Running | `Stopped_permanently ] -> unit
val inner_monitor : t -> Async_unix__.Import.Monitor.t
val monitor : t -> Async_unix__.Import.Monitor.t
val fd : t -> Async_unix.Fd.t
val set_fd : t -> Async_unix.Fd.t -> unit
val id : t -> Id.t
module Fields : sig ... end
val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t
type t_internals = t
val sexp_of_t_internals : t -> Ppx_sexp_conv_lib.Sexp.t
type writer = t
val sexp_of_writer : writer -> Ppx_sexp_conv_lib.Sexp.t
val set_raise_when_consumer_leaves : t -> bool -> unit
val bytes_to_write : t -> int
val is_stopped_permanently : t -> bool
val invariant : t -> unit
module Check_buffer_age : sig ... end
val flushed_time_ns : t -> Async_kernel__.Import.Time_ns.t Async_kernel__Deferred.t
val flushed_time : t -> Core_kernel__.Time_float.t Async_unix__.Import.Deferred.t
val flushed : t -> unit Async_kernel__Deferred.t
val set_backing_out_channel : t -> Backing_out_channel.t -> unit
val set_synchronous_backing_out_channel : t -> Backing_out_channel.t -> unit Async_kernel__Deferred.t
val set_synchronous_out_channel : t -> Core.Out_channel.t -> unit Async_kernel__Deferred.t
val using_synchronous_backing_out_channel : t -> bool
val clear_synchronous_out_channel : t -> unit
val with_synchronous_backing_out_channel : t -> Backing_out_channel.t -> f:(unit -> 'a Async_kernel__Deferred.t) -> 'a Async_unix__.Import.Monitor.Deferred.t
val with_synchronous_out_channel : t -> Core.Out_channel.t -> f:(unit -> 'a Async_kernel__Deferred.t) -> 'a Async_unix__.Import.Monitor.Deferred.t
val set_fd : t -> Async_unix.Fd.t -> unit Async_kernel__Deferred.t
val consumer_left : t -> unit Async_kernel__.Deferred0.t
val close_finished : t -> unit Async_kernel__.Deferred0.t
val close_started : t -> unit Async_kernel__.Deferred0.t
val is_closed : t -> bool
val is_open : t -> bool
val writers_to_flush_at_shutdown : t Core.Bag.t
val final_flush : ?⁠force:unit Async_unix__.Import.Deferred.t -> t -> unit Async_unix__.Import.Deferred.t
val close : ?⁠force_close:unit Async_unix__.Import.Deferred.t -> t -> unit Async_kernel__.Deferred0.t
val fill_flushes : t -> unit
val stop_permanently : t -> unit
val stopped_permanently : t -> unit Async_kernel__.Deferred0.t
val die : t -> Base.Sexp.t -> 'a
type buffer_age_limit = [
| `At_most of Async_unix.Require_explicit_time_source.Time.Span.t
| `Unlimited
]
val bin_shape_buffer_age_limit : Bin_prot.Shape.t
val bin_size_buffer_age_limit : [> `At_most of Async_unix.Require_explicit_time_source.Time.Span.t ] -> int
val bin_write_buffer_age_limit : Bin_prot.Common.buf -> pos:Bin_prot.Common.pos -> [< `At_most of Async_unix.Require_explicit_time_source.Time.Span.t | `Unlimited ] -> Bin_prot.Common.pos
val bin_writer_buffer_age_limit : [< `At_most of Async_unix.Require_explicit_time_source.Time.Span.t | `Unlimited At_most ] Bin_prot.Type_class.writer
val __bin_read_buffer_age_limit__ : Bin_prot.Common.buf -> pos_ref:Bin_prot.Common.pos_ref -> int -> [> `At_most of Async_unix.Require_explicit_time_source.Time.Span.t | `Unlimited ]
val bin_read_buffer_age_limit : Bin_prot.Common.buf -> pos_ref:Bin_prot.Common.pos_ref -> [> `At_most of Async_unix.Require_explicit_time_source.Time.Span.t | `Unlimited ]
val bin_reader_buffer_age_limit : [> `At_most of Async_unix.Require_explicit_time_source.Time.Span.t | `Unlimited ] Bin_prot.Type_class.reader
val bin_buffer_age_limit : [ `At_most of Async_unix.Require_explicit_time_source.Time.Span.t | `Unlimited ] Bin_prot.Type_class.t
val __buffer_age_limit_of_sexp__ : Ppx_sexp_conv_lib.Sexp.t -> buffer_age_limit
val buffer_age_limit_of_sexp : Ppx_sexp_conv_lib.Sexp.t -> buffer_age_limit
val sexp_of_buffer_age_limit : buffer_age_limit -> Ppx_sexp_conv_lib.Sexp.t
val create : ?⁠buf_len:Core_kernel__Int.t -> ?⁠syscall:[ `Per_cycle | `Periodic of Async_unix.Require_explicit_time_source.Time.Span.t ] -> ?⁠buffer_age_limit:[ `At_most of Async_unix.Require_explicit_time_source.Time.Span.t | `Unlimited ] -> ?⁠raise_when_consumer_leaves:bool -> ?⁠line_ending:Line_ending.t -> ?⁠time_source:[> Core_kernel.read ] Async_unix__.Import.Time_source.T1.t -> Async_unix.Fd.t -> t
val set_buffer_age_limit : writer -> [ `At_most of Async_unix.Require_explicit_time_source.Time.Span.t | `Unlimited ] -> unit
val of_out_channel : Core.Out_channel.t -> Async_unix.Fd.Kind.t -> t
val can_write : t -> bool
val ensure_can_write : t -> unit
val open_file : ?⁠append:bool -> ?⁠buf_len:Core_kernel__Int.t -> ?⁠syscall:[ `Per_cycle | `Periodic of Async_unix.Require_explicit_time_source.Time.Span.t ] -> ?⁠perm:Unix.file_perm -> ?⁠line_ending:Line_ending.t -> ?⁠time_source:[> Core_kernel.read ] Async_unix__.Import.Time_source.T1.t -> string -> t Async_kernel__Deferred.t
val with_close : t -> f:(unit -> 'a Async_unix__.Import.Monitor.Deferred.t) -> 'a Async_unix__.Import.Monitor.Deferred.t
val with_writer_exclusive : t -> (unit -> 'a Async_unix__.Import.Monitor.Deferred.t) -> 'a Async_kernel__Deferred.t
val with_file : ?⁠perm:Unix.file_perm -> ?⁠append:bool -> ?⁠exclusive:bool -> ?⁠line_ending:Line_ending.t -> ?⁠time_source:[> Core_kernel.read ] Async_unix__.Import.Time_source.T1.t -> string -> f:(t -> 'a Async_unix__.Import.Monitor.Deferred.t) -> 'a Async_kernel__Deferred.t
val got_bytes : t -> int -> unit
val add_iovec : t -> Destroy_or_keep.t -> Core.Bigstring.t IOVec.t -> count_bytes_as_received:bool -> unit
val schedule_unscheduled : t -> Destroy_or_keep.t -> unit
val dummy_iovec : IOVec.bigstring IOVec.t
val mk_iovecs : t -> IOVec.bigstring IOVec.t Core.Array.t * bool * int
val thread_io_cutoff : int
val is_running : [> `Running ] -> bool
val fd_closed : t -> unit
val start_write : t -> unit
val write_when_ready : t -> unit
val write_finished : t -> Core_kernel__Int.t -> unit
val maybe_start_writer : t -> unit
val give_buf : t -> Core_kernel__Int.t -> Core.Bigstring.t * int
val write_gen_internal : t -> 'a -> src_pos:int -> src_len:Core_kernel__Int.t -> allow_partial_write:bool -> blit_to_bigstring:('a, Core.Bigstring.t) Core.Blit.blit -> unit
val write_direct : t -> f:(Core.Bigstring.t -> pos:int -> len:int -> 'a * Core_kernel__Int.t) -> 'a option
val write_gen_unchecked : ?⁠pos:int -> ?⁠len:int -> t -> 'a -> blit_to_bigstring:('a, Core.Bigstring.t) Core.Blit.blit -> length:('a -> int) -> unit
val write_gen_whole_unchecked : t -> 'a -> blit_to_bigstring:('a -> Core.Bigstring.t -> pos:int -> unit) -> length:('a -> Core_kernel__Int.t) -> unit
val write_bytes : ?⁠pos:int -> ?⁠len:int -> t -> Base.bytes -> unit
val write : ?⁠pos:int -> ?⁠len:int -> t -> Base.string -> unit
val write_bigstring : ?⁠pos:int -> ?⁠len:int -> t -> Core.Bigstring.t -> unit
val write_iobuf : ?⁠pos:int -> ?⁠len:int -> t -> ([> Core__.Import.read ], 'a) Core.Iobuf.t -> unit
val write_substring : t -> Core.Substring.t -> unit
val write_bigsubstring : t -> Core.Bigsubstring.t -> unit
val writef : t -> ('a, unit, string, unit) Stdlib.format4 -> 'a
val write_gen : ?⁠pos:int -> ?⁠len:int -> t -> 'a -> blit_to_bigstring:('a, Core.Bigstring.t) Core.Blit.blit -> length:('a -> int) -> unit
val write_gen_whole : t -> 'a -> blit_to_bigstring:('a -> Core.Bigstring.t -> pos:int -> unit) -> length:('a -> Core_kernel__Int.t) -> unit
val to_formatter : t -> Stdlib.Format.formatter
val write_char : t -> Core_kernel__.Import.char -> unit
val newline : ?⁠line_ending:Line_ending.t -> t -> unit
val write_line : ?⁠line_ending:Line_ending.t -> t -> Base.string -> unit
val write_byte : t -> Core_kernel.Int.t -> unit
module Terminate_with : sig ... end
val write_sexp_internal : terminate_with:Terminate_with.t -> ?⁠hum:bool -> t -> Core.Sexp.t -> unit
val write_sexp : ?⁠hum:bool -> ?⁠terminate_with:Terminate_with.t -> t -> Core.Sexp.t -> unit
val write_bin_prot : t -> 'a Bin_prot.Type_class.writer -> 'a -> unit
val write_bin_prot_no_size_header : t -> size:Core_kernel__Int.t -> (Core.Bigstring.t -> pos:int -> 'a -> int) -> 'a -> unit
val send : t -> Base.string -> unit
val schedule_iovec : ?⁠destroy_or_keep:Destroy_or_keep.t -> t -> Core.Bigstring.t IOVec.t -> unit
val schedule_iovecs : t -> Core.Bigstring.t IOVec.t Core.Queue.t -> unit
val schedule_bigstring : ?⁠destroy_or_keep:Destroy_or_keep.t -> t -> ?⁠pos:int -> ?⁠len:int -> IOVec.bigstring -> unit
val schedule_bigsubstring : t -> Core.Bigsubstring.t -> unit
val schedule_iobuf_peek : t -> ?⁠pos:int -> ?⁠len:int -> ('a, 'b) Core__Iobuf.t -> unit
val schedule_iobuf_consume : t -> ?⁠len:int -> ('a, Core.Iobuf.seek) Core.Iobuf.t -> unit Async_kernel__Deferred.t
val fsync : t -> unit Async_kernel__Deferred.t
val fdatasync : t -> unit Async_kernel__Deferred.t
val write_bin_prot : t -> 'a Bin_prot.Type_class.writer -> 'a -> unit
val send : t -> Base.string -> unit
val schedule_iovec : ?⁠destroy_or_keep:Destroy_or_keep.t -> t -> Core.Bigstring.t IOVec.t -> unit
val schedule_iovecs : t -> Core.Bigstring.t IOVec.t Core.Queue.t -> unit
val schedule_bigstring : t -> ?⁠pos:int -> ?⁠len:int -> IOVec.bigstring -> unit
val schedule_bigsubstring : t -> Core.Bigsubstring.t -> unit
val schedule_iobuf_peek : t -> ?⁠pos:int -> ?⁠len:int -> ('a, 'b) Core__Iobuf.t -> unit
val schedule_iobuf_consume : t -> ?⁠len:int -> ('a, Core.Iobuf.seek) Core.Iobuf.t -> unit Async_kernel__Deferred.t
val write_gen : ?⁠pos:int -> ?⁠len:int -> t -> 'a -> blit_to_bigstring:('a, Core.Bigstring.t) Core.Blit.blit -> length:('a -> int) -> unit
val write_bytes : ?⁠pos:int -> ?⁠len:int -> t -> Base.bytes -> unit
val write : ?⁠pos:int -> ?⁠len:int -> t -> Base.string -> unit
val write_line : ?⁠line_ending:Line_ending.t -> t -> Base.string -> unit
val writef : t -> ('a, unit, string, unit) Stdlib.format4 -> 'a
val write_sexp : ?⁠hum:bool -> ?⁠terminate_with:Terminate_with.t -> t -> Core.Sexp.t -> unit
val write_iobuf : ?⁠pos:int -> ?⁠len:int -> t -> ([> Core__.Import.read ], 'a) Core.Iobuf.t -> unit
val write_bigstring : ?⁠pos:int -> ?⁠len:int -> t -> Core.Bigstring.t -> unit
val write_bigsubstring : t -> Core.Bigsubstring.t -> unit
val write_substring : t -> Core.Substring.t -> unit
val write_byte : t -> Core_kernel.Int.t -> unit
val write_char : t -> Core_kernel__.Import.char -> unit
val newline : ?⁠line_ending:Line_ending.t -> t -> unit
val stdout_and_stderr : (t * t) lazy_t
val stdout : t lazy_t
val stderr : t lazy_t
val use_synchronous_stdout_and_stderr : unit -> unit Async_unix__.Import.Deferred.t
val behave_nicely_in_pipeline : ?⁠writers:writer list -> unit -> unit
val apply_umask : int -> int
val with_file_atomic : ?⁠temp_file:Core_kernel__.Import.string -> ?⁠perm:Async_unix__Unix_syscalls.file_perm -> ?⁠fsync:bool -> ?⁠time_source:[> Core_kernel.read ] Async_unix__.Import.Time_source.T1.t -> Core_kernel__.Import.string -> f:(t -> 'a Async_kernel__Deferred.t) -> 'a Async_kernel__Deferred.t
val save : ?⁠temp_file:Core_kernel__.Import.string -> ?⁠perm:Async_unix__Unix_syscalls.file_perm -> ?⁠fsync:bool -> Core_kernel__.Import.string -> contents:Base.string -> unit Async_kernel__Deferred.t
val save_lines : ?⁠temp_file:Core_kernel__.Import.string -> ?⁠perm:Async_unix__Unix_syscalls.file_perm -> ?⁠fsync:bool -> Core_kernel__.Import.string -> Base.string list -> unit Async_kernel__Deferred.t
val save_sexp : ?⁠temp_file:Core_kernel__.Import.string -> ?⁠perm:Async_unix__Unix_syscalls.file_perm -> ?⁠fsync:bool -> ?⁠hum:bool -> Core_kernel__.Import.string -> Core.Sexp.t -> unit Async_kernel__Deferred.t
val save_sexps : ?⁠temp_file:Core_kernel__.Import.string -> ?⁠perm:Async_unix__Unix_syscalls.file_perm -> ?⁠fsync:bool -> ?⁠hum:bool -> Core_kernel__.Import.string -> Core.Sexp.t list -> unit Async_kernel__Deferred.t
val save_bin_prot : ?⁠temp_file:Core_kernel__.Import.string -> ?⁠perm:Async_unix__Unix_syscalls.file_perm -> ?⁠fsync:bool -> Core_kernel__.Import.string -> 'a Bin_prot.Type_class.writer -> 'a -> unit Async_kernel__Deferred.t
val with_flushed_at_close : t -> flushed:(unit -> unit Async_unix__.Import.Deferred.t) -> f:(unit -> 'a Async_unix__.Import.Monitor.Deferred.t) -> 'a Async_unix__.Import.Monitor.Deferred.t
val make_transfer : ?⁠stop:unit Async_unix__.Import.Deferred.t -> ?⁠max_num_values_per_read:int -> t -> 'a Async_unix__.Import.Pipe.Reader.t -> ('a Core_kernel.Queue.t -> cont:(unit -> unit) -> unit) -> unit Async_unix__.Import.Monitor.Deferred.t
val transfer : ?⁠stop:unit Async_unix__.Import.Deferred.t -> ?⁠max_num_values_per_read:int -> t -> 'a Async_unix__.Import.Pipe.Reader.t -> ('a -> unit) -> unit Async_unix__.Import.Monitor.Deferred.t
val transfer' : ?⁠stop:unit Async_unix__.Import.Deferred.t -> ?⁠max_num_values_per_read:int -> t -> 'a Async_unix__.Import.Pipe.Reader.t -> ('a Core_kernel.Queue.t -> unit Async_kernel__Deferred.t) -> unit Async_unix__.Import.Monitor.Deferred.t
val pipe : t -> Base.string Async_unix__.Import.Pipe.Writer.t