async_unix v0.9.1 · OCaml Package

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

package async_unix