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

fix(stages): transaction block lookup (#2481)

Browse Source
This commit is contained in:
Roman Krasiuk
2023-04-30 15:32:45 +03:00
committed by GitHub
parent c28ad55a7a
commit 1651009c19
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
crates/stages/src/stages/bodies.rs
View File

@@ -83,7 +83,7 @@ impl<DB: Database, D: BodyDownloader> Stage<DB> for BodyStage<D> {
let (from_block, to_block) = range.into_inner();
// Cursors used to write bodies, ommers and transactions
let mut block_meta_cursor = tx.cursor_write::<tables::BlockBodyIndices>()?;
let mut block_indices_cursor = tx.cursor_write::<tables::BlockBodyIndices>()?;
let mut tx_cursor = tx.cursor_write::<tables::Transactions>()?;
let mut tx_block_cursor = tx.cursor_write::<tables::TransactionBlock>()?;
let mut ommers_cursor = tx.cursor_write::<tables::BlockOmmers>()?;
@@ -106,14 +106,18 @@ impl<DB: Database, D: BodyDownloader> Stage<DB> for BodyStage<D> {
// Write block
let block_number = response.block_number();
let first_tx_num = next_tx_num;
let mut tx_count = 0;
let block_indices = StoredBlockBodyIndices {
first_tx_num: next_tx_num,
tx_count: match &response {
BlockResponse::Full(block) => block.body.len() as u64,
BlockResponse::Empty(_) => 0,
},
};
match response {
BlockResponse::Full(block) => {
tx_count = block.body.len() as u64;
// write transaction block index
if !block.body.is_empty() {
tx_block_cursor.append(first_tx_num, block.number)?;
tx_block_cursor.append(block_indices.last_tx_num(), block.number)?;
}
// Write transactions
@@ -142,8 +146,7 @@ impl<DB: Database, D: BodyDownloader> Stage<DB> for BodyStage<D> {
};
// insert block meta
block_meta_cursor
.append(block_number, StoredBlockBodyIndices { first_tx_num, tx_count })?;
block_indices_cursor.append(block_number, block_indices)?;
highest_block = block_number;
}