package async_kernel

  1. Overview
  2. Docs

Module Synchronous_time_source.T1

module Event : sig ... end
module Job_or_event : sig ... end
type -'rw t = {
  1. id : Id.t;
  2. mutable advance_errors : Core.Error.t list;
  3. mutable am_advancing : bool;
  4. events : Job_or_event.t Timing_wheel.t;
  5. mutable fired_events : Event.Option.t;
  6. mutable most_recently_fired : Event.Option.t;
  7. handle_fired : Job_or_event.t Alarm.t -> unit;
  8. is_wall_clock : bool;
  9. scheduler : Async_kernel__.Types.Scheduler.t;
}
val scheduler : 'a t -> Async_kernel__.Types.Scheduler.t
val is_wall_clock : 'a t -> bool
val handle_fired : 'a t -> Job_or_event.t Alarm.t -> unit
val most_recently_fired : 'a t -> Event.Option.t
val set_most_recently_fired : 'a t -> Event.Option.t -> unit
val fired_events : 'a t -> Event.Option.t
val set_fired_events : 'a t -> Event.Option.t -> unit
val events : 'a t -> Job_or_event.t Timing_wheel.t
val am_advancing : 'a t -> bool
val set_am_advancing : 'a t -> bool -> unit
val advance_errors : 'a t -> Core.Error.t list
val set_advance_errors : 'a t -> Core.Error.t list -> unit
val id : 'a t -> Id.t
module Fields : sig ... end
val sexp_of_t : 'a -> 'b t -> Ppx_sexp_conv_lib.Sexp.t
val timing_wheel_now : 'a t -> Core.Time_ns.t
val is_in_fired_events : 'a t -> Async_kernel__.Types.Event.t -> bool
val invariant_with_jobs : job: ((Async_kernel__.Types.Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.Pointer.t -> unit) -> 'rw t -> unit
val invariant : 'a t -> unit