mirror of
https://github.com/status-im/nimbus-eth1.git
synced 2025-01-21 09:39:09 +00:00
71e466d173
* Block header download starting at Beacon down to Era1 details: The header download implementation is intended to be completed to a full sync facility. Downloaded block headers are stored in a `CoreDb` table. Later on they should be fetched, complemented by a block body, executed/imported, and deleted from the table. The Era1 repository may be partial or missing. Era1 headers are neither downloaded nor stored on the `CoreDb` table. Headers are downloaded top down (largest block number first) using the hash of the block header by one peer. Other peers fetch headers opportunistically using block numbers Observed download times for 14m `MainNet` headers varies between 30min and 1h (Era1 size truncated to 66m blocks.), full download 52min (anectdotal.) The number of peers downloading concurrently is crucial here. * Activate `flare` by command line option * Fix copyright year
139 lines
4.5 KiB
Nim
139 lines
4.5 KiB
Nim
# Nimbus
|
|
# Copyright (c) 2023-2024 Status Research & Development GmbH
|
|
# Licensed and distributed under either of
|
|
# * MIT license (license terms in the root directory or at
|
|
# https://opensource.org/licenses/MIT).
|
|
# * Apache v2 license (license terms in the root directory or at
|
|
# https://www.apache.org/licenses/LICENSE-2.0).
|
|
# at your option. This file may not be copied, modified, or distributed
|
|
# except according to those terms.
|
|
|
|
{.push raises:[].}
|
|
|
|
import
|
|
pkg/bearssl/rand,
|
|
pkg/chronicles,
|
|
pkg/eth/[common, p2p],
|
|
../../protocol,
|
|
../worker_desc,
|
|
"."/[staged, unproc]
|
|
|
|
when enableTicker:
|
|
import ./start_stop/ticker
|
|
|
|
logScope:
|
|
topics = "flare start/stop"
|
|
|
|
const extraTraceMessages = false or true
|
|
## Enabled additional logging noise
|
|
|
|
# ------------------------------------------------------------------------------
|
|
# Private functions
|
|
# ------------------------------------------------------------------------------
|
|
|
|
when enableTicker:
|
|
proc tickerUpdater(ctx: FlareCtxRef): TickerFlareStatsUpdater =
|
|
## Legacy stuff, will be probably be superseded by `metrics`
|
|
result = proc: auto =
|
|
TickerFlareStats(
|
|
base: ctx.layout.base,
|
|
least: ctx.layout.least,
|
|
final: ctx.layout.final,
|
|
beacon: ctx.lhc.beacon.header.number,
|
|
nStaged: ctx.stagedChunks(),
|
|
stagedTop: ctx.stagedTop(),
|
|
unprocTop: ctx.unprocTop(),
|
|
nUnprocessed: ctx.unprocTotal(),
|
|
nUnprocFragm: ctx.unprocChunks(),
|
|
reorg: ctx.pool.nReorg)
|
|
|
|
proc updateBeaconHeaderCB(ctx: FlareCtxRef): SyncReqNewHeadCB =
|
|
## Update beacon header. This function is intended as a call back function
|
|
## for the RPC module.
|
|
when extraTraceMessages:
|
|
var count = 0
|
|
result = proc(h: BlockHeader) {.gcsafe, raises: [].} =
|
|
if ctx.lhc.beacon.header.number < h.number:
|
|
when extraTraceMessages:
|
|
if count mod 77 == 0: # reduce some noise
|
|
trace "updateBeaconHeaderCB", blockNumber=("#" & $h.number), count
|
|
count.inc
|
|
ctx.lhc.beacon.header = h
|
|
ctx.lhc.beacon.changed = true
|
|
|
|
# ------------------------------------------------------------------------------
|
|
# Public functions
|
|
# ------------------------------------------------------------------------------
|
|
|
|
when enableTicker:
|
|
proc setupTicker*(ctx: FlareCtxRef) =
|
|
## Helper for `setup()`: Start ticker
|
|
ctx.pool.ticker = TickerRef.init(ctx.tickerUpdater)
|
|
|
|
proc destroyTicker*(ctx: FlareCtxRef) =
|
|
## Helper for `release()`
|
|
ctx.pool.ticker.destroy()
|
|
ctx.pool.ticker = TickerRef(nil)
|
|
|
|
else:
|
|
template setupTicker*(ctx: FlareCtxRef) = discard
|
|
template destroyTicker*(ctx: FlareCtxRef) = discard
|
|
|
|
# ---------
|
|
|
|
proc setupRpcMagic*(ctx: FlareCtxRef) =
|
|
## Helper for `setup()`: Enable external pivot update via RPC
|
|
ctx.chain.com.syncReqNewHead = ctx.updateBeaconHeaderCB
|
|
|
|
proc destroyRpcMagic*(ctx: FlareCtxRef) =
|
|
## Helper for `release()`
|
|
ctx.chain.com.syncReqNewHead = SyncReqNewHeadCB(nil)
|
|
|
|
# ---------
|
|
|
|
proc startBuddy*(buddy: FlareBuddyRef): bool =
|
|
## Convenience setting for starting a new worker
|
|
let
|
|
ctx = buddy.ctx
|
|
peer = buddy.peer
|
|
if peer.supports(protocol.eth) and peer.state(protocol.eth).initialized:
|
|
ctx.pool.nBuddies.inc # for metrics
|
|
when enableTicker:
|
|
ctx.pool.ticker.startBuddy()
|
|
return true
|
|
|
|
proc stopBuddy*(buddy: FlareBuddyRef) =
|
|
buddy.ctx.pool.nBuddies.dec # for metrics
|
|
when enableTicker:
|
|
buddy.ctx.pool.ticker.stopBuddy()
|
|
|
|
# ---------
|
|
|
|
proc flipCoin*(ctx: FlareCtxRef): bool =
|
|
## This function is intended to randomise recurrent buddy processes. Each
|
|
## participant fetches a vote via `getVote()` and continues on a positive
|
|
## vote only. The scheduler will then re-queue the participant.
|
|
##
|
|
if ctx.pool.tossUp.nCoins == 0:
|
|
result = true
|
|
else:
|
|
if ctx.pool.tossUp.nLeft == 0:
|
|
ctx.pool.rng[].generate(ctx.pool.tossUp.coins)
|
|
ctx.pool.tossUp.nLeft = 8 * sizeof(ctx.pool.tossUp.coins)
|
|
ctx.pool.tossUp.nCoins.dec
|
|
ctx.pool.tossUp.nLeft.dec
|
|
result = bool(ctx.pool.tossUp.coins and 1)
|
|
ctx.pool.tossUp.coins = ctx.pool.tossUp.coins shr 1
|
|
|
|
proc setCoinTosser*(ctx: FlareCtxRef; nCoins = 8u) =
|
|
## Create a new sequence of `nCoins` oracles.
|
|
ctx.pool.tossUp.nCoins = nCoins
|
|
|
|
proc resCoinTosser*(ctx: FlareCtxRef) =
|
|
## Set up all oracles to be `true`
|
|
ctx.pool.tossUp.nCoins = 0
|
|
|
|
# ------------------------------------------------------------------------------
|
|
# End
|
|
# ------------------------------------------------------------------------------
|