mirrors/mempool
1
0
Fork 0
mirror of https://github.com/mempool/mempool.git synced 2024-11-19 18:03:00 +01:00
Code Issues Projects Releases Wiki Activity

Move conversion logic to struct file

Browse Source
This commit is contained in:
junderw 2023-06-23 23:06:13 -07:00 committed by Mononaut
parent 920232be4c
commit d2a47b92c8
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
2 changed files with 27 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
backend/rust-gbt/src/audit_transaction.rs
View File

@ -1,3 +1,4 @@
use crate::thread_transaction::ThreadTransaction;
use std::{
cmp::Ordering,
collections::HashSet,
@ -55,3 +56,28 @@ impl Ord for AuditTransaction {
self.partial_cmp(other).unwrap()
}
}
impl AuditTransaction {
pub fn from_thread_transaction(tx: &ThreadTransaction) -> Self {
AuditTransaction {
uid: tx.uid,
fee: tx.fee,
weight: tx.weight,
sigops: tx.sigops,
fee_per_vsize: tx.fee_per_vsize,
effective_fee_per_vsize: tx.effective_fee_per_vsize,
dependency_rate: f64::INFINITY,
inputs: tx.inputs.clone(),
relatives_set_flag: false,
ancestors: HashSet::new(),
children: HashSet::new(),
ancestor_fee: tx.fee,
ancestor_weight: tx.weight,
ancestor_sigops: tx.sigops,
score: 0.0,
used: false,
modified: false,
dirty: false,
}
}
}

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

@ -1,7 +1,6 @@
use priority_queue::PriorityQueue;
use std::cmp::Ordering;
use std::collections::{HashMap, HashSet, VecDeque};
use std::f64::INFINITY;
use crate::audit_transaction::AuditTransaction;
use crate::thread_transaction::ThreadTransaction;
@ -60,26 +59,7 @@ fn make_block_templates(mempool: &mut HashMap<u32, ThreadTransaction>) -> Option
// Initialize working structs
for (uid, tx) in mempool {
let audit_tx = AuditTransaction {
uid: tx.uid,
fee: tx.fee,
weight: tx.weight,
sigops: tx.sigops,
fee_per_vsize: tx.fee_per_vsize,
effective_fee_per_vsize: tx.effective_fee_per_vsize,
dependency_rate: INFINITY,
inputs: tx.inputs.clone(),
relatives_set_flag: false,
ancestors: HashSet::new(),
children: HashSet::new(),
ancestor_fee: tx.fee,
ancestor_weight: tx.weight,
ancestor_sigops: tx.sigops,
score: 0.0,
used: false,
modified: false,
dirty: false,
};
let audit_tx = AuditTransaction::from_thread_transaction(tx);
audit_pool.insert(audit_tx.uid, audit_tx);
mempool_array.push_back(*uid);
}