machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

only return rates changed since last update

Browse Source
This commit is contained in:
Mononaut 2023-07-03 12:01:49 -04:00
parent 897c667f17
commit cfa2363743
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
backend/rust-gbt/src/gbt.rs
View File

@ -66,7 +66,7 @@ pub fn gbt(mempool: &mut ThreadTransactionsMap) -> GbtResult {
let mut block_weights: Vec<u32> = Vec::new(); let mut block_weights: Vec<u32> = Vec::new();
info!("Initializing working structs"); info!("Initializing working structs");
for (uid, tx) in mempool { for (uid, tx) in &mut *mempool {
let audit_tx = AuditTransaction::from_thread_transaction(tx); let audit_tx = AuditTransaction::from_thread_transaction(tx);
// Safety: audit_pool and mempool_stack must always contain the same transactions // Safety: audit_pool and mempool_stack must always contain the same transactions
audit_pool.insert(audit_tx.uid, audit_tx); audit_pool.insert(audit_tx.uid, audit_tx);
@ -241,6 +241,9 @@ pub fn gbt(mempool: &mut ThreadTransactionsMap) -> GbtResult {
trace!("txid: {}, is_dirty: {}", txid, tx.dirty); trace!("txid: {}, is_dirty: {}", txid, tx.dirty);
if tx.dirty { if tx.dirty {
rates.push(vec![f64::from(txid), tx.effective_fee_per_vsize]); rates.push(vec![f64::from(txid), tx.effective_fee_per_vsize]);
if let Some(mempool_tx) = mempool.get_mut(&txid) {
mempool_tx.effective_fee_per_vsize = tx.effective_fee_per_vsize;
}
} }
} }
trace!("\n\n\n\n\n===================="); trace!("\n\n\n\n\n====================");