Transition_handler.Catchup_schedulerCatchup_scheduler defines a process which schedules catchup jobs and monitors them for invalidation. This allows the transition frontier controller to handle out of order transitions without spinning up and tearing down catchup jobs constantly. The Catchup_scheduler must receive notifications whenever a new transition is added to the transition frontier so that it can determine if any pending catchup jobs can be invalidated. When catchup jobs are invalidated, the catchup scheduler extracts all of the invalidated catchup jobs and spins up a process to materialize breadcrumbs from those transitions, which will write the breadcrumbs back into the processor as if catchup had successfully completed.
type t = {logger : Logger.t; | |
time_controller : Block_time.Controller.t; | |
catchup_job_writer : ( Mina_base.State_hash.t
* (( Mina_block.initial_valid_block
Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t
* Mina_net2.Validation_callback.t option)
Rose_tree.t
list,
Pipe_lib.Strict_pipe.crash Pipe_lib.Strict_pipe.buffered,
unit )
Pipe_lib.Strict_pipe.Writer.t; | (* `collected_transitins` stores all seen transitions as its keys, and values are a list of direct children of those transitions. The invariant is that every collected transition would appear as a key in this table. Even if a transition doesn't has a child, its corresponding value in the hash table would just be an empty list. *) |
collected_transitions : ( Mina_block.initial_valid_block
Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t
list
Mina_base.State_hash.Table.t; | |
validation_callbacks : Mina_net2.Validation_callback.t
Mina_base.State_hash.Table.t; | (* `parent_root_timeouts` stores the timeouts for catchup job. The keys are the missing transitions, and the values are the timeouts. *) |
parent_root_timeouts : unit Block_time.Timeout.t Mina_base.State_hash.Table.t; | |
breadcrumb_builder_supervisor : (Mina_base.State_hash.t
* (( Mina_block.initial_valid_block
Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t
* Mina_net2.Validation_callback.t option)
Rose_tree.t
list)
Otp_lib.Capped_supervisor.t; |
}val create :
logger:Logger.t ->
precomputed_values:Precomputed_values.t ->
verifier:Verifier.t ->
trust_system:Trust_system.t ->
frontier:Transition_frontier.t ->
time_controller:Block_time.Controller.t ->
catchup_job_writer:
( Mina_base.State_hash.t
* (( Mina_block.initial_valid_block Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t
* Mina_net2.Validation_callback.t option)
Rose_tree.t
list,
Pipe_lib.Strict_pipe.crash Pipe_lib.Strict_pipe.buffered,
unit )
Pipe_lib.Strict_pipe.Writer.t ->
catchup_breadcrumbs_writer:
( (( Transition_frontier.Breadcrumb.t, Mina_base.State_hash.t )
Cache_lib.Cached.t
* Mina_net2.Validation_callback.t option)
Rose_tree.t
list
* [ `Catchup_scheduler | `Ledger_catchup of unit Async_kernel.Ivar.t ],
Pipe_lib.Strict_pipe.crash Pipe_lib.Strict_pipe.buffered,
unit )
Pipe_lib.Strict_pipe.Writer.t ->
clean_up_signal:unit Async_kernel.Ivar.t ->
tval mem : t -> Mina_block.t -> boolval mem_parent_hash :
t ->
Mina_base.State_hash.Table.key Core_kernel.Hashtbl.key ->
boolval has_timeout : t -> Mina_block.t -> boolval has_timeout_parent_hash :
t ->
Mina_base.State_hash.Table.key Core_kernel.Hashtbl.key ->
boolval is_empty : t -> boolval cancel_timeout :
t ->
Mina_base.State_hash.Table.key Core_kernel.Hashtbl.key ->
Block_time.Span.t optionval extract_subtree :
t ->
( Mina_block.initial_valid_block Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t ->
(( Mina_block.initial_valid_block Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t
* Mina_net2.Validation_callback.t option)
Rose_tree.tval extract_forest :
t ->
Mina_base.State_hash.Table.key Core_kernel.Hashtbl.key ->
Mina_base.State_hash.Table.key Core_kernel.Hashtbl.key
* (( Mina_block.initial_valid_block Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t
* Mina_net2.Validation_callback.t option)
Rose_tree.t
listval remove_tree :
t ->
Mina_base.State_hash.Table.key Core_kernel.Hashtbl.key ->
unitval watch :
t ->
timeout_duration:Block_time.Span.t ->
cached_transition:
( Mina_block.initial_valid_block Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t ->
valid_cb:Mina_net2.Validation_callback.t option ->
unitval notify :
t ->
hash:Mina_base.State_hash.Table.key Core_kernel.Hashtbl.key ->
unit Core_kernel.Or_error.t