package async_unix

  1. Overview
  2. Docs
Monadic concurrency library

Install 

dune-project
 Dependency

github.com Readme Changelog MIT License Edit opam file Versions (5)

Authors

  1. J
    Jane Street Group, LLC

Maintainers

  1. J
    Jane Street developers

Sources

v0.17.0.tar.gz
sha256=814d3a9997ec1316b8b2a601b24471740641647a25002761f7df7869c3ac9e33

doc/async_unix/Async_unix/Async_config/index.html

Module Async_unix.Async_configSource

include module type of struct include Async_kernel.Async_kernel_config end
module Epoll_max_ready_events = Async_kernel_config.Epoll_max_ready_events
module Io_uring_max_submission_entries = Async_kernel_config.Io_uring_max_submission_entries
module Max_inter_cycle_timeout = Async_kernel_config.Max_inter_cycle_timeout
module Min_inter_cycle_timeout = Async_kernel_config.Min_inter_cycle_timeout
module Max_num_threads = Async_kernel_config.Max_num_threads
module Max_num_jobs_per_priority_per_cycle = Async_kernel_config.Max_num_jobs_per_priority_per_cycle
module Max_num_open_file_descrs = Async_kernel_config.Max_num_open_file_descrs
module Dump_core_on_job_delay = Async_kernel_config.Dump_core_on_job_delay
module Debug_tag = Async_kernel_config.Debug_tag
module File_descr_watcher = Async_kernel_config.File_descr_watcher
module Io_uring_mode = Async_kernel_config.Io_uring_mode
type t = Async_kernel_config.t = {
  1. abort_after_thread_pool_stuck_for : Core.Time_ns.Span.t option;
  2. check_invariants : bool option;
  3. detect_invalid_access_from_thread : bool option;
  4. dump_core_on_job_delay : Dump_core_on_job_delay.t option;
  5. epoll_max_ready_events : Epoll_max_ready_events.t option;
  6. io_uring_max_submission_entries : Io_uring_max_submission_entries.t option;
  7. io_uring_mode : Io_uring_mode.t option;
  8. file_descr_watcher : File_descr_watcher.t option;
  9. max_inter_cycle_timeout : Max_inter_cycle_timeout.t option;
  10. max_num_open_file_descrs : Max_num_open_file_descrs.t option;
  11. max_num_threads : Max_num_threads.t option;
  12. max_num_jobs_per_priority_per_cycle : Max_num_jobs_per_priority_per_cycle.t option;
  13. min_inter_cycle_timeout : Min_inter_cycle_timeout.t option;
  14. print_debug_messages_for : Debug_tag.t list option;
  15. record_backtraces : bool option;
  16. report_thread_pool_stuck_for : Core.Time_ns.Span.t option;
  17. thread_pool_cpu_affinity : Thread_pool_cpu_affinity.t option;
  18. timing_wheel_config : Timing_wheel.Config.t option;
}
val sexp_of_t : t -> Sexplib0.Sexp.t
val create : ?abort_after_thread_pool_stuck_for:??? -> ?check_invariants:??? -> ?detect_invalid_access_from_thread:??? -> ?dump_core_on_job_delay:??? -> ?epoll_max_ready_events:??? -> ?io_uring_max_submission_entries:??? -> ?io_uring_mode:??? -> ?file_descr_watcher:??? -> ?max_inter_cycle_timeout:??? -> ?max_num_open_file_descrs:??? -> ?max_num_threads:??? -> ?max_num_jobs_per_priority_per_cycle:??? -> ?min_inter_cycle_timeout:??? -> ?print_debug_messages_for:??? -> ?record_backtraces:??? -> ?report_thread_pool_stuck_for:??? -> ?thread_pool_cpu_affinity:??? -> ?timing_wheel_config:??? -> unit -> t
val t : t
val environment_variable : string
module Print_debug_messages_for = Async_kernel_config.Print_debug_messages_for
val abort_after_thread_pool_stuck_for : Core.Time_ns.Span.t
val check_invariants : bool
val detect_invalid_access_from_thread : bool
val dump_core_on_job_delay : Dump_core_on_job_delay.t
val thread_pool_cpu_affinity : Thread_pool_cpu_affinity.t
val epoll_max_ready_events : Epoll_max_ready_events.t
val io_uring_max_submission_entries : Io_uring_max_submission_entries.t
val io_uring_mode : Io_uring_mode.t
Sourceval file_descr_watcher : File_descr_watcher.t
val max_inter_cycle_timeout : Max_inter_cycle_timeout.t
val max_num_jobs_per_priority_per_cycle : Max_num_jobs_per_priority_per_cycle.t
Sourceval max_num_open_file_descrs : Max_num_open_file_descrs.t
val max_num_threads : Max_num_threads.t
val min_inter_cycle_timeout : Min_inter_cycle_timeout.t
val record_backtraces : bool
val report_thread_pool_stuck_for : Core.Time_ns.Span.t
val timing_wheel_config : Timing_wheel.Config.t
val default_timing_wheel_config_for_word_size : Core.Word_size.t -> Timing_wheel.Config.t
val task_id : (unit -> Core.Sexp.t) Core.ref