Module `Scheduler.Fields`Source

Sourceval names : string list

val record_backtraces : 
  ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm

Source

val max_num_jobs_per_priority_per_cycle : 
  ([< `Read | `Set_and_create ],
    t,
    Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
    Fieldslib.Field.t_with_perm

Source

val check_invariants : 
  ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm

Source

val yield_until_no_jobs_remain : 
  ([< `Read | `Set_and_create ],
    t,
    (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
    Fieldslib.Field.t_with_perm

Source

val yield : 
  ([< `Read | `Set_and_create ],
    t,
    (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
    Fieldslib.Field.t_with_perm

Source

val event_added_hook : 
  ([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
    Fieldslib.Field.t_with_perm

Source

val job_queued_hook : 
  ([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
    Fieldslib.Field.t_with_perm

Source

val thread_safe_external_job_hook : 
  ([< `Read | `Set_and_create ], t, unit -> unit) Fieldslib.Field.t_with_perm

Source

val external_jobs : 
  ([< `Read | `Set_and_create ],
    t,
    Async_kernel__.Types.External_job.t Thread_safe_queue.t)
    Fieldslib.Field.t_with_perm

Source

val time_source : 
  ([< `Read | `Set_and_create ],
    t,
    Core.read_write Synchronous_time_source.T1.t)
    Fieldslib.Field.t_with_perm

Source

val total_cycle_time : 
  ([< `Read | `Set_and_create ],
    t,
    Core.Core_private.Time_ns_alternate_sexp.Span.t)
    Fieldslib.Field.t_with_perm

Source

val last_cycle_num_jobs : 
  ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm

Source

val last_cycle_time : 
  ([< `Read | `Set_and_create ],
    t,
    Core.Core_private.Time_ns_alternate_sexp.Span.t)
    Fieldslib.Field.t_with_perm

Source

val run_every_cycle_end_state : 
  ([< `Read | `Set_and_create ],
    t,
    (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
    Fieldslib.Field.t_with_perm

Source

val run_every_cycle_end : 
  ([< `Read | `Set_and_create ], t, (unit -> unit) array)
    Fieldslib.Field.t_with_perm

Source

val run_every_cycle_start_state : 
  ([< `Read | `Set_and_create ],
    t,
    (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
    Fieldslib.Field.t_with_perm

Source

val run_every_cycle_start : 
  ([< `Read | `Set_and_create ], t, (unit -> unit) array)
    Fieldslib.Field.t_with_perm

Source

val in_cycle : 
  ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm

Source

val cycle_start : 
  ([< `Read | `Set_and_create ], t, Core.Time_ns.t) Fieldslib.Field.t_with_perm

Source

val cycle_count : 
  ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm

Source

val uncaught_exn : 
  ([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
    Fieldslib.Field.t_with_perm

Source

val current_execution_context : 
  ([< `Read | `Set_and_create ], t, Execution_context.t)
    Fieldslib.Field.t_with_perm

Source

val main_execution_context : 
  ([< `Read | `Set_and_create ], t, Execution_context.t)
    Fieldslib.Field.t_with_perm

Source

val very_low_priority_workers : 
  ([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
    Fieldslib.Field.t_with_perm

Source

val low_priority_jobs : 
  ([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
    Fieldslib.Field.t_with_perm

Source

val normal_priority_jobs : 
  ([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
    Fieldslib.Field.t_with_perm

Source

val job_pool : 
  ([< `Read | `Set_and_create ],
    t,
    (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
      Tuple_pool.t)
    Fieldslib.Field.t_with_perm

Source

val check_access : 
  ([< `Read | `Set_and_create ], t, (unit -> unit) option)
    Fieldslib.Field.t_with_perm

Source

val make_creator : 
  check_access:
    (([< `Read | `Set_and_create ], t, (unit -> unit) option)
       Fieldslib.Field.t_with_perm ->
      'a ->
      ('b -> (unit -> unit) option) * 'c) ->
  job_pool:
    (([< `Read | `Set_and_create ],
       t,
       (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
         Tuple_pool.t)
       Fieldslib.Field.t_with_perm ->
      'c ->
      ('b ->
      (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
        Tuple_pool.t)
      * 'd) ->
  normal_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      'd ->
      ('b -> Async_kernel__.Types.Job_queue.t) * 'e) ->
  low_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      'e ->
      ('b -> Async_kernel__.Types.Job_queue.t) * 'f) ->
  very_low_priority_workers:
    (([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
       Fieldslib.Field.t_with_perm ->
      'f ->
      ('b -> Very_low_priority_worker.t Core.Deque.t) * 'g) ->
  main_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      'g ->
      ('b -> Execution_context.t) * 'h) ->
  current_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      'h ->
      ('b -> Execution_context.t) * 'i) ->
  uncaught_exn:
    (([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
       Fieldslib.Field.t_with_perm ->
      'i ->
      ('b -> (Core.Exn.t * Core.Sexp.t) option) * 'j) ->
  cycle_count:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      'j ->
      ('b -> int) * 'k) ->
  cycle_start:
    (([< `Read | `Set_and_create ], t, Core.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      'k ->
      ('b -> Core.Time_ns.t) * 'l) ->
  in_cycle:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      'l ->
      ('b -> bool) * 'm) ->
  run_every_cycle_start:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      'm ->
      ('b -> (unit -> unit) array) * 'n) ->
  run_every_cycle_start_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      'n ->
      ('b ->
      (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
      * 'o) ->
  run_every_cycle_end:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      'o ->
      ('b -> (unit -> unit) array) * 'p) ->
  run_every_cycle_end_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      'p ->
      ('b ->
      (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
      * 'q) ->
  last_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      'q ->
      ('b -> Core.Core_private.Time_ns_alternate_sexp.Span.t) * 'r) ->
  last_cycle_num_jobs:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      'r ->
      ('b -> int) * 's) ->
  total_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      's ->
      ('b -> Core.Core_private.Time_ns_alternate_sexp.Span.t) * 't) ->
  time_source:
    (([< `Read | `Set_and_create ],
       t,
       Core.read_write Synchronous_time_source.T1.t)
       Fieldslib.Field.t_with_perm ->
      't ->
      ('b -> Core.read_write Synchronous_time_source.T1.t) * 'u) ->
  external_jobs:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel__.Types.External_job.t Thread_safe_queue.t)
       Fieldslib.Field.t_with_perm ->
      'u ->
      ('b -> Async_kernel__.Types.External_job.t Thread_safe_queue.t) * 'v) ->
  thread_safe_external_job_hook:
    (([< `Read | `Set_and_create ], t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      'v ->
      ('b -> unit -> unit) * 'w) ->
  job_queued_hook:
    (([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      'w ->
      ('b -> (Priority.t -> unit) option) * 'x) ->
  event_added_hook:
    (([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      'x ->
      ('b -> (Core.Time_ns.t -> unit) option) * 'y) ->
  yield:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      'y ->
      ('b -> (unit, Core.read_write) Async_kernel__.Types.Bvar.t) * 'z) ->
  yield_until_no_jobs_remain:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      'z ->
      ('b -> (unit, Core.read_write) Async_kernel__.Types.Bvar.t) * 'a1) ->
  check_invariants:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      'a1 ->
      ('b -> bool) * 'b1) ->
  max_num_jobs_per_priority_per_cycle:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
       Fieldslib.Field.t_with_perm ->
      'b1 ->
      ('b -> Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) * 'c1) ->
  record_backtraces:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      'c1 ->
      ('b -> bool) * 'd1) ->
  'a ->
  ('b -> t) * 'd1

Source

val create : 
  check_access:(unit -> unit) option ->
  job_pool:
    (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
      Tuple_pool.t ->
  normal_priority_jobs:Async_kernel__.Types.Job_queue.t ->
  low_priority_jobs:Async_kernel__.Types.Job_queue.t ->
  very_low_priority_workers:Very_low_priority_worker.t Core.Deque.t ->
  main_execution_context:Execution_context.t ->
  current_execution_context:Execution_context.t ->
  uncaught_exn:(Core.Exn.t * Core.Sexp.t) option ->
  cycle_count:int ->
  cycle_start:Core.Time_ns.t ->
  in_cycle:bool ->
  run_every_cycle_start:(unit -> unit) array ->
  run_every_cycle_start_state:
    (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t ->
  run_every_cycle_end:(unit -> unit) array ->
  run_every_cycle_end_state:
    (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t ->
  last_cycle_time:Core.Core_private.Time_ns_alternate_sexp.Span.t ->
  last_cycle_num_jobs:int ->
  total_cycle_time:Core.Core_private.Time_ns_alternate_sexp.Span.t ->
  time_source:Core.read_write Synchronous_time_source.T1.t ->
  external_jobs:Async_kernel__.Types.External_job.t Thread_safe_queue.t ->
  thread_safe_external_job_hook:(unit -> unit) ->
  job_queued_hook:(Priority.t -> unit) option ->
  event_added_hook:(Core.Time_ns.t -> unit) option ->
  yield:(unit, Core.read_write) Async_kernel__.Types.Bvar.t ->
  yield_until_no_jobs_remain:
    (unit, Core.read_write) Async_kernel__.Types.Bvar.t ->
  check_invariants:bool ->
  max_num_jobs_per_priority_per_cycle:
    Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t ->
  record_backtraces:bool ->
  t

Source

val map : 
  check_access:
    (([< `Read | `Set_and_create ], t, (unit -> unit) option)
       Fieldslib.Field.t_with_perm ->
      (unit -> unit) option) ->
  job_pool:
    (([< `Read | `Set_and_create ],
       t,
       (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
         Tuple_pool.t)
       Fieldslib.Field.t_with_perm ->
      (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
        Tuple_pool.t) ->
  normal_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      Async_kernel__.Types.Job_queue.t) ->
  low_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      Async_kernel__.Types.Job_queue.t) ->
  very_low_priority_workers:
    (([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
       Fieldslib.Field.t_with_perm ->
      Very_low_priority_worker.t Core.Deque.t) ->
  main_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      Execution_context.t) ->
  current_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      Execution_context.t) ->
  uncaught_exn:
    (([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
       Fieldslib.Field.t_with_perm ->
      (Core.Exn.t * Core.Sexp.t) option) ->
  cycle_count:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> int) ->
  cycle_start:
    (([< `Read | `Set_and_create ], t, Core.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      Core.Time_ns.t) ->
  in_cycle:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_start:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      (unit -> unit) array) ->
  run_every_cycle_start_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) ->
  run_every_cycle_end:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      (unit -> unit) array) ->
  run_every_cycle_end_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t) ->
  last_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      Core.Core_private.Time_ns_alternate_sexp.Span.t) ->
  last_cycle_num_jobs:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> int) ->
  total_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      Core.Core_private.Time_ns_alternate_sexp.Span.t) ->
  time_source:
    (([< `Read | `Set_and_create ],
       t,
       Core.read_write Synchronous_time_source.T1.t)
       Fieldslib.Field.t_with_perm ->
      Core.read_write Synchronous_time_source.T1.t) ->
  external_jobs:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel__.Types.External_job.t Thread_safe_queue.t)
       Fieldslib.Field.t_with_perm ->
      Async_kernel__.Types.External_job.t Thread_safe_queue.t) ->
  thread_safe_external_job_hook:
    (([< `Read | `Set_and_create ], t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      unit ->
      unit) ->
  job_queued_hook:
    (([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      (Priority.t -> unit) option) ->
  event_added_hook:
    (([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      (Core.Time_ns.t -> unit) option) ->
  yield:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      (unit, Core.read_write) Async_kernel__.Types.Bvar.t) ->
  yield_until_no_jobs_remain:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      (unit, Core.read_write) Async_kernel__.Types.Bvar.t) ->
  check_invariants:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  max_num_jobs_per_priority_per_cycle:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
       Fieldslib.Field.t_with_perm ->
      Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t) ->
  record_backtraces:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  t

Source

val iter : 
  check_access:
    (([< `Read | `Set_and_create ], t, (unit -> unit) option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  job_pool:
    (([< `Read | `Set_and_create ],
       t,
       (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
         Tuple_pool.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  normal_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  low_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  very_low_priority_workers:
    (([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  main_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  current_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  uncaught_exn:
    (([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  cycle_count:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      unit) ->
  cycle_start:
    (([< `Read | `Set_and_create ], t, Core.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  in_cycle:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      unit) ->
  run_every_cycle_start:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  run_every_cycle_start_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  run_every_cycle_end:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  run_every_cycle_end_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  last_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  last_cycle_num_jobs:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      unit) ->
  total_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  time_source:
    (([< `Read | `Set_and_create ],
       t,
       Core.read_write Synchronous_time_source.T1.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  external_jobs:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel__.Types.External_job.t Thread_safe_queue.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  thread_safe_external_job_hook:
    (([< `Read | `Set_and_create ], t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  job_queued_hook:
    (([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  event_added_hook:
    (([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  yield:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  yield_until_no_jobs_remain:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  check_invariants:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      unit) ->
  max_num_jobs_per_priority_per_cycle:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  record_backtraces:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      unit) ->
  unit

Source

val fold : 
  init:'a ->
  check_access:
    ('a ->
      ([< `Read | `Set_and_create ], t, (unit -> unit) option)
        Fieldslib.Field.t_with_perm ->
      'b) ->
  job_pool:
    ('b ->
      ([< `Read | `Set_and_create ],
        t,
        (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
          Tuple_pool.t)
        Fieldslib.Field.t_with_perm ->
      'c) ->
  normal_priority_jobs:
    ('c ->
      ([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
        Fieldslib.Field.t_with_perm ->
      'd) ->
  low_priority_jobs:
    ('d ->
      ([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
        Fieldslib.Field.t_with_perm ->
      'e) ->
  very_low_priority_workers:
    ('e ->
      ([< `Read | `Set_and_create ],
        t,
        Very_low_priority_worker.t Core.Deque.t)
        Fieldslib.Field.t_with_perm ->
      'f) ->
  main_execution_context:
    ('f ->
      ([< `Read | `Set_and_create ], t, Execution_context.t)
        Fieldslib.Field.t_with_perm ->
      'g) ->
  current_execution_context:
    ('g ->
      ([< `Read | `Set_and_create ], t, Execution_context.t)
        Fieldslib.Field.t_with_perm ->
      'h) ->
  uncaught_exn:
    ('h ->
      ([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
        Fieldslib.Field.t_with_perm ->
      'i) ->
  cycle_count:
    ('i ->
      ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      'j) ->
  cycle_start:
    ('j ->
      ([< `Read | `Set_and_create ], t, Core.Time_ns.t)
        Fieldslib.Field.t_with_perm ->
      'k) ->
  in_cycle:
    ('k ->
      ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      'l) ->
  run_every_cycle_start:
    ('l ->
      ([< `Read | `Set_and_create ], t, (unit -> unit) array)
        Fieldslib.Field.t_with_perm ->
      'm) ->
  run_every_cycle_start_state:
    ('m ->
      ([< `Read | `Set_and_create ],
        t,
        (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
        Fieldslib.Field.t_with_perm ->
      'n) ->
  run_every_cycle_end:
    ('n ->
      ([< `Read | `Set_and_create ], t, (unit -> unit) array)
        Fieldslib.Field.t_with_perm ->
      'o) ->
  run_every_cycle_end_state:
    ('o ->
      ([< `Read | `Set_and_create ],
        t,
        (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
        Fieldslib.Field.t_with_perm ->
      'p) ->
  last_cycle_time:
    ('p ->
      ([< `Read | `Set_and_create ],
        t,
        Core.Core_private.Time_ns_alternate_sexp.Span.t)
        Fieldslib.Field.t_with_perm ->
      'q) ->
  last_cycle_num_jobs:
    ('q ->
      ([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      'r) ->
  total_cycle_time:
    ('r ->
      ([< `Read | `Set_and_create ],
        t,
        Core.Core_private.Time_ns_alternate_sexp.Span.t)
        Fieldslib.Field.t_with_perm ->
      's) ->
  time_source:
    ('s ->
      ([< `Read | `Set_and_create ],
        t,
        Core.read_write Synchronous_time_source.T1.t)
        Fieldslib.Field.t_with_perm ->
      't) ->
  external_jobs:
    ('t ->
      ([< `Read | `Set_and_create ],
        t,
        Async_kernel__.Types.External_job.t Thread_safe_queue.t)
        Fieldslib.Field.t_with_perm ->
      'u) ->
  thread_safe_external_job_hook:
    ('u ->
      ([< `Read | `Set_and_create ], t, unit -> unit)
        Fieldslib.Field.t_with_perm ->
      'v) ->
  job_queued_hook:
    ('v ->
      ([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
        Fieldslib.Field.t_with_perm ->
      'w) ->
  event_added_hook:
    ('w ->
      ([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
        Fieldslib.Field.t_with_perm ->
      'x) ->
  yield:
    ('x ->
      ([< `Read | `Set_and_create ],
        t,
        (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
        Fieldslib.Field.t_with_perm ->
      'y) ->
  yield_until_no_jobs_remain:
    ('y ->
      ([< `Read | `Set_and_create ],
        t,
        (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
        Fieldslib.Field.t_with_perm ->
      'z) ->
  check_invariants:
    ('z ->
      ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      'a1) ->
  max_num_jobs_per_priority_per_cycle:
    ('a1 ->
      ([< `Read | `Set_and_create ],
        t,
        Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
        Fieldslib.Field.t_with_perm ->
      'b1) ->
  record_backtraces:
    ('b1 ->
      ([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      'c1) ->
  'c1

Source

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

Source

val for_all : 
  check_access:
    (([< `Read | `Set_and_create ], t, (unit -> unit) option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  job_pool:
    (([< `Read | `Set_and_create ],
       t,
       (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
         Tuple_pool.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  normal_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  low_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  very_low_priority_workers:
    (([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  main_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  current_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  uncaught_exn:
    (([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  cycle_count:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      bool) ->
  cycle_start:
    (([< `Read | `Set_and_create ], t, Core.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  in_cycle:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_start:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_start_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_end:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_end_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  last_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  last_cycle_num_jobs:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      bool) ->
  total_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  time_source:
    (([< `Read | `Set_and_create ],
       t,
       Core.read_write Synchronous_time_source.T1.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  external_jobs:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel__.Types.External_job.t Thread_safe_queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  thread_safe_external_job_hook:
    (([< `Read | `Set_and_create ], t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  job_queued_hook:
    (([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  event_added_hook:
    (([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  yield:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  yield_until_no_jobs_remain:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  check_invariants:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  max_num_jobs_per_priority_per_cycle:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  record_backtraces:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  bool

Source

val exists : 
  check_access:
    (([< `Read | `Set_and_create ], t, (unit -> unit) option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  job_pool:
    (([< `Read | `Set_and_create ],
       t,
       (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
         Tuple_pool.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  normal_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  low_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  very_low_priority_workers:
    (([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  main_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  current_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  uncaught_exn:
    (([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  cycle_count:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      bool) ->
  cycle_start:
    (([< `Read | `Set_and_create ], t, Core.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  in_cycle:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_start:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_start_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_end:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  run_every_cycle_end_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  last_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  last_cycle_num_jobs:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm ->
      bool) ->
  total_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  time_source:
    (([< `Read | `Set_and_create ],
       t,
       Core.read_write Synchronous_time_source.T1.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  external_jobs:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel__.Types.External_job.t Thread_safe_queue.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  thread_safe_external_job_hook:
    (([< `Read | `Set_and_create ], t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  job_queued_hook:
    (([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  event_added_hook:
    (([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  yield:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  yield_until_no_jobs_remain:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  check_invariants:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  max_num_jobs_per_priority_per_cycle:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  record_backtraces:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm ->
      bool) ->
  bool

Source

val to_list : 
  check_access:
    (([< `Read | `Set_and_create ], t, (unit -> unit) option)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  job_pool:
    (([< `Read | `Set_and_create ],
       t,
       (Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3
         Tuple_pool.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  normal_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  low_priority_jobs:
    (([< `Read | `Set_and_create ], t, Async_kernel__.Types.Job_queue.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  very_low_priority_workers:
    (([< `Read | `Set_and_create ], t, Very_low_priority_worker.t Core.Deque.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  main_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  current_execution_context:
    (([< `Read | `Set_and_create ], t, Execution_context.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  uncaught_exn:
    (([< `Read | `Set_and_create ], t, (Core.Exn.t * Core.Sexp.t) option)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  cycle_count:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'a) ->
  cycle_start:
    (([< `Read | `Set_and_create ], t, Core.Time_ns.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  in_cycle:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> 'a) ->
  run_every_cycle_start:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  run_every_cycle_start_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  run_every_cycle_end:
    (([< `Read | `Set_and_create ], t, (unit -> unit) array)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  run_every_cycle_end_state:
    (([< `Read | `Set_and_create ],
       t,
       (Async_kernel__.Types.Cycle_hook_handle.t, unit -> unit) Core.Hashtbl.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  last_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  last_cycle_num_jobs:
    (([< `Read | `Set_and_create ], t, int) Fieldslib.Field.t_with_perm -> 'a) ->
  total_cycle_time:
    (([< `Read | `Set_and_create ],
       t,
       Core.Core_private.Time_ns_alternate_sexp.Span.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  time_source:
    (([< `Read | `Set_and_create ],
       t,
       Core.read_write Synchronous_time_source.T1.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  external_jobs:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel__.Types.External_job.t Thread_safe_queue.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  thread_safe_external_job_hook:
    (([< `Read | `Set_and_create ], t, unit -> unit)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  job_queued_hook:
    (([< `Read | `Set_and_create ], t, (Priority.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  event_added_hook:
    (([< `Read | `Set_and_create ], t, (Core.Time_ns.t -> unit) option)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  yield:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  yield_until_no_jobs_remain:
    (([< `Read | `Set_and_create ],
       t,
       (unit, Core.read_write) Async_kernel__.Types.Bvar.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  check_invariants:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> 'a) ->
  max_num_jobs_per_priority_per_cycle:
    (([< `Read | `Set_and_create ],
       t,
       Async_kernel_config.Max_num_jobs_per_priority_per_cycle.t)
       Fieldslib.Field.t_with_perm ->
      'a) ->
  record_backtraces:
    (([< `Read | `Set_and_create ], t, bool) Fieldslib.Field.t_with_perm -> 'a) ->
  'a list

Sourcemodule Direct : sig ... end

package async_kernel

Module Scheduler.FieldsSource

Module `Scheduler.Fields`Source