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

rename to write_bundle_state

Browse Source
This commit is contained in:
Dan Cline
2024-02-14 16:38:17 -05:00
parent 110a6db7ce
commit dbabf50ace
6 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
bin/reth/src/commands/debug_cmd/in_memory_merkle.rs
View File

@@ -199,7 +199,7 @@ impl Command {
.map_err(|_| BlockValidationError::SenderRecoveryError)?,
None,
)?;
provider_rw.write_state(block_state, OriginalValuesKnown::No)?;
provider_rw.write_bundle_state(block_state, OriginalValuesKnown::No)?;
let storage_lists = provider_rw.changed_storages_with_range(block.number..=block.number)?;
let storages = provider_rw.plain_state_storages(storage_lists)?;
provider_rw.insert_storage_for_hashing(storages)?;

2
crates/node-core/src/init.rs
View File

@@ -152,7 +152,7 @@ pub fn insert_genesis_state<DB: Database>(
0,
);
provider.write_state(bundle, OriginalValuesKnown::Yes)?;
provider.write_bundle_state(bundle, OriginalValuesKnown::Yes)?;
Ok(())
}

2
crates/stages/src/stages/execution.rs
View File

@@ -195,7 +195,7 @@ impl<EF: ExecutorFactory> ExecutionStage<EF> {
let time = Instant::now();
// write output
provider.write_state(state, OriginalValuesKnown::Yes)?;
provider.write_bundle_state(state, OriginalValuesKnown::Yes)?;
let db_write_duration = time.elapsed();
debug!(
target: "sync::stages::execution",

12
crates/storage/provider/src/bundle_state/bundle_state_with_receipts.rs
View File

@@ -510,7 +510,7 @@ mod tests {
let state = BundleStateWithReceipts::new(state.take_bundle(), Receipts::new(), 1);
provider
.write_state(state, OriginalValuesKnown::Yes)
.write_bundle_state(state, OriginalValuesKnown::Yes)
.expect("Could not write bundle state to DB");
// Check plain storage state
@@ -609,7 +609,7 @@ mod tests {
state.merge_transitions(BundleRetention::Reverts);
let state = BundleStateWithReceipts::new(state.take_bundle(), Receipts::new(), 2);
provider
.write_state(state, OriginalValuesKnown::Yes)
.write_bundle_state(state, OriginalValuesKnown::Yes)
.expect("Could not write bundle state to DB");
assert_eq!(
@@ -674,7 +674,7 @@ mod tests {
init_state.merge_transitions(BundleRetention::Reverts);
let state = BundleStateWithReceipts::new(init_state.take_bundle(), Receipts::new(), 0);
provider
.write_state(state, OriginalValuesKnown::Yes)
.write_bundle_state(state, OriginalValuesKnown::Yes)
.expect("Could not write init bundle state to DB");
let mut state = State::builder().with_bundle_update().build();
@@ -820,7 +820,7 @@ mod tests {
let state = BundleStateWithReceipts::new(bundle, Receipts::new(), 1);
provider
.write_state(state, OriginalValuesKnown::Yes)
.write_bundle_state(state, OriginalValuesKnown::Yes)
.expect("Could not write bundle state to DB");
let mut storage_changeset_cursor = provider
@@ -984,7 +984,7 @@ mod tests {
init_state.merge_transitions(BundleRetention::Reverts);
let state = BundleStateWithReceipts::new(init_state.take_bundle(), Receipts::new(), 0);
provider
.write_state(state, OriginalValuesKnown::Yes)
.write_bundle_state(state, OriginalValuesKnown::Yes)
.expect("Could not write init bundle state to DB");
let mut state = State::builder().with_bundle_update().build();
@@ -1030,7 +1030,7 @@ mod tests {
state.merge_transitions(BundleRetention::Reverts);
let state = BundleStateWithReceipts::new(state.take_bundle(), Receipts::new(), 1);
provider
.write_state(state, OriginalValuesKnown::Yes)
.write_bundle_state(state, OriginalValuesKnown::Yes)
.expect("Could not write bundle state to DB");
let mut storage_changeset_cursor = provider

4
crates/storage/provider/src/providers/database/provider.rs
View File

@@ -2562,7 +2562,7 @@ impl<TX: DbTxMut + DbTx> BlockWriter for DatabaseProvider<TX> {
// Write state and changesets to the database.
// Must be written after blocks because of the receipt lookup.
self.write_state(state, OriginalValuesKnown::No)?;
self.write_bundle_state(state, OriginalValuesKnown::No)?;
durations_recorder.record_relative(metrics::Action::InsertState);
// insert hashes and intermediate merkle nodes
@@ -2590,7 +2590,7 @@ impl<TX: DbTxMut + DbTx> StateWriter for DatabaseProvider<TX> {
///
/// `is_value_known` should be set to `Not` if the [BundleStateWithReceipts] has some of its
/// state detached, This would make some original values not known.
fn write_state(
fn write_bundle_state(
&self,
state: BundleStateWithReceipts,
is_value_known: OriginalValuesKnown,

2
crates/storage/provider/src/traits/state.rs
View File

@@ -238,7 +238,7 @@ pub trait StateWriter: Send + Sync {
///
/// `is_value_known` should be set to `Not` if the [BundleStateWithReceipts] has some of its
/// state detached, This would make some original values not known.
fn write_state(
fn write_bundle_state(
&self,
state: BundleStateWithReceipts,
is_value_known: OriginalValuesKnown,