jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: misc static tx range (#7326)

Browse Source
This commit is contained in:
Matthias Seitz
2024-03-25 16:00:58 +01:00
committed by GitHub
parent 28935daa99
commit c6abf0ca86
1 changed files with 14 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
crates/storage/provider/src/providers/static_file/manager.rs
View File

@ -881,22 +881,12 @@ impl TransactionsProviderExt for StaticFileProvider {
// chunks are too big, there will be idle threads waiting for work. Choosing an
// arbitrary smaller value to make sure it doesn't happen.
let chunk_size = 100;
let mut channels = Vec::new();
// iterator over the chunks
let chunks = (tx_range.start..tx_range.end)
.step_by(chunk_size)
.map(|start| start..std::cmp::min(start + chunk_size as u64, tx_range.end))
.collect::<Vec<Range<u64>>>();
let mut channels = Vec::with_capacity(chunk_size);
#[inline]
fn calculate_hash(
entry: (TxNumber, TransactionSignedNoHash),
rlp_buf: &mut Vec<u8>,
) -> Result<(B256, TxNumber), Box<ProviderError>> {
let (tx_id, tx) = entry;
tx.transaction.encode_with_signature(&tx.signature, rlp_buf, false);
Ok((keccak256(rlp_buf), tx_id))
}
.map(|start| start..std::cmp::min(start + chunk_size as u64, tx_range.end));
for chunk_range in chunks {
let (channel_tx, channel_rx) = mpsc::channel();
@ -1153,3 +1143,14 @@ impl StatsReader for StaticFileProvider {
}
}
}
/// Calculates the tx hash for the given transaction and its id.
#[inline]
fn calculate_hash(
entry: (TxNumber, TransactionSignedNoHash),
rlp_buf: &mut Vec<u8>,
) -> Result<(B256, TxNumber), Box<ProviderError>> {
let (tx_id, tx) = entry;
tx.transaction.encode_with_signature(&tx.signature, rlp_buf, false);
Ok((keccak256(rlp_buf), tx_id))
}