Module Fields

val names : string list

val min_inter_cycle_timeout : ([< ], t, Import.Min_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm

val max_inter_cycle_timeout : ([< ], t, Import.Max_inter_cycle_timeout.t) Fieldslib.Field.t_with_perm

val kernel_scheduler : ([< ], t, Import.Kernel_scheduler.t) Fieldslib.Field.t_with_perm

val next_tsc_calibration : ([< ], t, Core.Std.Time_stamp_counter.t) Fieldslib.Field.t_with_perm

val busy_poll_thread_is_running : ([< ], t, bool) Fieldslib.Field.t_with_perm

val busy_pollers : ([< ], t, Busy_pollers.t) Fieldslib.Field.t_with_perm

val handle_thread_pool_stuck : ([< ], t, stuck_for:Core.Std.Time_ns.Span.t -> unit) Fieldslib.Field.t_with_perm

val thread_pool : ([< ], t, Thread_pool.t) Fieldslib.Field.t_with_perm

val signal_manager : ([< ], t, Raw_signal_manager.t) Fieldslib.Field.t_with_perm

val interruptor : ([< ], t, Interruptor.t) Fieldslib.Field.t_with_perm

val scheduler_thread_id : ([< ], t, int) Fieldslib.Field.t_with_perm

val timerfd : ([< ], t, Core.Std.Linux_ext.Timerfd.t option) Fieldslib.Field.t_with_perm

val fd_by_descr : ([< ], t, Fd_by_descr.t) Fieldslib.Field.t_with_perm

val time_spent_waiting_for_io : ([< ], t, Tsc.Span.t) Fieldslib.Field.t_with_perm

val file_descr_watcher : ([< ], t, File_descr_watcher.t) Fieldslib.Field.t_with_perm

val fds_whose_watching_has_changed : ([< ], t, Fd.t list) Fieldslib.Field.t_with_perm

val have_called_go : ([< ], t, bool) Fieldslib.Field.t_with_perm

val is_running : ([< ], t, bool) Fieldslib.Field.t_with_perm

val mutex : ([< ], t, Core.Std.Nano_mutex.t) Fieldslib.Field.t_with_perm

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

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

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

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

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

val map_poly : ([< ], t, 'a) Fieldslib.Field.user -> 'a list

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

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

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