github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-29 09:08:05 -05:00
Code Issues Packages Projects Releases Wiki Activity

refactor: convert closure into function (#3144)

Browse Source
This commit is contained in:
Matthias Seitz
2023-06-14 20:09:27 +02:00
committed by GitHub
parent 3bba41a209
commit 518784205f
1 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
crates/stages/src/stages/tx_lookup.rs
View File

@@ -79,16 +79,6 @@ impl<DB: Database> Stage<DB> for TransactionLookupStage {
let chunk: Vec<_> = chunk.collect();
transaction_count += chunk.len();
// closure that will calculate the TxHash
let calculate_hash =
|entry: Result<(TxNumber, TransactionSignedNoHash), reth_db::DatabaseError>,
rlp_buf: &mut Vec<u8>|
-> Result<(H256, u64), Box<StageError>> {
let (tx_id, tx) = entry.map_err(|e| Box::new(e.into()))?;
tx.transaction.encode_with_signature(&tx.signature, rlp_buf, false);
Ok((H256(keccak256(rlp_buf)), tx_id))
};
// Spawn the task onto the global rayon pool
// This task will send the results through the channel after it has calculated the hash.
rayon::spawn(move || {
@@ -179,6 +169,17 @@ impl<DB: Database> Stage<DB> for TransactionLookupStage {
}
}
/// Calculates the hash of the given transaction
#[inline]
fn calculate_hash(
entry: Result<(TxNumber, TransactionSignedNoHash), DatabaseError>,
rlp_buf: &mut Vec<u8>,
) -> Result<(H256, TxNumber), Box<StageError>> {
let (tx_id, tx) = entry.map_err(|e| Box::new(e.into()))?;
tx.transaction.encode_with_signature(&tx.signature, rlp_buf, false);
Ok((H256(keccak256(rlp_buf)), tx_id))
}
fn stage_checkpoint<DB: Database>(
provider: &DatabaseProviderRW<'_, &DB>,
) -> Result<EntitiesCheckpoint, DatabaseError> {