Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Pruning skeleton #1229

Merged
merged 45 commits into from
Oct 4, 2024
Merged

Pruning skeleton #1229

merged 45 commits into from
Oct 4, 2024

Conversation

rakanalh
Copy link
Contributor

@rakanalh rakanalh commented Sep 25, 2024

Description

This PR implements pruning.

Here we introduce the Pruner structure which runs for as long as the node is running to prune blocks every X number of blocks.
At each L2 block production, we calculate the trigger block number which would invoke pruning X - distance blocks. This happens by spawning blocking tasks (since we use sync rocksdb) to delete specific state based on up_to_block.

The implementation of the actual pruning is implemented in later tickets referenced in:
#1190

Linked Issues

MERGE AFTER

@rakanalh rakanalh changed the base branch from nightly to rakanalh/structured-concurrency-pt2 September 25, 2024 11:39
@rakanalh rakanalh added the HOLD-MERGE PR is not draft but should not be merged yet label Sep 25, 2024
crates/pruning/src/lib.rs Outdated Show resolved Hide resolved
crates/pruning/src/lib.rs Outdated Show resolved Hide resolved
crates/prover/src/runner.rs Outdated Show resolved Hide resolved
crates/pruning/src/lib.rs Outdated Show resolved Hide resolved
crates/pruning/src/lib.rs Outdated Show resolved Hide resolved
crates/pruning/src/lib.rs Outdated Show resolved Hide resolved
Copy link
Member

@ercecan ercecan left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

So I thought the distance thing was supposed to work like the window size of a sliding window, and prune after each new l2 to keep the distance same, but after we talked with @rakanalh it made sense to at least wait another distance amount of blocks to prune so that it does not have to deal with extra (blocking) reads and writes every new block

Copy link
Contributor

@yaziciahmet yaziciahmet left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Great work overall, just have some nitpicks and questions.

