mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-03 09:37:38 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

added stage 3 documentation to rtd (#1328)

Browse Source
This commit is contained in:
Giulio rebuffo 2020-10-30 23:16:10 +01:00 committed by GitHub
parent ed1819ec58
commit 3d5f7ab892
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 45 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
docs/readthedocs/source/stagedsync.rst
View File

@ -81,4 +81,48 @@ The function above its used with ETL to extract blockHashes and blockNumber from
Changes in DB:
* BlockHash => BlockNumber are written in bucket `dbutils.HeaderNumberPrefix`
* BlockHash => BlockNumber are written in bucket `dbutils.HeaderNumberPrefix`
Stage 3 : Download Block Bodies
===============================
.. code-block:: go
{
ID: stages.Bodies,
Build: func(world StageParameters) *Stage {
return &Stage{
ID: stages.Bodies,
Description: "Download block bodies",
ExecFunc: func(s *StageState, u Unwinder) error {
return spawnBodyDownloadStage(s, u, world.d, world.pid, world.prefetchedBlocks)
},
UnwindFunc: func(u *UnwindState, s *StageState) error {
return unwindBodyDownloadStage(u, world.db)
},
}
},
},
This stage, downloads block bodies and put them into the database. This stage is divided into two processes:
.. code-block:: go
func (d *Downloader) fetchBodies(from uint64) error
func (d *Downloader) processBodiesStage(logPrefix string, to uint64) error
`fetchBodies` downloads the bodies from the peer and decode them from RLP format.
`processBodiesStage` takes the bodies downloaded and those the following with them:
* Verifiy them.
* RLP-encode them.
* compress the rlp-encoded bodies using `snappy`.
* put the commpressed RLP into the database.
in order for turbo-geth to reaccess the block bodies, it decompress the and rlp-decode them. the entries in the db for block bodies are a concatenation of [block number] + [block hash] in order to pre-sort them before inserting them into the database.
Changes in DB:
* [block number] + [block hash] => Block bodies are written in bucket `dbutils.BlockBodyPrefix`