neptune-mempool 0.14.0

Neptune transaction mempool: the Mempool store, its transaction-id and upgrade-priority abstractions, and the proof-quality policy used for gossip and replacement
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

//! The Neptune transaction mempool.
//!
//! This crate holds the [`Mempool`](mempool::Mempool) store together with the
//! small set of abstractions it is built on:
//!
//! - [`transaction_kernel_id`] — the `TransactionKernelId`/`Txid` identifiers
//!   used to key transactions in the mempool.
//! - [`upgrade_incentive`] and [`upgrade_priority`] — the priority
//!   model that decides which transactions are worth proof-upgrading.
//! - [`transaction_proof_quality`] — the node-level proof-quality policy used
//!   for mempool replacement and peer gossip.
//! - [`tx_upgrade_filter`] — the TXID filter that partitions upgrade work.

// enable the unstable "coverage" attribute, so that `#[cfg_attr(coverage_nightly,
// coverage(off))]` compiles under `cargo +nightly llvm-cov` and is a no-op
// otherwise.
#![cfg_attr(coverage_nightly, feature(coverage_attribute))]

pub mod mempool;
pub mod mempool_event;
pub mod mempool_update_job;
pub mod mempool_update_job_result;
pub mod merge_input_cache;
pub mod primitive_witness_update;
pub mod transaction_kernel_id;
pub mod transaction_proof_quality;
pub mod tx_upgrade_filter;
pub mod upgrade_incentive;
pub mod upgrade_priority;

/// Test-only helpers. Mirrors the per-crate `shared_tokio_runtime` macro,
/// delegating to the shared runtime in `neptune-consensus` so async tests can
/// run under `#[apply(...)]`.
#[cfg(test)]
mod test_utils {
    macro_rules! shared_tokio_runtime {
        (
            $(#[$fn_meta:meta])*
            $vis:vis async fn $fn_name:ident() $(-> $ret:ty)? {
                $($tt:tt)*
            }
        ) => {
            $(#[$fn_meta])*
            #[test]
            $vis fn $fn_name() $(-> $ret)? {
                let runtime = neptune_consensus::proof_abstractions::test_runtime::tokio_runtime();
                runtime.block_on(async {
                    $vis async fn __inner() $(-> $ret)? {
                        $($tt)*
                    }
                    __inner().await
                })
            }
        };
    }
    pub(crate) use shared_tokio_runtime;
}