crates/pruning/src/lib.rs Outdated Show resolved Hide resolved
crates/pruning/src/pruners/evm.rs Show resolved Hide resolved
crates/pruning/src/lib.rs Outdated Show resolved Hide resolved
bin/citrea/provers/risc0/guest-mock/Cargo.lock Outdated Show resolved Hide resolved
resources/configs/mock/sequencer_config.toml Outdated Show resolved Hide resolved
crates/pruning/src/lib.rs Show resolved Hide resolved
@eyusufatik eyusufatik removed the HOLD-MERGE PR is not draft but should not be merged yet label Oct 3, 2024
@eyusufatik eyusufatik merged commit 7c3440a into nightly Oct 4, 2024
14 checks passed
@eyusufatik eyusufatik deleted the rakanalh/pruning branch October 4, 2024 07:58
eyusufatik added a commit that referenced this pull request Oct 9, 2024
* Structured concurrency: Part 1 (#1214)

* Implement managed tasks for SubscriptionManager

* Fix clippy

* Add comment about trace task

* Use broadcast instead of mpsc for l2 blocks events

* Fix typo (#1246)

* Structured Concurrency: Part 2 (#1216)

* Implement managed tasks for SubscriptionManager

* Fix clippy

* Add comment about trace task

* Use broadcast instead of mpsc for l2 blocks events

* Fix spawns in DaService

* Add TaskManager

* Use task manager in sequencer

* Document TaskManager

* Handle shutdown event

* Use TaskTracker

* Add comment about using a cancellation token

* Use JoinHandles instead of TaskTracker

* Use TaskManager in fullnode and prover

* Improve bitcoin-da service

* Force spawned tasks to accept a cancellation token

* Use biased polling

* Satisfy clippy

* Address PR feedback

* Fix checks

* Pin foundry (#1253)

* Pin foundary

* Add comment

* Remove puclihs mock da block script

* Use default block time on error (#1244)

* Use default block time on error

* Constant target_block_time

* Remove import

* Dump logs and cleanup on assert failures (#1252)

* Fix estiamte gas l1 fee issue when metamask max amount is selected (#1261)

* Fix estiamte gas l1 fee issue when metamask max amount is selected

* Fix tests

* Remove unnecessary comment

* Fix hive (#1263)

* Fix configs

* Remove publish mock block from docker

* Update port for hive

* Rename config in hive

* Refactor eth estimate gas l1 fee issue (#1264)

* Refactor eth estimate gas l1 fee issue

* Nits

* Fix bug

* Refactor

* Do not ignore resources

* Fix

---------

Co-authored-by: Roman Proskuryakoff <[email protected]>

* Pruning skeleton (#1229)

* Implement managed tasks for SubscriptionManager

* Fix clippy

* Add comment about trace task

* Use broadcast instead of mpsc for l2 blocks events

* Fix spawns in DaService

* Add TaskManager

* Use task manager in sequencer

* Document TaskManager

* Handle shutdown event

* Use TaskTracker

* Add comment about using a cancellation token

* Use JoinHandles instead of TaskTracker

* Use TaskManager in fullnode and prover

* Improve bitcoin-da service

* Force spawned tasks to accept a cancellation token

* Use biased polling

* Satisfy clippy

* WIP

* Add pruning tables

* Pruning skeleton implementation

* Use pruner in nodes

* Use biased polling based on order

* WIP

* Fix how config is done

* Derive default

* Add logs

* Let the tasks finish without panicing

* Use pruning config in fullnode and prover

* Add simple run test

* Use option instead of PruningMode

* Unneccessary changes

* l2_receiver

* Cleanup prints

* Use last pruned block in calculation

* Implement pruning criteria

* Lint and add comment

* Set the last_pruned_block to up_to_block value

* Don't store config internally

* Remove from constructor

* Should not change

* Move config value

* Remove pruning from sequencer / prover

* Derive SequencerClient (#1269)

* Derive SequencerClient

* Renames

* Lint

* Improve estimate gas and create access list rpcs (#1265)

* Remove unnecessary transact_to conversion

* unwrap_or_default

* More concise block_env initialization

* Actually get highest gas limit from request and block env

* One liner set

* Allow unused

* Cleanup prepare_call_env

* Fix tests & lint

* Replace unwrap

* Set state to block in eth_call

* Consume request in prepare_call_env

* Lint

* Set state before reading config

* Remove unnecessary clone

* Replace allow unused with feature native gate

* Add sys txs to evm tests (#1255)

* modify config_push_contracts

* modify call_multiple_test

* modify tests in call_tests.rs

* moving common functions to utils.rs

* minor fixes

* updated lock files

* modify tests

---------

Co-authored-by: Esad Yusuf Atik <[email protected]>

* make prover config arg not optional (#1278)

* Pin to 27.1 (#1279)

* E2E tests using citrea-e2e (#1277)

* E2E tests using citrea-e2e

* Lint

* Set CITREA path

* With github.workspace

* Target citrea-e2e main

* Update citrea-e2e rev

* Use debug build

* Update citrea-e2e

* Prover generate input rpc (#1280)

* WIP Implement prover generate rpcg

* It compiles but stf is modified

* Context

* Fix Context: Send

* Merge fix

* Move function from common to prover

* Remove code duplicate and unnecessary log

* Add optional parameter to break commitments into groups

* Return input as string

---------

Co-authored-by: Roman Proskuryakoff <[email protected]>

* Move node configs to citrea-common (#1286)

* move node configs to a seperate crate

* fix udeps

* remove native feature

* move SequencerConfig

* move config to citrea-common

* fix use statements

* Update e2e test framework and fix tests (#1305)

* Update e2e test framework and fix tests

* Fix bug

* Update ci binary env key

* Test if new fix works

* Update bitcoincore-rpc version

* Dprint

* Try against fix prover config rev

* Target main HEAD rev

---------

Co-authored-by: jfldde <[email protected]>

* build and publish a new image for every commit to the nightly branch (#1309)

* Get fee recommendation from mempool space (#1302)

* Get fee recommendation from mempool space

* Fix bug

* Construct mempool space endpoint by network

---------

Co-authored-by: Esad Yusuf Atik <[email protected]>

* new path fix for nightly (#1310)

* Enable pending block tag in simulation endpoints (#1303)

* treat pending tag same as latest

* fix lint

* return new sealed block for pending

* handle pending tag externally

* revert enabling pending in some endpoints

* get blockenv instead of sealed block

* address review comments

* implement tests for eth_call, eth_estimateGas, eth_createAccessList pending blocks

* rename tests

---------

Co-authored-by: eyusufatik <[email protected]>

* Implement state and block overrides (#1270)

* Implement state and block overrides

* Update comment

* apply_block_overrides func

* apply_state_overrides func

* Use a single func for replacing account storage

* Clippy

* Address feedback

Use Reth's BlockOverrides with saturating_to to convert back to u64

* Test for block overrides

* Test for state overrides

* Comment tests

* Create a fresh working set

* Remove box

* remove alloy-serde

---------

Co-authored-by: eyusufatik <[email protected]>

* Use spawn_blocking for da queue (#1311)

* Fetch smart fee only if none (#1312)

* update run doc and changelog (#1315)

---------

Co-authored-by: Rakan Al-Huneiti <[email protected]>
Co-authored-by: Ahmet Yazıcı <[email protected]>
Co-authored-by: Erce Can Bektüre <[email protected]>
Co-authored-by: jfldde <[email protected]>
Co-authored-by: Erce Can Bektüre <[email protected]>
Co-authored-by: Roman Proskuryakoff <[email protected]>
Co-authored-by: Ege Okan Ünaldı <[email protected]>
Co-authored-by: Çetin <[email protected]>
eyusufatik added a commit that referenced this pull request Oct 9, 2024
* Structured concurrency: Part 1 (#1214)

* Implement managed tasks for SubscriptionManager

* Fix clippy

* Add comment about trace task

* Use broadcast instead of mpsc for l2 blocks events

* Fix typo (#1246)

* Structured Concurrency: Part 2 (#1216)

* Implement managed tasks for SubscriptionManager

* Fix clippy

* Add comment about trace task

* Use broadcast instead of mpsc for l2 blocks events

* Fix spawns in DaService

* Add TaskManager

* Use task manager in sequencer

* Document TaskManager

* Handle shutdown event

* Use TaskTracker

* Add comment about using a cancellation token

* Use JoinHandles instead of TaskTracker

* Use TaskManager in fullnode and prover

* Improve bitcoin-da service

* Force spawned tasks to accept a cancellation token

* Use biased polling

* Satisfy clippy

* Address PR feedback

* Fix checks

* Pin foundry (#1253)

* Pin foundary

* Add comment

* Remove puclihs mock da block script

* Use default block time on error (#1244)

* Use default block time on error

* Constant target_block_time

* Remove import

* Dump logs and cleanup on assert failures (#1252)

* Fix estiamte gas l1 fee issue when metamask max amount is selected (#1261)

* Fix estiamte gas l1 fee issue when metamask max amount is selected

* Fix tests

* Remove unnecessary comment

* Fix hive (#1263)

* Fix configs

* Remove publish mock block from docker

* Update port for hive

* Rename config in hive

* Refactor eth estimate gas l1 fee issue (#1264)

* Refactor eth estimate gas l1 fee issue

* Nits

* Fix bug

* Refactor

* Do not ignore resources

* Fix

---------

Co-authored-by: Roman Proskuryakoff <[email protected]>

* Pruning skeleton (#1229)

* Implement managed tasks for SubscriptionManager

* Fix clippy

* Add comment about trace task

* Use broadcast instead of mpsc for l2 blocks events

* Fix spawns in DaService

* Add TaskManager

* Use task manager in sequencer

* Document TaskManager

* Handle shutdown event

* Use TaskTracker

* Add comment about using a cancellation token

* Use JoinHandles instead of TaskTracker

* Use TaskManager in fullnode and prover

* Improve bitcoin-da service

* Force spawned tasks to accept a cancellation token

* Use biased polling

* Satisfy clippy

* WIP

* Add pruning tables

* Pruning skeleton implementation

* Use pruner in nodes

* Use biased polling based on order

* WIP

* Fix how config is done

* Derive default

* Add logs

* Let the tasks finish without panicing

* Use pruning config in fullnode and prover

* Add simple run test

* Use option instead of PruningMode

* Unneccessary changes

* l2_receiver

* Cleanup prints

* Use last pruned block in calculation

* Implement pruning criteria

* Lint and add comment

* Set the last_pruned_block to up_to_block value

* Don't store config internally

* Remove from constructor

* Should not change

* Move config value

* Remove pruning from sequencer / prover

* Derive SequencerClient (#1269)

* Derive SequencerClient

* Renames

* Lint

* Improve estimate gas and create access list rpcs (#1265)

* Remove unnecessary transact_to conversion

* unwrap_or_default

* More concise block_env initialization

* Actually get highest gas limit from request and block env

* One liner set

* Allow unused

* Cleanup prepare_call_env

* Fix tests & lint

* Replace unwrap

* Set state to block in eth_call

* Consume request in prepare_call_env

* Lint

* Set state before reading config

* Remove unnecessary clone

* Replace allow unused with feature native gate

* Add sys txs to evm tests (#1255)

* modify config_push_contracts

* modify call_multiple_test

* modify tests in call_tests.rs

* moving common functions to utils.rs

* minor fixes

* updated lock files

* modify tests

---------

Co-authored-by: Esad Yusuf Atik <[email protected]>

* make prover config arg not optional (#1278)

* Pin to 27.1 (#1279)

* E2E tests using citrea-e2e (#1277)

* E2E tests using citrea-e2e

* Lint

* Set CITREA path

* With github.workspace

* Target citrea-e2e main

* Update citrea-e2e rev

* Use debug build

* Update citrea-e2e

* Prover generate input rpc (#1280)

* WIP Implement prover generate rpcg

* It compiles but stf is modified

* Context

* Fix Context: Send

* Merge fix

* Move function from common to prover

* Remove code duplicate and unnecessary log

* Add optional parameter to break commitments into groups

* Return input as string

---------

Co-authored-by: Roman Proskuryakoff <[email protected]>

* Move node configs to citrea-common (#1286)

* move node configs to a seperate crate

* fix udeps

* remove native feature

* move SequencerConfig

* move config to citrea-common

* fix use statements

* Update e2e test framework and fix tests (#1305)

* Update e2e test framework and fix tests

* Fix bug

* Update ci binary env key

* Test if new fix works

* Update bitcoincore-rpc version

* Dprint

* Try against fix prover config rev

* Target main HEAD rev

---------

Co-authored-by: jfldde <[email protected]>

* build and publish a new image for every commit to the nightly branch (#1309)

* Get fee recommendation from mempool space (#1302)

* Get fee recommendation from mempool space

* Fix bug

* Construct mempool space endpoint by network

---------

Co-authored-by: Esad Yusuf Atik <[email protected]>

* new path fix for nightly (#1310)

* Enable pending block tag in simulation endpoints (#1303)

* treat pending tag same as latest

* fix lint

* return new sealed block for pending

* handle pending tag externally

* revert enabling pending in some endpoints

* get blockenv instead of sealed block

* address review comments

* implement tests for eth_call, eth_estimateGas, eth_createAccessList pending blocks

* rename tests

---------

Co-authored-by: eyusufatik <[email protected]>

* Implement state and block overrides (#1270)

* Implement state and block overrides

* Update comment

* apply_block_overrides func

* apply_state_overrides func

* Use a single func for replacing account storage

* Clippy

* Address feedback

Use Reth's BlockOverrides with saturating_to to convert back to u64

* Test for block overrides

* Test for state overrides

* Comment tests

* Create a fresh working set

* Remove box

* remove alloy-serde

---------

Co-authored-by: eyusufatik <[email protected]>

* Use spawn_blocking for da queue (#1311)

* Fetch smart fee only if none (#1312)

* update run doc and changelog (#1315)

---------

Co-authored-by: Rakan Al-Huneiti <[email protected]>
Co-authored-by: Ahmet Yazıcı <[email protected]>
Co-authored-by: Erce Can Bektüre <[email protected]>
Co-authored-by: jfldde <[email protected]>
Co-authored-by: Erce Can Bektüre <[email protected]>
Co-authored-by: Roman Proskuryakoff <[email protected]>
Co-authored-by: Ege Okan Ünaldı <[email protected]>
Co-authored-by: Çetin <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Pruning: Implement pruning crate & config
5 participants