status-im
/
nimbus-eth2
mirror of https://github.com/status-im/nimbus-eth2.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

ncli_db pruneDatabase checkpointing; remove onSlotEnd lookaheadTime

This commit is contained in:
Dustin Brody 2021-03-12 18:13:26 +01:00 committed by zah
parent 6533999c82
commit 97504fdb9d
3 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
beacon_chain/nimbus_beacon_node.nim
View File

@ -928,12 +928,9 @@ proc onSlotEnd(node: BeaconNode, slot: Slot) {.async.} =
node.db.checkpoint() node.db.checkpoint()
let let
horizonSlot = compute_start_slot_at_epoch(
node.attestationSubnets.lastCalculatedAttestationEpoch + 1) - 1
nextAttestationSlot = node.getNextAttestation(slot) nextAttestationSlot = node.getNextAttestation(slot)
nextActionWaitTime = nextActionWaitTime =
saturate(fromNow(node.beaconClock, nextAttestationSlot)) saturate(fromNow(node.beaconClock, nextAttestationSlot))
horizonDistance = saturate(fromNow(node.beaconClock, horizonSlot))
info "Slot end", info "Slot end",
slot = shortLog(slot), slot = shortLog(slot),
@ -948,8 +945,7 @@ proc onSlotEnd(node: BeaconNode, slot: Slot) {.async.} =
if nextAttestationSlot == FAR_FUTURE_SLOT: if nextAttestationSlot == FAR_FUTURE_SLOT:
"n/a" "n/a"
else: else:
shortLog(nextActionWaitTime), shortLog(nextActionWaitTime)
lookaheadTime = shortLog(horizonDistance)
if nextAttestationSlot != FAR_FUTURE_SLOT: if nextAttestationSlot != FAR_FUTURE_SLOT:
next_action_wait.set(nextActionWaitTime.toFloatSeconds) next_action_wait.set(nextActionWaitTime.toFloatSeconds)

1
ncli/ncli_db.nim
View File

@ -234,6 +234,7 @@ proc copyPrunedDatabase(
for signedBlock in getAncestors(db, headBlock.get): for signedBlock in getAncestors(db, headBlock.get):
if not dry_run: if not dry_run:
copyDb.putBlock(signedBlock) copyDb.putBlock(signedBlock)
copyDb.checkpoint()
if verbose: if verbose:
echo "copied block at slot ", signedBlock.message.slot echo "copied block at slot ", signedBlock.message.slot

2
tests/test_sync_manager.nim
View File

@ -2,7 +2,7 @@
import unittest import unittest
import chronos import chronos
import ../beacon_chain/gossip_processing/[eth2_processor, gossip_to_consensus], import ../beacon_chain/gossip_processing/gossip_to_consensus,
../beacon_chain/sync/sync_manager ../beacon_chain/sync/sync_manager
type type