logos-blockchain/logos-blockchain-specs
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-specs.git synced 2026-01-02 13:13:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

comment

Browse Source
This commit is contained in:
Youngjoon Lee 2025-02-28 15:10:06 +09:00
parent 1d38073f6a
commit 974208a1f5
No known key found for this signature in database
GPG Key ID: 303963A54A81DD4D
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
cryptarchia/sync/full_sync.py
View File

@ -6,14 +6,24 @@ SLOT_TOLERANCE = 1
def full_sync(local: Follower, remotes: list[Follower], start_slot: Slot):
# Start a full sync from the remotes to the local, starting from the given slot.
# Sync only with remotes that are at least SLOT_TOLERANCE ahead of the local.
# Continue until there is no target to sync with.
#
# Group the remotes by their tip slot, and sync only with one remote per group.
# This is safe as long as the remote provides all blocks necessary for the future fork choice.
while groups := group_targets(remotes, start_slot):
for _, group in groups.items():
for _tip_id, group in groups.items():
remote = group[0]
range_sync(local, remote, start_slot, remote.tip().slot)
# Update the start_slot to check if the sync should continue.
start_slot = Slot(local.tip().slot.absolute_slot + 1)
def range_sync(local: Follower, remote: Follower, from_slot: Slot, to_slot: Slot):
# Fetch blocks in the given range of slots from the remote and apply them to the local.
# Blocks should be fetched in order of slot.
for block in remote.block_storage.blocks_by_range(from_slot, to_slot):
local.on_block(block)
@ -21,6 +31,8 @@ def range_sync(local: Follower, remote: Follower, from_slot: Slot, to_slot: Slot
def group_targets(
targets: list[Follower], start_slot: Slot
) -> dict[Id, list[Follower]]:
# Group the targets by their tip slot.
# Filter only the targets that are at least SLOT_TOLERANCE ahead of the start_slot.
groups: dict[Id, list[Follower]] = defaultdict(list)
for target in targets:
if target.tip().slot.absolute_slot - start_slot.absolute_slot > SLOT_TOLERANCE: