Module Direct

val iter : t -> mutex:(([< ], t, Core.Std.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Nano_mutex.t -> unit) -> is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> unit) -> have_called_go:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> unit) -> fds_whose_watching_has_changed:(([< ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> unit) -> file_descr_watcher:(([< ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> unit) -> time_spent_waiting_for_io:(([< ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> unit) -> fd_by_descr:(([< ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> unit) -> timerfd:(([< ], t, Core.Std.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Std.Linux_ext.Timerfd.t option -> unit) -> scheduler_thread_id:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> unit) -> interruptor:(([< ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> unit) -> signal_manager:(([< ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> unit) -> thread_pool:(([< ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> unit) -> handle_thread_pool_stuck:(([< ], t, stuck_for:Core.Std.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Std.Time_ns.Span.t -> unit) -> unit) -> busy_pollers:(([< ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> unit) -> busy_poll_thread_is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> unit) -> next_tsc_calibration:(([< ], t, Core.Std.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Time_stamp_counter.t -> unit) -> kernel_scheduler:(([< ], t, Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Import.Kernel_scheduler.t -> unit) -> max_inter_cycle_timeout:(([< ], t, Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_inter_cycle_timeout.t -> unit) -> min_inter_cycle_timeout:(([< ], t, Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Min_inter_cycle_timeout.t -> 'a) -> 'a

val fold : t -> init:'a -> mutex:('a -> ([< ], t, Core.Std.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Nano_mutex.t -> 'b) -> is_running:('b -> ([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'c) -> have_called_go:('c -> ([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'd) -> fds_whose_watching_has_changed:('d -> ([< ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> 'e) -> file_descr_watcher:('e -> ([< ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> 'f) -> time_spent_waiting_for_io:('f -> ([< ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> 'g) -> fd_by_descr:('g -> ([< ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> 'h) -> timerfd:('h -> ([< ], t, Core.Std.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Std.Linux_ext.Timerfd.t option -> 'i) -> scheduler_thread_id:('i -> ([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'j) -> interruptor:('j -> ([< ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> 'k) -> signal_manager:('k -> ([< ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> 'l) -> thread_pool:('l -> ([< ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> 'm) -> handle_thread_pool_stuck:('m -> ([< ], t, stuck_for:Core.Std.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Std.Time_ns.Span.t -> unit) -> 'n) -> busy_pollers:('n -> ([< ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> 'o) -> busy_poll_thread_is_running:('o -> ([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'p) -> next_tsc_calibration:('p -> ([< ], t, Core.Std.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Time_stamp_counter.t -> 'q) -> kernel_scheduler:('q -> ([< ], t, Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Import.Kernel_scheduler.t -> 'r) -> max_inter_cycle_timeout:('r -> ([< ], t, Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_inter_cycle_timeout.t -> 's) -> min_inter_cycle_timeout:('s -> ([< ], t, Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Min_inter_cycle_timeout.t -> 't) -> 't

val for_all : t -> mutex:(([< ], t, Core.Std.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Nano_mutex.t -> bool) -> is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> have_called_go:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> fds_whose_watching_has_changed:(([< ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> bool) -> file_descr_watcher:(([< ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> bool) -> time_spent_waiting_for_io:(([< ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> bool) -> fd_by_descr:(([< ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> bool) -> timerfd:(([< ], t, Core.Std.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Std.Linux_ext.Timerfd.t option -> bool) -> scheduler_thread_id:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> bool) -> interruptor:(([< ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> bool) -> signal_manager:(([< ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> bool) -> thread_pool:(([< ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> bool) -> handle_thread_pool_stuck:(([< ], t, stuck_for:Core.Std.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Std.Time_ns.Span.t -> unit) -> bool) -> busy_pollers:(([< ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> bool) -> busy_poll_thread_is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> next_tsc_calibration:(([< ], t, Core.Std.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Time_stamp_counter.t -> bool) -> kernel_scheduler:(([< ], t, Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Import.Kernel_scheduler.t -> bool) -> max_inter_cycle_timeout:(([< ], t, Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_inter_cycle_timeout.t -> bool) -> min_inter_cycle_timeout:(([< ], t, Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Min_inter_cycle_timeout.t -> bool) -> bool

val exists : t -> mutex:(([< ], t, Core.Std.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Nano_mutex.t -> bool) -> is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> have_called_go:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> fds_whose_watching_has_changed:(([< ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> bool) -> file_descr_watcher:(([< ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> bool) -> time_spent_waiting_for_io:(([< ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> bool) -> fd_by_descr:(([< ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> bool) -> timerfd:(([< ], t, Core.Std.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Std.Linux_ext.Timerfd.t option -> bool) -> scheduler_thread_id:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> bool) -> interruptor:(([< ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> bool) -> signal_manager:(([< ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> bool) -> thread_pool:(([< ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> bool) -> handle_thread_pool_stuck:(([< ], t, stuck_for:Core.Std.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Std.Time_ns.Span.t -> unit) -> bool) -> busy_pollers:(([< ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> bool) -> busy_poll_thread_is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> next_tsc_calibration:(([< ], t, Core.Std.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Time_stamp_counter.t -> bool) -> kernel_scheduler:(([< ], t, Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Import.Kernel_scheduler.t -> bool) -> max_inter_cycle_timeout:(([< ], t, Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_inter_cycle_timeout.t -> bool) -> min_inter_cycle_timeout:(([< ], t, Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Min_inter_cycle_timeout.t -> bool) -> bool

val to_list : t -> mutex:(([< ], t, Core.Std.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Nano_mutex.t -> 'a) -> is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> have_called_go:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> fds_whose_watching_has_changed:(([< ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> 'a) -> file_descr_watcher:(([< ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> 'a) -> time_spent_waiting_for_io:(([< ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> 'a) -> fd_by_descr:(([< ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> 'a) -> timerfd:(([< ], t, Core.Std.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Std.Linux_ext.Timerfd.t option -> 'a) -> scheduler_thread_id:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'a) -> interruptor:(([< ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> 'a) -> signal_manager:(([< ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> 'a) -> thread_pool:(([< ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> 'a) -> handle_thread_pool_stuck:(([< ], t, stuck_for:Core.Std.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Std.Time_ns.Span.t -> unit) -> 'a) -> busy_pollers:(([< ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> 'a) -> busy_poll_thread_is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> next_tsc_calibration:(([< ], t, Core.Std.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Time_stamp_counter.t -> 'a) -> kernel_scheduler:(([< ], t, Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Import.Kernel_scheduler.t -> 'a) -> max_inter_cycle_timeout:(([< ], t, Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_inter_cycle_timeout.t -> 'a) -> min_inter_cycle_timeout:(([< ], t, Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Min_inter_cycle_timeout.t -> 'a) -> 'a list

val map : t -> mutex:(([< ], t, Core.Std.Nano_mutex.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Nano_mutex.t -> Core.Std.Nano_mutex.t) -> is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> have_called_go:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> fds_whose_watching_has_changed:(([< ], t, Fd.t list) Fieldslib.Field.t_with_perm -> t -> Fd.t list -> Fd.t list) -> file_descr_watcher:(([< ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm -> t -> File_descr_watcher.t -> File_descr_watcher.t) -> time_spent_waiting_for_io:(([< ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm -> t -> Tsc.Span.t -> Tsc.Span.t) -> fd_by_descr:(([< ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm -> t -> Fd_by_descr.t -> Fd_by_descr.t) -> timerfd:(([< ], t, Core.Std.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm -> t -> Core.Std.Linux_ext.Timerfd.t option -> Core.Std.Linux_ext.Timerfd.t option) -> scheduler_thread_id:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> int) -> interruptor:(([< ], t, Interruptor.t) Fieldslib.Field.t_with_perm -> t -> Interruptor.t -> Interruptor.t) -> signal_manager:(([< ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm -> t -> Raw_signal_manager.t -> Raw_signal_manager.t) -> thread_pool:(([< ], t, Thread_pool.t) Fieldslib.Field.t_with_perm -> t -> Thread_pool.t -> Thread_pool.t) -> handle_thread_pool_stuck:(([< ], t, stuck_for:Core.Std.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm -> t -> (stuck_for:Core.Std.Time_ns.Span.t -> unit) -> stuck_for:Core.Std.Time_ns.Span.t -> unit) -> busy_pollers:(([< ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm -> t -> Busy_pollers.t -> Busy_pollers.t) -> busy_poll_thread_is_running:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> next_tsc_calibration:(([< ], t, Core.Std.Time_stamp_counter.t) Fieldslib.Field.t_with_perm -> t -> Core.Std.Time_stamp_counter.t -> Core.Std.Time_stamp_counter.t) -> kernel_scheduler:(([< ], t, Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm -> t -> Import.Kernel_scheduler.t -> Import.Kernel_scheduler.t) -> max_inter_cycle_timeout:(([< ], t, Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_inter_cycle_timeout.t -> Import.Max_inter_cycle_timeout.t) -> min_inter_cycle_timeout:(([< ], t, Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm -> t -> Import.Min_inter_cycle_timeout.t -> 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.Std.Linux_ext.Timerfd.t option -> scheduler_thread_id:int -> handle_thread_pool_stuck:(stuck_for:Core.Std.Time_ns.Span.t -> unit) -> busy_poll_thread_is_running:bool -> next_tsc_calibration:Core.Std.Time_stamp_counter.t -> max_inter_cycle_timeout:Import.Max_inter_cycle_timeout.t -> min_inter_cycle_timeout:Import.Min_inter_cycle_timeout.t -> unit