package octez-shell-libs
Install
Dune Dependency
Authors
Maintainers
Sources
sha256=ddfb5076eeb0b32ac21c1eed44e8fc86a6743ef18ab23fff02d36e365bb73d61
sha512=d22a827df5146e0aa274df48bc2150b098177ff7e5eab52c6109e867eb0a1f0ec63e6bfbb0e3645a6c2112de3877c91a17df32ccbff301891ce4ba630c997a65
doc/octez-shell-libs.shell/Tezos_shell/Prevalidator_classification/index.html
Module Tezos_shell.Prevalidator_classificationSource
type error_classification = [ | `Branch_delayed of Tezos_base.TzPervasives.tztrace| `Branch_refused of Tezos_base.TzPervasives.tztrace| `Refused of Tezos_base.TzPervasives.tztrace| `Outdated of Tezos_base.TzPervasives.tztrace
]Classifications which correspond to errors
Classification of an operation in the mempool
val map :
'protocol_data bounded_map ->
('protocol_data Shell_operation.operation * Tezos_base.TzPervasives.tztrace)
Tezos_base.TzPervasives.Operation_hash.Map.tmap bounded_map gets the underling map of the bounded_map.
cardinal bounded_map gets the cardinal of the underling map of the bounded_map
module Sized_map :
Tezos_base.Sized.SizedMap
with type 'a map := 'a Tezos_base.TzPervasives.Operation_hash.Map.t
and type key = Tezos_base.TzPervasives.Operation_hash.tThis module implements a sized-map data-structure.
type 'protocol_data t = private {parameters : parameters;refused : 'protocol_data bounded_map;outdated : 'protocol_data bounded_map;branch_refused : 'protocol_data bounded_map;branch_delayed : 'protocol_data bounded_map;mutable validated : 'protocol_data Shell_operation.operation Sized_map.t;mutable unparsable : Tezos_base.TzPervasives.Operation_hash.Set.t;mutable in_mempool : ('protocol_data Shell_operation.operation * classification) Tezos_base.TzPervasives.Operation_hash.Map.t;
}Invariants ensured by this module, provided that the caller does not add an operation which is already present in t:
- The field
in_mempoolis the set of all operation hashes present in fields:refused; outdated; branch_refused; branch_delayed; validated.
- An operation cannot be at the same time in two of the fields:
refused; outdated; branch_refused; branch_delayed; validated.
Note: unparsable operations are handled in a different way because they cannot be handled as a operation since this datatype requires an operation to be parsable. Hence, unparsable operations are handled differently. In particular, unparsable operations are removed on flush.
Note: We could always enforce these invariants by checking in add whether the operation is already present. However, this would make the behavior of add less predictable, so we do not think this to be an improvement from the point of view of the caller.
create parameters returns an empty t whose bounded maps hold at most parameters.map_size_limit values. The on_discarded_operation is called when a new operation is added and an old one is discarded because the limit was reached.
Invalid_argument is raised if ring_size is 0 or less.
is_empty t returns true iff t doesn't contain any operation.
val is_in_mempool :
Tezos_base.TzPervasives.Operation_hash.t ->
'protocol_data t ->
('protocol_data Shell_operation.operation * classification) optionis_in_mempool oph classes indicates whether oph is present in field in_mempool of classes. It returns the corresponding operation and its classification if present, and None otherwise.
val is_known_unparsable :
Tezos_base.TzPervasives.Operation_hash.t ->
'protocol_data t ->
boolis_known_unparsable oph returns true if the oph is associated to an operation which is known to be unparsable. false otherwise.
val remove :
Tezos_base.TzPervasives.Operation_hash.t ->
'protocol_data t ->
('protocol_data Shell_operation.operation * classification) optionremove oph classes removes operation of hash oph from all fields of classes. The function is O(log n) with n the number of operations in the corresponding class.
If oph was found, its classification as well as the operation it was bound to are returned. If oph was not found, None is returned.
val add :
classification ->
'protocol_data Shell_operation.operation ->
'protocol_data t ->
unitadd ~notify classification op classes adds the operation op classified as classification to the classifier classes. The classes.parameters.on_discarded_operation callback is called for any operation discarded in this process. Currently, an operation is discarded in the following cases:
- the corresponding error class field is full. In that case, the new operation is added to the class, and the removed one is discarded.
- an operation is classified as
Refused.
Note that a Refused operation may thus be passed twice to on_discarded_operation: as soon as it is added, and if it is removed because the classes.refused bounded map is full.
As a summary:
Validatedoperations are never discarded
Branch_refusedandBranch_delayedare discarded 0 or 1 time (if the corresponding bounded_map is full)
Refusedis discarded 1 or 2 times (if the corresponding bounded_map is full)
add_unparsable oph classes adds oph as an unparsable operation. unparsable operations are removed automatically by the recycle_operations function. on_discard_operation is also called on those operations.
type 'block block_tools = {bhash : 'block -> Tezos_base.TzPervasives.Block_hash.t;(*The hash of a block
*)operations : 'block -> Tezos_base.Operation.t list list;(*The list of operations of a block ordered by their validation pass
*)all_operation_hashes : 'block -> Tezos_base.TzPervasives.Operation_hash.t list list;(*The list of hashes of operations of a block ordered by their validation pass. Could be implemented using
*)operationsbut this lets an alternative implementation to be provided.
}Functions to query data on a polymorphic block-like type 'block.
type 'block chain_tools = {clear_or_cancel : Tezos_base.TzPervasives.Operation_hash.t -> unit;(*Removes the operation from the distributed database.
*)inject_operation : Tezos_base.TzPervasives.Operation_hash.t -> Tezos_base.Operation.t -> unit Lwt.t;(*Puts the operation in the distributed database. Returns
*)falseif thehashis already in the distributed databasenew_blocks : from_block:'block -> to_block:'block -> ('block * 'block list) Lwt.t;(*
*)new_blocks ~from_block ~to_blockreturns a pair(ancestor, path), whereancestoris the common ancestor offrom_blockandto_blockand wherepathis the chain fromancestor(excluded) toto_block(included).read_predecessor_opt : 'block -> 'block option Lwt.t;(*
*)read_predecessor_opt blockreturns the direct predecessor ofblockorNoneif it cannot be found.
}A wrapper over chain-related modules, to make client code easier to emulate, and hence to test
val recycle_operations :
from_branch:'block ->
to_branch:'block ->
live_blocks:Tezos_base.TzPervasives.Block_hash.Set.t ->
classes:'protocol_data t ->
parse:
(Tezos_base.TzPervasives.Operation_hash.t ->
Tezos_base.Operation.t ->
'protocol_data Shell_operation.operation option) ->
pending:
'protocol_data Shell_operation.operation
Tezos_base.TzPervasives.Operation_hash.Map.t ->
block_store:'block block_tools ->
chain:'block chain_tools ->
handle_branch_refused:bool ->
'protocol_data Shell_operation.operation
Tezos_base.TzPervasives.Operation_hash.Map.t
Lwt.trecycle_operations returns the new pending operations when a reorganisation or a head update occurs. Returned operations come from:
1. operations in from_branch that are NOT in to_branch, 2. operations in the relevant classes of classification 3. operations the pending map
This function guarantees that the branch of all returned operations is in live_blocks (live_blocks acts as a filter).
Operation which where included in from_branch and which are NOT in to_branch need to be parsed again using the parse argument. If the parsing fails those operations are just dropped. This may happen if those operations comes from another protocol.