kaspa-mining 0.15.0

Kaspa mining
Documentation 
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
58
59
60
61
62
63
64
65
66
67
68
69
70

use crate::mempool::{
    errors::RuleResult,
    model::{pool::Pool, tx::TxRemovalReason},
    Mempool,
};
use kaspa_consensus_core::tx::TransactionId;
use kaspa_core::debug;
use kaspa_utils::iter::IterExtensions;

impl Mempool {
    pub(crate) fn remove_transaction(
        &mut self,
        transaction_id: &TransactionId,
        remove_redeemers: bool,
        reason: TxRemovalReason,
        extra_info: &str,
    ) -> RuleResult<()> {
        if self.orphan_pool.has(transaction_id) {
            return self.orphan_pool.remove_orphan(transaction_id, true, reason, extra_info).map(|_| ());
        }

        if !self.transaction_pool.has(transaction_id) {
            return Ok(());
        }

        let mut removed_transactions = vec![*transaction_id];
        if remove_redeemers {
            // Add all descendent txs as pending removals
            removed_transactions.extend(self.transaction_pool.get_redeemer_ids_in_pool(transaction_id));
        }

        let mut removed_orphans: Vec<TransactionId> = vec![];
        for tx_id in removed_transactions.iter() {
            // Remove the tx from the transaction pool and the UTXO set (handled within the pool)
            let tx = self.transaction_pool.remove_transaction(tx_id)?;
            // Update/remove descendent orphan txs (depending on `remove_redeemers`)
            let txs = self.orphan_pool.update_orphans_after_transaction_removed(&tx, remove_redeemers)?;
            removed_orphans.extend(txs.into_iter().map(|x| x.id()));
        }
        removed_transactions.extend(removed_orphans);

        match reason {
            TxRemovalReason::Muted => {}
            TxRemovalReason::DoubleSpend => match removed_transactions.len() {
                0 => {}
                1 => debug!("Removed transaction ({}) {}{}", reason, removed_transactions[0], extra_info),
                n => debug!(
                    "Removed {} transactions ({}): {}{}",
                    n,
                    reason,
                    removed_transactions.iter().reusable_format(", "),
                    extra_info
                ),
            },
            _ => match removed_transactions.len() {
                0 => {}
                1 => debug!("Removed transaction ({}) {}{}", reason, removed_transactions[0], extra_info),
                n => debug!(
                    "Removed {} transactions ({}): {}{}",
                    n,
                    reason,
                    removed_transactions.iter().reusable_format(", "),
                    extra_info
                ),
            },
        }

        Ok(())
    }
}