Transition_handler.ProcessorThis module contains the transition processor. The transition processor is * the thread in which transitions are attached the to the transition frontier. * * Two types of data are handled by the transition processor: validated external transitions * with precomputed state hashes (via the block producer and validator pipes) * and breadcrumb rose trees (via the catchup pipe).
module type CONTEXT = sig ... endval catchup_timeout_duration : Precomputed_values.t -> Block_time.Span.tval cached_transform_deferred_result :
transform_cached:
( 'a -> ( 'b, 'c ) Core_kernel.Result.t Async_kernel.Deferred.t ) ->
transform_result:
( ( ( 'b, 'd ) Cache_lib.Cached.t, 'c ) Core_kernel.Result.t ->
'e Async_kernel__Deferred.t ) ->
( 'a, 'f ) Cache_lib.Cached.t ->
'e Async_kernel__Deferred.tval add_and_finalize :
logger:Logger.t ->
frontier:Transition_frontier.t ->
catchup_scheduler:Catchup_scheduler.t ->
processed_transition_writer:
( [> `Transition of Mina_block.Validated.t ]
* [> `Source of [> `Internal ] as 'a ]
* [> `Valid_cb of 'b option ],
'c,
'd )
Pipe_lib.Strict_pipe.Writer.t ->
only_if_present:bool ->
time_controller:Block_time.Controller.t ->
source:'a ->
valid_cb:'b option ->
( Transition_frontier.Breadcrumb.t, 'e ) Cache_lib.Cached.t ->
precomputed_values:Precomputed_values.t ->
unit Core_kernel.Or_error.t Async_kernel__Deferred.tval process_transition :
context:(module CONTEXT) ->
trust_system:Trust_system.t ->
verifier:Verifier.t ->
frontier:Transition_frontier.t ->
catchup_scheduler:Catchup_scheduler.t ->
processed_transition_writer:
( [> `Transition of Mina_block.Validated.t ]
* [> `Source of [> `Gossip | `Internal ] ]
* [> `Valid_cb of Mina_net2.Validation_callback.t option ],
'a,
'b )
Pipe_lib.Strict_pipe.Writer.t ->
time_controller:Block_time.Controller.t ->
transition:
( ( [ `Time_received ] * unit Truth.true_t,
[ `Genesis_state ] * unit Truth.true_t,
[ `Proof ] * unit Truth.true_t,
[ `Delta_block_chain ]
* Mina_base.State_hash.t Mina_stdlib.Nonempty_list.t Truth.true_t,
[ `Frontier_dependencies ] * unit Truth.false_t,
[ `Staged_ledger_diff ] * unit Truth.false_t,
[ `Protocol_versions ] * unit Truth.true_t )
Mina_block.Validation.with_block
Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t ->
valid_cb:Mina_net2.Validation_callback.t option ->
unit Async_kernel.Deferred.tval run :
context:(module CONTEXT) ->
verifier:Verifier.t ->
trust_system:Trust_system.t ->
time_controller:Block_time.Controller.t ->
frontier:Transition_frontier.t ->
primary_transition_reader:
([ `Block of
( Mina_block.initial_valid_block Network_peer.Envelope.Incoming.t,
Mina_base.State_hash.t )
Cache_lib.Cached.t ]
* [ `Valid_cb of Mina_net2.Validation_callback.t option ])
Pipe_lib.Strict_pipe.Reader.t ->
producer_transition_reader:
Transition_frontier.Breadcrumb.t Pipe_lib.Strict_pipe.Reader.t ->
clean_up_catchup_scheduler:unit Async_kernel.Ivar.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_reader:
((( 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.Reader.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 ->
processed_transition_writer:
( [> `Transition of Mina_block.Validated.t ]
* [> `Source of [> `Catchup | `Gossip | `Internal ] ]
* [> `Valid_cb of Mina_net2.Validation_callback.t option ],
'a,
'b )
Pipe_lib.Strict_pipe.Writer.t ->
unit