mirror of
https://gitlab.com/pulsechaincom/erigon-pulse.git
synced 2024-12-22 03:30:37 +00:00
add an explainer for staged sync
This commit is contained in:
parent
590b59dc30
commit
afdf89ee07
@ -48,6 +48,8 @@ Turbo-Geth uses a rearchitected full sync algorithm from
|
||||
[Go-Ethereum](https://github.com/ethereum/go-ethereum) that is split into
|
||||
"stages".
|
||||
|
||||
See more detailed explanation in the [Staged Sync Readme](./docs/stagedsync/)
|
||||
|
||||
It uses the same network primitives and is compatible with regular go-ethereum
|
||||
nodes that are using full sync, you do not need any special sync capabilities
|
||||
for turbo-geth to sync.
|
||||
|
148
docs/stagedsync/README.md
Normal file
148
docs/stagedsync/README.md
Normal file
@ -0,0 +1,148 @@
|
||||
# Staged Sync
|
||||
|
||||
Staged Sync is a version of [Go-Ethereum](https://github.com/ethereum/go-ethereum)'s Full Sync that was rearchitected for better performance.
|
||||
|
||||
It is I/O intensive and even though we have a goal on being able to sync the node on an HDD, we still recommend using fast SSDs.
|
||||
|
||||
Staged Sync, as its name suggests, consists of 10 stages that are executed in order, one after another.
|
||||
|
||||
## How The Sync Works
|
||||
|
||||
For each peer Turbo-Geth learns what the HEAD blocks is and it executes each stage in order for the missing blocks between the local HEAD block and the peer's head blocks.
|
||||
|
||||
The first stage (downloading headers) sets the local HEAD block.
|
||||
|
||||
Each stage is executed in order and a stage N does not stop until the local head is reached for it.
|
||||
|
||||
That mean, that in the ideal scenario (no network interruptions, the app isn't restarted, etc), for the full initial sync, each stage will be executed exactly once.
|
||||
|
||||
After the last stage is finished, the process starts from the beginning, by looking for the new headers to download.
|
||||
|
||||
If the app is restarted in between stages, it restarts from the first stage.
|
||||
|
||||
If the app is restared in the middle of the stage execution, it restarts from that stage, giving it the opportunity to complete.
|
||||
|
||||
## Reorgs / Unwinds
|
||||
|
||||
Sometimes the chain makes a reorg and we need to "undo" some parts of our sync.
|
||||
|
||||
This happens backward from the last stage to the first one with one caveat that tx pool is updated after we already unwound the execution so we know the new nonces.
|
||||
|
||||
That is the example of stages order to be unwound (unwind happens from right to left).
|
||||
|
||||
```
|
||||
state.unwindOrder = []*Stage{
|
||||
// Unwinding of tx pool (reinjecting transactions into the pool needs to happen after unwinding execution)
|
||||
stages[0], stages[1], stages[2], stages[9], stages[3], stages[4], stages[5], stages[6], stages[7], stages[8],
|
||||
}
|
||||
```
|
||||
|
||||
## Preprocessing with [ETL](/common/etl/)
|
||||
|
||||
Some stages use our ETL framework to sort data by keys before inserting it into the database.
|
||||
|
||||
That allows to reduce db write amplification significantly.
|
||||
|
||||
So, when we are generating indexes or hashed state, we do a multi-step process.
|
||||
1. We write the processed data into a couple of temp files in your data directory;
|
||||
2. We and then use a heap to insert data from the temp files them in the order that minimizes db write amplification.
|
||||
|
||||
This optimization sometimes leads to dramatic (orders of magnitude) write speed improvements.
|
||||
|
||||
## Stages (for the up to date list see [`stagedsync.go`](/eth/stagedsync/stagedsync.go)):
|
||||
|
||||
Each stage consists of 2 functions `ExecFunc` that progesses the stage forward and `UnwindFunc` that unwinds the stage backwards.
|
||||
|
||||
Some of the stages can theoretically work offline though it isn't implemented in the current version.
|
||||
|
||||
### Stage 1: Download Headers Stage
|
||||
|
||||
During this stage we download all the headers between the local HEAD and our peer's head.
|
||||
|
||||
This stage is CPU intensive and can benefit from a multicore processor due to verifying PoW of the headers.
|
||||
|
||||
Most of the unwinds are initiated on this stage due to the chain reorgs.
|
||||
|
||||
This stage promotes local HEAD pointer.
|
||||
|
||||
### Stage 2: Download Block Bodies Stage
|
||||
|
||||
At that stage, we download bodies for block headers that we already downloaded.
|
||||
|
||||
That is the most intensive stage for the network connection, the vast majority of data is downloaded here.
|
||||
|
||||
### Stage 3: Recover Senders Stage
|
||||
|
||||
This stage recovers and stores senders for each transaction in each downloaded block.
|
||||
|
||||
This is also a CPU intensive stage and also benefits from multi-core CPUs.
|
||||
|
||||
This stage doesn't use any network connection.
|
||||
|
||||
### Stage 4: Execute Blocks Stage
|
||||
|
||||
During this stage, we execute block-by-block everything that we downloaded before.
|
||||
|
||||
One important point there, that we don't check root hashes during this execution, we don't even build a merkle trie here.
|
||||
|
||||
This stage is single threaded.
|
||||
|
||||
This stage doesn't use internet connection.
|
||||
|
||||
This stage is disk intensive.
|
||||
|
||||
This stage can spawn unwinds if the block execution fails.
|
||||
|
||||
### Stage 5: Compute State Root Stage
|
||||
|
||||
This stage build the Merkle trie and checks the root hash for the current state.
|
||||
|
||||
It also builds Intermediate Hashes along the way and stores them into the database.
|
||||
|
||||
If there were no intermediate hashes stored before (that could happend during the first inital sync), it builds the full Merkle Trie and its root hash.
|
||||
|
||||
If there are intermediate hashes in the database, it uses the block history to figure out which ones are outdated and which ones are still up to date. Then it builds a partial Merkle trie using the up-to-date hashes and only rebuilding the outdated ones.
|
||||
|
||||
If the root hash doesn't match, it initiates an unwind one block backwards.
|
||||
|
||||
This stage doesn't use a network connection.
|
||||
|
||||
### Stage 6: Generate Hashed State Stage
|
||||
|
||||
Turbo-Geth during execution uses Plain state storage.
|
||||
|
||||
> Plain State: Instead of the normal (we call it "Hashed State") where accounts and storage items are addressed as `keccak256(address)`, in the plain state them are addressed by the `address` itself.
|
||||
|
||||
Though, to make sure that some APIs work and keep the compatibility with the other clients, we generate Hashed state as well.
|
||||
|
||||
If the hashed state is not empty, then we are looking at the History ChangeSets and update only the items that were changed.
|
||||
|
||||
This stage doesn't use a network connection.
|
||||
|
||||
### Stages 7, 8, 9: Generate Indexes Stages
|
||||
|
||||
There are 3 indexes that are generated during sync.
|
||||
|
||||
They might be disabled because they aren't used for all the APIs.
|
||||
|
||||
This stage doesn't use a network connection.
|
||||
|
||||
**Tx Lookup Index**
|
||||
|
||||
This index sets up a link from the transaction hash to the block number.
|
||||
|
||||
**Account History Index**
|
||||
|
||||
This index stores the mapping from the account address to the list of blocks where this account was changed in some way.
|
||||
|
||||
**Storage History Index**
|
||||
|
||||
This index stores the mapping from the storage item address to the list of blocks where this storage item was changed in some way.
|
||||
|
||||
### Stage 10: Update transaction pool Stage
|
||||
|
||||
During this stage we start the transaction pool or update its state. For instance, we remove the transactions from the blocks we have downloaded from the pool.
|
||||
|
||||
On unwinds, we add the transactions from the blocks we unwind, back to the pool.
|
||||
|
||||
This stage doesn't use a network connection.
|
Loading…
Reference in New Issue
Block a user