Module Direct

val iter : t -> check_access:(([< ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> unit) -> job_pool:(([< ], t, Job_pool.t) Fieldslib.Field.t_with_perm -> t -> Job_pool.t -> unit) -> normal_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> unit) -> low_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> unit) -> main_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> unit) -> current_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> unit) -> uncaught_exn:(([< ], t, (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option) Fieldslib.Field.t_with_perm -> t -> (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option -> unit) -> cycle_count:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> unit) -> cycle_start:(([< ], t, Import.Time_ns.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.t -> unit) -> run_every_cycle_start:(([< ], t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) list -> unit) -> last_cycle_time:(([< ], t, Import.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.Span.t -> unit) -> last_cycle_num_jobs:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> unit) -> time_source:(([< ], t, Core_kernel.Std.read_write Time_source.T1.t) Fieldslib.Field.t_with_perm -> t -> Core_kernel.Std.read_write Time_source.T1.t -> unit) -> external_jobs:(([< ], t, External_job.t Core_kernel.Std.Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> t -> External_job.t Core_kernel.Std.Thread_safe_queue.t -> unit) -> thread_safe_external_job_hook:(([< ], t, unit -> unit) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) -> unit) -> job_queued_hook:(([< ], t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Priority.t -> unit) option -> unit) -> event_added_hook:(([< ], t, (Import.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Import.Time_ns.t -> unit) option -> unit) -> yield_ivar:(([< ], t, unit Types.Ivar.t Core_kernel.Std.sexp_opaque option) Fieldslib.Field.t_with_perm -> t -> unit Types.Ivar.t Core_kernel.Std.sexp_opaque option -> unit) -> check_invariants:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> unit) -> max_num_jobs_per_priority_per_cycle:(([< ], t, Import.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_num_jobs_per_priority_per_cycle.t -> unit) -> record_backtraces:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> 'a

val fold : t -> init:'a -> check_access:('a -> ([< ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> 'b) -> job_pool:('b -> ([< ], t, Job_pool.t) Fieldslib.Field.t_with_perm -> t -> Job_pool.t -> 'c) -> normal_priority_jobs:('c -> ([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> 'd) -> low_priority_jobs:('d -> ([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> 'e) -> main_execution_context:('e -> ([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> 'f) -> current_execution_context:('f -> ([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> 'g) -> uncaught_exn:('g -> ([< ], t, (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option) Fieldslib.Field.t_with_perm -> t -> (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option -> 'h) -> cycle_count:('h -> ([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'i) -> cycle_start:('i -> ([< ], t, Import.Time_ns.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.t -> 'j) -> run_every_cycle_start:('j -> ([< ], t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) list -> 'k) -> last_cycle_time:('k -> ([< ], t, Import.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.Span.t -> 'l) -> last_cycle_num_jobs:('l -> ([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'm) -> time_source:('m -> ([< ], t, Core_kernel.Std.read_write Time_source.T1.t) Fieldslib.Field.t_with_perm -> t -> Core_kernel.Std.read_write Time_source.T1.t -> 'n) -> external_jobs:('n -> ([< ], t, External_job.t Core_kernel.Std.Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> t -> External_job.t Core_kernel.Std.Thread_safe_queue.t -> 'o) -> thread_safe_external_job_hook:('o -> ([< ], t, unit -> unit) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) -> 'p) -> job_queued_hook:('p -> ([< ], t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Priority.t -> unit) option -> 'q) -> event_added_hook:('q -> ([< ], t, (Import.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Import.Time_ns.t -> unit) option -> 'r) -> yield_ivar:('r -> ([< ], t, unit Types.Ivar.t Core_kernel.Std.sexp_opaque option) Fieldslib.Field.t_with_perm -> t -> unit Types.Ivar.t Core_kernel.Std.sexp_opaque option -> 's) -> check_invariants:('s -> ([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 't) -> max_num_jobs_per_priority_per_cycle:('t -> ([< ], t, Import.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_num_jobs_per_priority_per_cycle.t -> 'u) -> record_backtraces:('u -> ([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'v) -> 'v

val for_all : t -> check_access:(([< ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> bool) -> job_pool:(([< ], t, Job_pool.t) Fieldslib.Field.t_with_perm -> t -> Job_pool.t -> bool) -> normal_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> bool) -> low_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> bool) -> main_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> bool) -> current_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> bool) -> uncaught_exn:(([< ], t, (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option) Fieldslib.Field.t_with_perm -> t -> (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option -> bool) -> cycle_count:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> bool) -> cycle_start:(([< ], t, Import.Time_ns.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.t -> bool) -> run_every_cycle_start:(([< ], t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) list -> bool) -> last_cycle_time:(([< ], t, Import.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.Span.t -> bool) -> last_cycle_num_jobs:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> bool) -> time_source:(([< ], t, Core_kernel.Std.read_write Time_source.T1.t) Fieldslib.Field.t_with_perm -> t -> Core_kernel.Std.read_write Time_source.T1.t -> bool) -> external_jobs:(([< ], t, External_job.t Core_kernel.Std.Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> t -> External_job.t Core_kernel.Std.Thread_safe_queue.t -> bool) -> thread_safe_external_job_hook:(([< ], t, unit -> unit) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) -> bool) -> job_queued_hook:(([< ], t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Priority.t -> unit) option -> bool) -> event_added_hook:(([< ], t, (Import.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Import.Time_ns.t -> unit) option -> bool) -> yield_ivar:(([< ], t, unit Types.Ivar.t Core_kernel.Std.sexp_opaque option) Fieldslib.Field.t_with_perm -> t -> unit Types.Ivar.t Core_kernel.Std.sexp_opaque option -> bool) -> check_invariants:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> max_num_jobs_per_priority_per_cycle:(([< ], t, Import.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_num_jobs_per_priority_per_cycle.t -> bool) -> record_backtraces:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> bool

val exists : t -> check_access:(([< ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> bool) -> job_pool:(([< ], t, Job_pool.t) Fieldslib.Field.t_with_perm -> t -> Job_pool.t -> bool) -> normal_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> bool) -> low_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> bool) -> main_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> bool) -> current_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> bool) -> uncaught_exn:(([< ], t, (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option) Fieldslib.Field.t_with_perm -> t -> (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option -> bool) -> cycle_count:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> bool) -> cycle_start:(([< ], t, Import.Time_ns.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.t -> bool) -> run_every_cycle_start:(([< ], t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) list -> bool) -> last_cycle_time:(([< ], t, Import.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.Span.t -> bool) -> last_cycle_num_jobs:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> bool) -> time_source:(([< ], t, Core_kernel.Std.read_write Time_source.T1.t) Fieldslib.Field.t_with_perm -> t -> Core_kernel.Std.read_write Time_source.T1.t -> bool) -> external_jobs:(([< ], t, External_job.t Core_kernel.Std.Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> t -> External_job.t Core_kernel.Std.Thread_safe_queue.t -> bool) -> thread_safe_external_job_hook:(([< ], t, unit -> unit) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) -> bool) -> job_queued_hook:(([< ], t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Priority.t -> unit) option -> bool) -> event_added_hook:(([< ], t, (Import.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Import.Time_ns.t -> unit) option -> bool) -> yield_ivar:(([< ], t, unit Types.Ivar.t Core_kernel.Std.sexp_opaque option) Fieldslib.Field.t_with_perm -> t -> unit Types.Ivar.t Core_kernel.Std.sexp_opaque option -> bool) -> check_invariants:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> max_num_jobs_per_priority_per_cycle:(([< ], t, Import.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_num_jobs_per_priority_per_cycle.t -> bool) -> record_backtraces:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> bool

val to_list : t -> check_access:(([< ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> 'a) -> job_pool:(([< ], t, Job_pool.t) Fieldslib.Field.t_with_perm -> t -> Job_pool.t -> 'a) -> normal_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> 'a) -> low_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> 'a) -> main_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> 'a) -> current_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> 'a) -> uncaught_exn:(([< ], t, (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option) Fieldslib.Field.t_with_perm -> t -> (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option -> 'a) -> cycle_count:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'a) -> cycle_start:(([< ], t, Import.Time_ns.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.t -> 'a) -> run_every_cycle_start:(([< ], t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) list -> 'a) -> last_cycle_time:(([< ], t, Import.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.Span.t -> 'a) -> last_cycle_num_jobs:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> 'a) -> time_source:(([< ], t, Core_kernel.Std.read_write Time_source.T1.t) Fieldslib.Field.t_with_perm -> t -> Core_kernel.Std.read_write Time_source.T1.t -> 'a) -> external_jobs:(([< ], t, External_job.t Core_kernel.Std.Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> t -> External_job.t Core_kernel.Std.Thread_safe_queue.t -> 'a) -> thread_safe_external_job_hook:(([< ], t, unit -> unit) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) -> 'a) -> job_queued_hook:(([< ], t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Priority.t -> unit) option -> 'a) -> event_added_hook:(([< ], t, (Import.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Import.Time_ns.t -> unit) option -> 'a) -> yield_ivar:(([< ], t, unit Types.Ivar.t Core_kernel.Std.sexp_opaque option) Fieldslib.Field.t_with_perm -> t -> unit Types.Ivar.t Core_kernel.Std.sexp_opaque option -> 'a) -> check_invariants:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> max_num_jobs_per_priority_per_cycle:(([< ], t, Import.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_num_jobs_per_priority_per_cycle.t -> 'a) -> record_backtraces:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> 'a) -> 'a list

val map : t -> check_access:(([< ], t, (unit -> unit) option) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) option -> (unit -> unit) option) -> job_pool:(([< ], t, Job_pool.t) Fieldslib.Field.t_with_perm -> t -> Job_pool.t -> Job_pool.t) -> normal_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> Job_queue.t) -> low_priority_jobs:(([< ], t, Job_queue.t) Fieldslib.Field.t_with_perm -> t -> Job_queue.t -> Job_queue.t) -> main_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> Execution_context.t) -> current_execution_context:(([< ], t, Execution_context.t) Fieldslib.Field.t_with_perm -> t -> Execution_context.t -> Execution_context.t) -> uncaught_exn:(([< ], t, (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option) Fieldslib.Field.t_with_perm -> t -> (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option -> (Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option) -> cycle_count:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> int) -> cycle_start:(([< ], t, Import.Time_ns.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.t -> Import.Time_ns.t) -> run_every_cycle_start:(([< ], t, (unit -> unit) list) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) list -> (unit -> unit) list) -> last_cycle_time:(([< ], t, Import.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> t -> Import.Time_ns.Span.t -> Import.Time_ns.Span.t) -> last_cycle_num_jobs:(([< ], t, int) Fieldslib.Field.t_with_perm -> t -> int -> int) -> time_source:(([< ], t, Core_kernel.Std.read_write Time_source.T1.t) Fieldslib.Field.t_with_perm -> t -> Core_kernel.Std.read_write Time_source.T1.t -> Core_kernel.Std.read_write Time_source.T1.t) -> external_jobs:(([< ], t, External_job.t Core_kernel.Std.Thread_safe_queue.t) Fieldslib.Field.t_with_perm -> t -> External_job.t Core_kernel.Std.Thread_safe_queue.t -> External_job.t Core_kernel.Std.Thread_safe_queue.t) -> thread_safe_external_job_hook:(([< ], t, unit -> unit) Fieldslib.Field.t_with_perm -> t -> (unit -> unit) -> unit -> unit) -> job_queued_hook:(([< ], t, (Priority.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Priority.t -> unit) option -> (Priority.t -> unit) option) -> event_added_hook:(([< ], t, (Import.Time_ns.t -> unit) option) Fieldslib.Field.t_with_perm -> t -> (Import.Time_ns.t -> unit) option -> (Import.Time_ns.t -> unit) option) -> yield_ivar:(([< ], t, unit Types.Ivar.t Core_kernel.Std.sexp_opaque option) Fieldslib.Field.t_with_perm -> t -> unit Types.Ivar.t Core_kernel.Std.sexp_opaque option -> unit Types.Ivar.t Core_kernel.Std.sexp_opaque option) -> check_invariants:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> max_num_jobs_per_priority_per_cycle:(([< ], t, Import.Max_num_jobs_per_priority_per_cycle.t) Fieldslib.Field.t_with_perm -> t -> Import.Max_num_jobs_per_priority_per_cycle.t -> Import.Max_num_jobs_per_priority_per_cycle.t) -> record_backtraces:(([< ], t, bool) Fieldslib.Field.t_with_perm -> t -> bool -> bool) -> t

val set_all_mutable_fields : t -> check_access:(unit -> unit) option -> job_pool:Job_pool.t -> main_execution_context:Execution_context.t -> current_execution_context:Execution_context.t -> uncaught_exn:(Core_kernel.Std.Exn.t * Core_kernel.Std.Sexp.t) option -> cycle_count:int -> cycle_start:Import.Time_ns.t -> run_every_cycle_start:(unit -> unit) list -> last_cycle_time:Import.Time_ns.Span.t -> last_cycle_num_jobs:int -> time_source:Core_kernel.Std.read_write Time_source.T1.t -> thread_safe_external_job_hook:(unit -> unit) -> job_queued_hook:(Priority.t -> unit) option -> event_added_hook:(Import.Time_ns.t -> unit) option -> yield_ivar:unit Types.Ivar.t Core_kernel.Std.sexp_opaque option -> check_invariants:bool -> max_num_jobs_per_priority_per_cycle:Import.Max_num_jobs_per_priority_per_cycle.t -> record_backtraces:bool -> unit