f39eca214a
Let's get serious. The full index of operations is not sustainable in the production code. We now only keep the index of operations not yet in the chain (i.e. the mempool/prevalidation). Operations from the chain are now only accesible through a block. For instance, see the RPC: /blocks/<hash>/proto/operations
49 lines
2.2 KiB
OCaml
49 lines
2.2 KiB
OCaml
(**************************************************************************)
|
|
(* *)
|
|
(* Copyright (c) 2014 - 2016. *)
|
|
(* Dynamic Ledger Solutions, Inc. <contact@tezos.com> *)
|
|
(* *)
|
|
(* All rights reserved. No warranty, explicit or implicit, provided. *)
|
|
(* *)
|
|
(**************************************************************************)
|
|
|
|
(** The prevalidation worker 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 worker 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 to include 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
|
|
broadcasted. If the operation is only "branch_refused" or
|
|
"branch_delayed", the operation won't be appended in the
|
|
prevalidation context, but still broadcasted.
|
|
|
|
*)
|
|
|
|
type t
|
|
|
|
(** Creation and destruction of a "prevalidation" worker. *)
|
|
val create: Distributed_db.net_db -> t Lwt.t
|
|
val shutdown: t -> unit Lwt.t
|
|
|
|
val notify_operations: t -> P2p.Peer_id.t -> Operation_hash.t list -> unit
|
|
|
|
(** Conditionnaly inject a new operation in the node: the operation will
|
|
be ignored when it is (strongly) refused This is the
|
|
entry-point used by the P2P layer. The operation content has been
|
|
previously stored on disk. *)
|
|
val inject_operation: t -> ?force:bool -> Operation.t -> unit tzresult Lwt.t
|
|
|
|
val flush: t -> State.Block.t -> unit
|
|
val timestamp: t -> Time.t
|
|
val operations: t -> error Prevalidation.preapply_result * Operation_hash.Set.t
|
|
val context: t -> Updater.validation_result tzresult Lwt.t
|
|
|
|
val pending: ?block:State.Block.t -> t -> Operation_hash.Set.t Lwt.t
|