Tezos Shell - Prevalidation of pending operations (a.k.a Mempool)
The prevalidator is in charge of the "mempool" (a.k.a. the set of known not-invalid-for-sure operations that are not yet included in the blockchain).
The prevalidator also maintains a sorted subset of the mempool that might correspond to a valid block on top of the current head. The "in-progress" context produced by the application of those operations is called the (pre)validation context.
Before including an operation into the mempool, the prevalidation worker tries to append the operation the prevalidation context. If the operation is (strongly) refused, it will not be added into the mempool and then it will be ignored by the node and never broadcast. If the operation is only "branch_refused" or "branch_delayed", the operation won't be appended in the prevalidation context, but still broadcast.
An (abstract) prevalidator context. Separate prevalidator contexts should be * used for separate chains (e.g., mainchain vs testchain).
type limits = {max_refused_operations : int;operation_timeout : Tezos_base.Time.System.Span.t;worker_limits : Tezos_base.Worker_types.limits;operations_batch_size : int;}val create :
limits ->
(module Prevalidator_filters.FILTER) ->
Distributed_db.chain_db ->
(t, Tezos_error_monad.TzCore.error list) result Lwt.tCreates/tear-down a new prevalidator context.
val notify_operations :
t ->
Tezos_base.P2p_peer.Id.t ->
Tezos_base.Mempool.t ->
unit Lwt.tNotify the prevalidator that the identified peer has sent a bunch of * operations relevant to the specified context.
val inject_operation :
t ->
Tezos_base.Operation.t ->
(unit, Tezos_error_monad.TzCore.error list) result Lwt.tNotify the prevalidator worker of a new injected operation.
val flush :
t ->
Tezos_crypto.Block_hash.t ->
Tezos_crypto.Block_hash.Set.t ->
Tezos_crypto.Operation_hash.Set.t ->
(unit, Tezos_error_monad.TzCore.error list) result Lwt.tNotify the prevalidator that a new head has been selected.
val timestamp : t -> Tezos_base.Time.System.tReturns the timestamp of the prevalidator worker, that is the timestamp of the last reset of the prevalidation context
val fitness : t -> Tezos_base.Fitness.t Lwt.tReturns the fitness of the current prevalidation context
val operations :
t ->
Tezos_error_monad.TzCore.error Tezos_base.Preapply_result.t
* Tezos_base.Operation.t Tezos_crypto.Operation_hash.Map.tReturns the list of valid operations known to this prevalidation worker
val pending :
t ->
Tezos_base.Operation.t Tezos_crypto.Operation_hash.Map.t Lwt.tReturns the list of pending operations known to this prevalidation worker
val running_workers :
unit ->
(Tezos_crypto.Chain_id.t * Tezos_crypto.Protocol_hash.t * t) listReturns the list of prevalidation contexts running and their associated chain
Two functions that are useful for managing the prevalidator's transition * from one protocol to the next.
val protocol_hash : t -> Tezos_crypto.Protocol_hash.tReturns the hash of the protocol the prevalidator was instantiated with
val parameters : t -> parametersReturns the parameters the prevalidator was created with.
Worker status and events
val status : t -> Tezos_base.Worker_types.worker_statusval pending_requests :
t ->
(Tezos_base.Time.System.t
* Tezos_shell_services.Prevalidator_worker_state.Request.view)
listval current_request :
t ->
(Tezos_base.Time.System.t
* Tezos_base.Time.System.t
* Tezos_shell_services.Prevalidator_worker_state.Request.view)
optionval last_events :
t ->
(Tezos_event_logging.Internal_event.level
* Tezos_shell_services.Prevalidator_worker_state.Event.t list)
listval information : t -> Tezos_base.Worker_types.worker_informationval pipeline_length : t -> intval rpc_directory : t option Tezos_rpc.RPC_directory.t