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

feat(bin): reset Finish stage in drop cmd (#2931)

Browse Source
This commit is contained in:
Alexey Shekhirin
2023-05-31 17:02:16 +04:00
committed by GitHub
parent 8a5fc9a974
commit adffd0aac9
1 changed files with 19 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
bin/reth/src/stage/drop.rs
View File

@ -61,9 +61,9 @@ impl Command {
let tool = DbTool::new(&db)?;
match &self.stage {
StageEnum::Execution => {
tool.db.update(|tx| {
tool.db.update(|tx| {
match &self.stage {
StageEnum::Execution => {
tx.clear::<tables::PlainAccountState>()?;
tx.clear::<tables::PlainStorageState>()?;
tx.clear::<tables::AccountChangeSet>()?;
@ -75,11 +75,8 @@ impl Command {
Default::default(),
)?;
insert_genesis_state::<Env<WriteMap>>(tx, self.chain.genesis())?;
Ok::<_, eyre::Error>(())
})??;
}
StageEnum::Hashing => {
tool.db.update(|tx| {
}
StageEnum::Hashing => {
// Clear hashed accounts
tx.clear::<tables::HashedAccount>()?;
tx.put::<tables::SyncStage>(
@ -93,12 +90,8 @@ impl Command {
StageId::StorageHashing.to_string(),
Default::default(),
)?;
Ok::<_, eyre::Error>(())
})??;
}
StageEnum::Merkle => {
tool.db.update(|tx| {
}
StageEnum::Merkle => {
tx.clear::<tables::AccountsTrie>()?;
tx.clear::<tables::StoragesTrie>()?;
tx.put::<tables::SyncStage>(
@ -113,11 +106,8 @@ impl Command {
StageId::MerkleExecute.to_string(),
None,
)?;
Ok::<_, eyre::Error>(())
})??;
}
StageEnum::History => {
tool.db.update(|tx| {
}
StageEnum::History => {
tx.clear::<tables::AccountHistory>()?;
tx.clear::<tables::StorageHistory>()?;
tx.put::<tables::SyncStage>(
@ -128,13 +118,17 @@ impl Command {
StageId::IndexStorageHistory.to_string(),
Default::default(),
)?;
Ok::<_, eyre::Error>(())
})??;
}
_ => {
info!("Nothing to do for stage {:?}", self.stage);
return Ok(())
}
}
_ => {
info!("Nothing to do for stage {:?}", self.stage);
}
}
tx.put::<tables::SyncStage>(StageId::Finish.to_string(), Default::default())?;
Ok::<_, eyre::Error>(())
})??;
Ok(())
}