mirror of
https://github.com/status-im/nimbus-eth1.git
synced 2025-02-28 20:00:43 +00:00
38413d25ac
* Remove obsolete header cache why: Was fall back for the case that the DB table was inaccessible before `FC` module reorg. * Add the number of unused connected peers to metric * Update docu, add Grafana example why: Provides useful settings, e.g. for memory debugging * Re-calibrate blocks queue for import why: Old queue setup provided a staging area which was much too large consuming too much idle memory. Also the command-line re-calibrating for debugging was much too complicated. And the naming for the old setup was wrong: There is no max queue size. Rather there is a HWM where filling the queue stops when reached. The currently tested size allows for 1.5k blocks on the queue. * Rename hidden command-line option for debug/re-calibrating blocks queue
80 lines
2.4 KiB
Nim
80 lines
2.4 KiB
Nim
# Nimbus
|
|
# Copyright (c) 2023-2025 Status Research & Development GmbH
|
|
# Licensed under either of
|
|
# * Apache License, version 2.0, ([LICENSE-APACHE](LICENSE-APACHE) or
|
|
# http://www.apache.org/licenses/LICENSE-2.0)
|
|
# * MIT license ([LICENSE-MIT](LICENSE-MIT) or
|
|
# http://opensource.org/licenses/MIT)
|
|
# at your option. This file may not be copied, modified, or distributed
|
|
# except according to those terms.
|
|
|
|
{.push raises: [].}
|
|
|
|
import
|
|
pkg/[chronicles, chronos, eth/p2p, results],
|
|
pkg/stew/[interval_set, sorted_set],
|
|
../core/chain,
|
|
./beacon/[worker, worker_desc, worker/db],
|
|
"."/[sync_desc, sync_sched, protocol]
|
|
|
|
logScope:
|
|
topics = "beacon sync"
|
|
|
|
type
|
|
BeaconSyncRef* = RunnerSyncRef[BeaconCtxData,BeaconBuddyData]
|
|
|
|
# ------------------------------------------------------------------------------
|
|
# Virtual methods/interface, `mixin` functions
|
|
# ------------------------------------------------------------------------------
|
|
|
|
proc runSetup(ctx: BeaconCtxRef): bool =
|
|
worker.setup(ctx, "RunSetup")
|
|
|
|
proc runRelease(ctx: BeaconCtxRef) =
|
|
worker.release(ctx, "RunRelease")
|
|
|
|
proc runDaemon(ctx: BeaconCtxRef) {.async: (raises: []).} =
|
|
await worker.runDaemon(ctx, "RunDaemon")
|
|
|
|
proc runTicker(ctx: BeaconCtxRef) =
|
|
worker.runTicker(ctx, "RunTicker")
|
|
|
|
proc runStart(buddy: BeaconBuddyRef): bool =
|
|
worker.start(buddy, "RunStart")
|
|
|
|
proc runStop(buddy: BeaconBuddyRef) =
|
|
worker.stop(buddy, "RunStop")
|
|
|
|
proc runPool(buddy: BeaconBuddyRef; last: bool; laps: int): bool =
|
|
worker.runPool(buddy, last, laps, "RunPool")
|
|
|
|
proc runPeer(buddy: BeaconBuddyRef) {.async: (raises: []).} =
|
|
await worker.runPeer(buddy, "RunPeer")
|
|
|
|
# ------------------------------------------------------------------------------
|
|
# Public functions
|
|
# ------------------------------------------------------------------------------
|
|
|
|
proc init*(
|
|
T: type BeaconSyncRef;
|
|
ethNode: EthereumNode;
|
|
chain: ForkedChainRef;
|
|
maxPeers: int;
|
|
blockQueueHwm = 0;
|
|
): T =
|
|
var desc = T()
|
|
desc.initSync(ethNode, maxPeers)
|
|
desc.ctx.pool.blocksStagedHwm = blockQueueHwm
|
|
desc.ctx.pool.chain = chain
|
|
desc
|
|
|
|
proc start*(desc: BeaconSyncRef): bool =
|
|
desc.startSync()
|
|
|
|
proc stop*(desc: BeaconSyncRef) {.async.} =
|
|
await desc.stopSync()
|
|
|
|
# ------------------------------------------------------------------------------
|
|
# End
|
|
# ------------------------------------------------------------------------------
|