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

fix: persistence action initial block insertion (#9930)

Browse Source
This commit is contained in:
joshieDo
2024-07-31 14:40:13 +01:00
committed by GitHub
parent 611a0292f9
commit 999f5a728b
2 changed files with 15 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
crates/storage/db-common/src/init.rs
View File

@@ -124,6 +124,13 @@ pub fn init_genesis<DB: Database>(factory: ProviderFactory<DB>) -> Result<B256,
provider_rw.save_stage_checkpoint(stage, Default::default())?;
}
// Static file segments start empty, so we need to initialize the genesis block.
let segment = StaticFileSegment::Receipts;
static_file_provider.latest_writer(segment)?.increment_block(segment, 0)?;
let segment = StaticFileSegment::Transactions;
static_file_provider.latest_writer(segment)?.increment_block(segment, 0)?;
provider_rw.commit()?;
static_file_provider.commit()?;

22
crates/storage/provider/src/writer/mod.rs
View File

@@ -13,7 +13,7 @@ use reth_execution_types::ExecutionOutcome;
use reth_primitives::{
BlockNumber, Header, StaticFileSegment, TransactionSignedNoHash, B256, U256,
};
use reth_storage_api::ReceiptWriter;
use reth_storage_api::{HeaderProvider, ReceiptWriter};
use reth_storage_errors::writer::StorageWriterError;
use reth_trie::updates::TrieUpdates;
use revm::db::OriginalValuesKnown;
@@ -139,26 +139,20 @@ where
{
self.ensure_database_writer()?;
self.ensure_static_file_writer()?;
let mut td_cursor =
self.database_writer().tx_ref().cursor_read::<tables::HeaderTerminalDifficulties>()?;
let mut first_td = if initial_block_number == 0 {
U256::ZERO
} else {
td_cursor
.seek_exact(initial_block_number - 1)?
.map(|(_, td)| td.0)
.ok_or_else(|| ProviderError::TotalDifficultyNotFound(initial_block_number))?
};
let mut td = self
.database_writer()
.header_td_by_number(initial_block_number)?
.ok_or(ProviderError::TotalDifficultyNotFound(initial_block_number))?;
for pair in headers {
let (header, hash) = pair.borrow();
let header = header.borrow();
first_td += header.difficulty;
self.static_file_writer().append_header(header, first_td, hash)?;
td += header.difficulty;
self.static_file_writer().append_header(header, td, hash)?;
}
Ok(first_td)
Ok(td)
}
/// Appends transactions to static files, using the