module Fields: sig .. end
val names : string list
val work_for_threads : (Raw_scheduler.t, Raw_scheduler.Work.t Core.Std.Squeue.t) Fieldslib.Field.t
val max_num_live_threads : (Raw_scheduler.t, int) Fieldslib.Field.t
val num_reserved_threads : (Raw_scheduler.t, int) Fieldslib.Field.t
val num_live_threads : (Raw_scheduler.t, int) Fieldslib.Field.t
val num_blocked_threads : (Raw_scheduler.t, int) Fieldslib.Field.t
val finalizer_jobs : (Raw_scheduler.t,
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque)
Fieldslib.Field.t
val signal_manager : (Raw_scheduler.t, Raw_signal_manager.t) Fieldslib.Field.t
val select_interruptor : (Raw_scheduler.t, Interruptor.t) Fieldslib.Field.t
val id_of_thread_running_the_select_loop : (Raw_scheduler.t, int) Fieldslib.Field.t
val fd_by_descr : (Raw_scheduler.t, Fd_by_descr.t) Fieldslib.Field.t
val file_descr_watcher : (Raw_scheduler.t,
(Raw_scheduler.Fd.t, Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t)
Fieldslib.Field.t
val go_has_been_called : (Raw_scheduler.t, bool) Fieldslib.Field.t
val mutex : (Raw_scheduler.t, Core.Std.Nano_mutex.t) Fieldslib.Field.t
val make_creator : mutex:((Raw_scheduler.t, Core.Std.Nano_mutex.t) Fieldslib.Field.t ->
'a -> ('b -> Core.Std.Nano_mutex.t) * 'c) ->
go_has_been_called:((Raw_scheduler.t, bool) Fieldslib.Field.t ->
'c -> ('b -> bool) * 'd) ->
file_descr_watcher:((Raw_scheduler.t,
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t)
Fieldslib.Field.t ->
'd ->
('b ->
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t) *
'e) ->
fd_by_descr:((Raw_scheduler.t, Fd_by_descr.t) Fieldslib.Field.t ->
'e -> ('b -> Fd_by_descr.t) * 'f) ->
id_of_thread_running_the_select_loop:((Raw_scheduler.t, int)
Fieldslib.Field.t ->
'f -> ('b -> int) * 'g) ->
select_interruptor:((Raw_scheduler.t, Interruptor.t) Fieldslib.Field.t ->
'g -> ('b -> Interruptor.t) * 'h) ->
signal_manager:((Raw_scheduler.t, Raw_signal_manager.t) Fieldslib.Field.t ->
'h -> ('b -> Raw_signal_manager.t) * 'i) ->
finalizer_jobs:((Raw_scheduler.t,
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque)
Fieldslib.Field.t ->
'i ->
('b ->
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque) *
'j) ->
num_blocked_threads:((Raw_scheduler.t, int) Fieldslib.Field.t ->
'j -> ('b -> int) * 'k) ->
num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t ->
'k -> ('b -> int) * 'l) ->
num_reserved_threads:((Raw_scheduler.t, int) Fieldslib.Field.t ->
'l -> ('b -> int) * 'm) ->
max_num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t ->
'm -> ('b -> int) * 'n) ->
work_for_threads:((Raw_scheduler.t, Raw_scheduler.Work.t Core.Std.Squeue.t)
Fieldslib.Field.t ->
'n -> ('b -> Raw_scheduler.Work.t Core.Std.Squeue.t) * 'o) ->
'a -> ('b -> Raw_scheduler.t) * 'o
val create : mutex:Core.Std.Nano_mutex.t ->
go_has_been_called:bool ->
file_descr_watcher:(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t ->
fd_by_descr:Fd_by_descr.t ->
id_of_thread_running_the_select_loop:int ->
select_interruptor:Interruptor.t ->
signal_manager:Raw_signal_manager.t ->
finalizer_jobs:Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque ->
num_blocked_threads:int ->
num_live_threads:int ->
num_reserved_threads:int ->
max_num_live_threads:int ->
work_for_threads:Raw_scheduler.Work.t Core.Std.Squeue.t -> Raw_scheduler.t
val iter : mutex:((Raw_scheduler.t, Core.Std.Nano_mutex.t) Fieldslib.Field.t -> 'a) ->
go_has_been_called:((Raw_scheduler.t, bool) Fieldslib.Field.t -> 'b) ->
file_descr_watcher:((Raw_scheduler.t,
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t)
Fieldslib.Field.t -> 'c) ->
fd_by_descr:((Raw_scheduler.t, Fd_by_descr.t) Fieldslib.Field.t -> 'd) ->
id_of_thread_running_the_select_loop:((Raw_scheduler.t, int)
Fieldslib.Field.t -> 'e) ->
select_interruptor:((Raw_scheduler.t, Interruptor.t) Fieldslib.Field.t -> 'f) ->
signal_manager:((Raw_scheduler.t, Raw_signal_manager.t) Fieldslib.Field.t ->
'g) ->
finalizer_jobs:((Raw_scheduler.t,
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque)
Fieldslib.Field.t -> 'h) ->
num_blocked_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> 'i) ->
num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> 'j) ->
num_reserved_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> 'k) ->
max_num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> 'l) ->
work_for_threads:((Raw_scheduler.t, Raw_scheduler.Work.t Core.Std.Squeue.t)
Fieldslib.Field.t -> 'm) ->
'm
val fold : init:'a ->
mutex:('a -> (Raw_scheduler.t, Core.Std.Nano_mutex.t) Fieldslib.Field.t -> 'b) ->
go_has_been_called:('b -> (Raw_scheduler.t, bool) Fieldslib.Field.t -> 'c) ->
file_descr_watcher:('c ->
(Raw_scheduler.t,
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t)
Fieldslib.Field.t -> 'd) ->
fd_by_descr:('d -> (Raw_scheduler.t, Fd_by_descr.t) Fieldslib.Field.t -> 'e) ->
id_of_thread_running_the_select_loop:('e ->
(Raw_scheduler.t, int)
Fieldslib.Field.t -> 'f) ->
select_interruptor:('f ->
(Raw_scheduler.t, Interruptor.t) Fieldslib.Field.t -> 'g) ->
signal_manager:('g ->
(Raw_scheduler.t, Raw_signal_manager.t) Fieldslib.Field.t ->
'h) ->
finalizer_jobs:('h ->
(Raw_scheduler.t,
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque)
Fieldslib.Field.t -> 'i) ->
num_blocked_threads:('i -> (Raw_scheduler.t, int) Fieldslib.Field.t -> 'j) ->
num_live_threads:('j -> (Raw_scheduler.t, int) Fieldslib.Field.t -> 'k) ->
num_reserved_threads:('k -> (Raw_scheduler.t, int) Fieldslib.Field.t -> 'l) ->
max_num_live_threads:('l -> (Raw_scheduler.t, int) Fieldslib.Field.t -> 'm) ->
work_for_threads:('m ->
(Raw_scheduler.t, Raw_scheduler.Work.t Core.Std.Squeue.t)
Fieldslib.Field.t -> 'n) ->
'n
val map : mutex:((Raw_scheduler.t, Core.Std.Nano_mutex.t) Fieldslib.Field.t ->
Core.Std.Nano_mutex.t) ->
go_has_been_called:((Raw_scheduler.t, bool) Fieldslib.Field.t -> bool) ->
file_descr_watcher:((Raw_scheduler.t,
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t)
Fieldslib.Field.t ->
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t) ->
fd_by_descr:((Raw_scheduler.t, Fd_by_descr.t) Fieldslib.Field.t ->
Fd_by_descr.t) ->
id_of_thread_running_the_select_loop:((Raw_scheduler.t, int)
Fieldslib.Field.t -> int) ->
select_interruptor:((Raw_scheduler.t, Interruptor.t) Fieldslib.Field.t ->
Interruptor.t) ->
signal_manager:((Raw_scheduler.t, Raw_signal_manager.t) Fieldslib.Field.t ->
Raw_signal_manager.t) ->
finalizer_jobs:((Raw_scheduler.t,
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque)
Fieldslib.Field.t ->
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque) ->
num_blocked_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> int) ->
num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> int) ->
num_reserved_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> int) ->
max_num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> int) ->
work_for_threads:((Raw_scheduler.t, Raw_scheduler.Work.t Core.Std.Squeue.t)
Fieldslib.Field.t -> Raw_scheduler.Work.t Core.Std.Squeue.t) ->
Raw_scheduler.t
val map_poly : (Raw_scheduler.t, 'a) Fieldslib.Field.user -> 'a list
val for_all : mutex:((Raw_scheduler.t, Core.Std.Nano_mutex.t) Fieldslib.Field.t -> bool) ->
go_has_been_called:((Raw_scheduler.t, bool) Fieldslib.Field.t -> bool) ->
file_descr_watcher:((Raw_scheduler.t,
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t)
Fieldslib.Field.t -> bool) ->
fd_by_descr:((Raw_scheduler.t, Fd_by_descr.t) Fieldslib.Field.t -> bool) ->
id_of_thread_running_the_select_loop:((Raw_scheduler.t, int)
Fieldslib.Field.t -> bool) ->
select_interruptor:((Raw_scheduler.t, Interruptor.t) Fieldslib.Field.t ->
bool) ->
signal_manager:((Raw_scheduler.t, Raw_signal_manager.t) Fieldslib.Field.t ->
bool) ->
finalizer_jobs:((Raw_scheduler.t,
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque)
Fieldslib.Field.t -> bool) ->
num_blocked_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> bool) ->
num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> bool) ->
num_reserved_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> bool) ->
max_num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> bool) ->
work_for_threads:((Raw_scheduler.t, Raw_scheduler.Work.t Core.Std.Squeue.t)
Fieldslib.Field.t -> bool) ->
bool
val exists : mutex:((Raw_scheduler.t, Core.Std.Nano_mutex.t) Fieldslib.Field.t -> bool) ->
go_has_been_called:((Raw_scheduler.t, bool) Fieldslib.Field.t -> bool) ->
file_descr_watcher:((Raw_scheduler.t,
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t)
Fieldslib.Field.t -> bool) ->
fd_by_descr:((Raw_scheduler.t, Fd_by_descr.t) Fieldslib.Field.t -> bool) ->
id_of_thread_running_the_select_loop:((Raw_scheduler.t, int)
Fieldslib.Field.t -> bool) ->
select_interruptor:((Raw_scheduler.t, Interruptor.t) Fieldslib.Field.t ->
bool) ->
signal_manager:((Raw_scheduler.t, Raw_signal_manager.t) Fieldslib.Field.t ->
bool) ->
finalizer_jobs:((Raw_scheduler.t,
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque)
Fieldslib.Field.t -> bool) ->
num_blocked_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> bool) ->
num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> bool) ->
num_reserved_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> bool) ->
max_num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> bool) ->
work_for_threads:((Raw_scheduler.t, Raw_scheduler.Work.t Core.Std.Squeue.t)
Fieldslib.Field.t -> bool) ->
bool
val to_list : mutex:((Raw_scheduler.t, Core.Std.Nano_mutex.t) Fieldslib.Field.t -> 'a) ->
go_has_been_called:((Raw_scheduler.t, bool) Fieldslib.Field.t -> 'a) ->
file_descr_watcher:((Raw_scheduler.t,
(Raw_scheduler.Fd.t,
Raw_scheduler.Fd.ready_to_result Import.Ivar.t)
File_descr_watcher.t)
Fieldslib.Field.t -> 'a) ->
fd_by_descr:((Raw_scheduler.t, Fd_by_descr.t) Fieldslib.Field.t -> 'a) ->
id_of_thread_running_the_select_loop:((Raw_scheduler.t, int)
Fieldslib.Field.t -> 'a) ->
select_interruptor:((Raw_scheduler.t, Interruptor.t) Fieldslib.Field.t -> 'a) ->
signal_manager:((Raw_scheduler.t, Raw_signal_manager.t) Fieldslib.Field.t ->
'a) ->
finalizer_jobs:((Raw_scheduler.t,
Raw_scheduler.finalizer_job Core.Std.Thread_safe_queue.t
Core.Std.sexp_opaque)
Fieldslib.Field.t -> 'a) ->
num_blocked_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> 'a) ->
num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> 'a) ->
num_reserved_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> 'a) ->
max_num_live_threads:((Raw_scheduler.t, int) Fieldslib.Field.t -> 'a) ->
work_for_threads:((Raw_scheduler.t, Raw_scheduler.Work.t Core.Std.Squeue.t)
Fieldslib.Field.t -> 'a) ->
'a list
module Direct: sig .. end