package async_unix

  1. Overview
  2. Docs
package async_unix
Legend:
Library
Module
Module type
Parameter
Class
Class type
val iter : t -> mutex: (([< `Read | `Set_and_create ], t, Core.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Nano_mutex.t -> 'a) -> is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'b) -> have_called_go: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'c) -> fds_whose_watching_has_changed: (([< `Read | `Set_and_create ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> 'd) -> file_descr_watcher: (([< `Read | `Set_and_create ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> 'e) -> time_spent_waiting_for_io: (([< `Read | `Set_and_create ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> 'f) -> fd_by_descr: (([< `Read | `Set_and_create ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> 'g) -> timerfd: (([< `Read | `Set_and_create ], t, Core.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Linux_ext.Timerfd.t option -> 'h) -> scheduler_thread_id: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'i) -> interruptor: (([< `Read | `Set_and_create ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> 'j) -> signal_manager: (([< `Read | `Set_and_create ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> 'k) -> thread_pool: (([< `Read | `Set_and_create ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> 'l) -> handle_thread_pool_stuck: (([< `Read | `Set_and_create ], t, stuck_for:Core.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Time_ns.Span.t -> unit) -> 'm) -> busy_pollers: (([< `Read | `Set_and_create ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> 'n) -> busy_poll_thread_is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'o) -> next_tsc_calibration: (([< `Read | `Set_and_create ], t, Core.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Time_stamp_counter.t -> 'p) -> kernel_scheduler: (([< `Read | `Set_and_create ], t, Async_unix.Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Kernel_scheduler.t -> 'q) -> have_lock_do_cycle: (([< `Read | `Set_and_create ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> 'r) -> max_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Max_inter_cycle_timeout.t -> 's) -> min_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Min_inter_cycle_timeout.t -> 't) -> 't
val fold : t -> init:'a -> mutex: ('a -> ([< `Read | `Set_and_create ], t, Core.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Nano_mutex.t -> 'b) -> is_running: ('b -> ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'c) -> have_called_go: ('c -> ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'd) -> fds_whose_watching_has_changed: ('d -> ([< `Read | `Set_and_create ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> 'e) -> file_descr_watcher: ('e -> ([< `Read | `Set_and_create ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> 'f) -> time_spent_waiting_for_io: ('f -> ([< `Read | `Set_and_create ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> 'g) -> fd_by_descr: ('g -> ([< `Read | `Set_and_create ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> 'h) -> timerfd: ('h -> ([< `Read | `Set_and_create ], t, Core.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Linux_ext.Timerfd.t option -> 'i) -> scheduler_thread_id: ('i -> ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'j) -> interruptor: ('j -> ([< `Read | `Set_and_create ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> 'k) -> signal_manager: ('k -> ([< `Read | `Set_and_create ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> 'l) -> thread_pool: ('l -> ([< `Read | `Set_and_create ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> 'm) -> handle_thread_pool_stuck: ('m -> ([< `Read | `Set_and_create ], t, stuck_for:Core.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Time_ns.Span.t -> unit) -> 'n) -> busy_pollers: ('n -> ([< `Read | `Set_and_create ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> 'o) -> busy_poll_thread_is_running: ('o -> ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'p) -> next_tsc_calibration: ('p -> ([< `Read | `Set_and_create ], t, Core.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Time_stamp_counter.t -> 'q) -> kernel_scheduler: ('q -> ([< `Read | `Set_and_create ], t, Async_unix.Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Kernel_scheduler.t -> 'r) -> have_lock_do_cycle: ('r -> ([< `Read | `Set_and_create ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> 's) -> max_inter_cycle_timeout: ('s -> ([< `Read | `Set_and_create ], t, Async_unix.Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Max_inter_cycle_timeout.t -> 't) -> min_inter_cycle_timeout: ('t -> ([< `Read | `Set_and_create ], t, Async_unix.Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Min_inter_cycle_timeout.t -> 'u) -> 'u
val for_all : t -> mutex: (([< `Read | `Set_and_create ], t, Core.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Nano_mutex.t -> bool) -> is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> have_called_go: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> fds_whose_watching_has_changed: (([< `Read | `Set_and_create ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> bool) -> file_descr_watcher: (([< `Read | `Set_and_create ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> bool) -> time_spent_waiting_for_io: (([< `Read | `Set_and_create ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> bool) -> fd_by_descr: (([< `Read | `Set_and_create ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> bool) -> timerfd: (([< `Read | `Set_and_create ], t, Core.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Linux_ext.Timerfd.t option -> bool) -> scheduler_thread_id: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> bool) -> interruptor: (([< `Read | `Set_and_create ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> bool) -> signal_manager: (([< `Read | `Set_and_create ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> bool) -> thread_pool: (([< `Read | `Set_and_create ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> bool) -> handle_thread_pool_stuck: (([< `Read | `Set_and_create ], t, stuck_for:Core.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Time_ns.Span.t -> unit) -> bool) -> busy_pollers: (([< `Read | `Set_and_create ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> bool) -> busy_poll_thread_is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> next_tsc_calibration: (([< `Read | `Set_and_create ], t, Core.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Time_stamp_counter.t -> bool) -> kernel_scheduler: (([< `Read | `Set_and_create ], t, Async_unix.Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Kernel_scheduler.t -> bool) -> have_lock_do_cycle: (([< `Read | `Set_and_create ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> bool) -> max_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Max_inter_cycle_timeout.t -> bool) -> min_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Min_inter_cycle_timeout.t -> bool) -> bool
val exists : t -> mutex: (([< `Read | `Set_and_create ], t, Core.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Nano_mutex.t -> bool) -> is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> have_called_go: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> fds_whose_watching_has_changed: (([< `Read | `Set_and_create ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> bool) -> file_descr_watcher: (([< `Read | `Set_and_create ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> bool) -> time_spent_waiting_for_io: (([< `Read | `Set_and_create ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> bool) -> fd_by_descr: (([< `Read | `Set_and_create ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> bool) -> timerfd: (([< `Read | `Set_and_create ], t, Core.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Linux_ext.Timerfd.t option -> bool) -> scheduler_thread_id: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> bool) -> interruptor: (([< `Read | `Set_and_create ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> bool) -> signal_manager: (([< `Read | `Set_and_create ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> bool) -> thread_pool: (([< `Read | `Set_and_create ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> bool) -> handle_thread_pool_stuck: (([< `Read | `Set_and_create ], t, stuck_for:Core.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Time_ns.Span.t -> unit) -> bool) -> busy_pollers: (([< `Read | `Set_and_create ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> bool) -> busy_poll_thread_is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> next_tsc_calibration: (([< `Read | `Set_and_create ], t, Core.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Time_stamp_counter.t -> bool) -> kernel_scheduler: (([< `Read | `Set_and_create ], t, Async_unix.Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Kernel_scheduler.t -> bool) -> have_lock_do_cycle: (([< `Read | `Set_and_create ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> bool) -> max_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Max_inter_cycle_timeout.t -> bool) -> min_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Min_inter_cycle_timeout.t -> bool) -> bool
val to_list : t -> mutex: (([< `Read | `Set_and_create ], t, Core.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Nano_mutex.t -> 'a) -> is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> have_called_go: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> fds_whose_watching_has_changed: (([< `Read | `Set_and_create ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> 'a) -> file_descr_watcher: (([< `Read | `Set_and_create ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> 'a) -> time_spent_waiting_for_io: (([< `Read | `Set_and_create ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> 'a) -> fd_by_descr: (([< `Read | `Set_and_create ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> 'a) -> timerfd: (([< `Read | `Set_and_create ], t, Core.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Linux_ext.Timerfd.t option -> 'a) -> scheduler_thread_id: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'a) -> interruptor: (([< `Read | `Set_and_create ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> 'a) -> signal_manager: (([< `Read | `Set_and_create ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> 'a) -> thread_pool: (([< `Read | `Set_and_create ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> 'a) -> handle_thread_pool_stuck: (([< `Read | `Set_and_create ], t, stuck_for:Core.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Time_ns.Span.t -> unit) -> 'a) -> busy_pollers: (([< `Read | `Set_and_create ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> 'a) -> busy_poll_thread_is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> next_tsc_calibration: (([< `Read | `Set_and_create ], t, Core.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Time_stamp_counter.t -> 'a) -> kernel_scheduler: (([< `Read | `Set_and_create ], t, Async_unix.Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Kernel_scheduler.t -> 'a) -> have_lock_do_cycle: (([< `Read | `Set_and_create ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> 'a) -> max_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Max_inter_cycle_timeout.t -> 'a) -> min_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Min_inter_cycle_timeout.t -> 'a) -> 'a list
val map : t -> mutex: (([< `Read | `Set_and_create ], t, Core.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Nano_mutex.t -> Core.Nano_mutex.t) -> is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> have_called_go: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> fds_whose_watching_has_changed: (([< `Read | `Set_and_create ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> Fd.t list) -> file_descr_watcher: (([< `Read | `Set_and_create ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> File_descr_watcher.t) -> time_spent_waiting_for_io: (([< `Read | `Set_and_create ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> Tsc.Span.t) -> fd_by_descr: (([< `Read | `Set_and_create ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> Fd_by_descr.t) -> timerfd: (([< `Read | `Set_and_create ], t, Core.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Linux_ext.Timerfd.t option -> Core.Linux_ext.Timerfd.t option) -> scheduler_thread_id: (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> int) -> interruptor: (([< `Read | `Set_and_create ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> Interruptor.t) -> signal_manager: (([< `Read | `Set_and_create ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> Raw_signal_manager.t) -> thread_pool: (([< `Read | `Set_and_create ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> Thread_pool.t) -> handle_thread_pool_stuck: (([< `Read | `Set_and_create ], t, stuck_for:Core.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Time_ns.Span.t -> unit) -> stuck_for:Core.Time_ns.Span.t -> unit) -> busy_pollers: (([< `Read | `Set_and_create ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> Busy_pollers.t) -> busy_poll_thread_is_running: (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> next_tsc_calibration: (([< `Read | `Set_and_create ], t, Core.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Time_stamp_counter.t -> Core.Time_stamp_counter.t) -> kernel_scheduler: (([< `Read | `Set_and_create ], t, Async_unix.Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Kernel_scheduler.t -> Async_unix.Import.Kernel_scheduler.t) -> have_lock_do_cycle: (([< `Read | `Set_and_create ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> (unit -> unit) option) -> max_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Max_inter_cycle_timeout.t -> Async_unix.Import.Max_inter_cycle_timeout.t) -> min_inter_cycle_timeout: (([< `Read | `Set_and_create ], t, Async_unix.Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Async_unix.Import.Min_inter_cycle_timeout.t -> Async_unix.Import.Min_inter_cycle_timeout.t) -> t
val set_all_mutable_fields : t -> is_running:bool -> have_called_go:bool -> fds_whose_watching_has_changed:Fd.t list -> time_spent_waiting_for_io:Tsc.Span.t -> timerfd:Core.Linux_ext.Timerfd.t option -> scheduler_thread_id:int -> handle_thread_pool_stuck:(stuck_for:Core.Time_ns.Span.t -> unit) -> busy_poll_thread_is_running:bool -> next_tsc_calibration:Core.Time_stamp_counter.t -> have_lock_do_cycle:(unit -> unit) option -> max_inter_cycle_timeout:Async_unix.Import.Max_inter_cycle_timeout.t -> min_inter_cycle_timeout:Async_unix.Import.Min_inter_cycle_timeout.t -> unit