logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-05-12 06:19:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: re-seed DHT routing table when empty

Browse Source 
Part of https://github.com/logos-storage/logos-storage-nim/issues/1427

Signed-off-by: Chrysostomos Nanakos <chris@include.gr>
This commit is contained in:
Chrysostomos Nanakos 2026-04-29 17:24:14 +03:00
parent bb6ab1befa
commit 0ba5844242
No known key found for this signature in database
1 changed files with 33 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
storage/blockexchange/engine/discovery.nim
View File

@ -30,6 +30,7 @@ declareGauge(storage_inflight_discovery, "inflight discovery requests")
const
DefaultConcurrentDiscRequests = 10
DefaultDiscoveryTimeout = 1.minutes
RoutingTableHealthInterval = 30.seconds
type DiscoveryEngine* = ref object of RootObj
localStore*: BlockStore # Local block store for this instance
@ -79,6 +80,33 @@ proc discoveryTaskLoop(b: DiscoveryEngine) {.async: (raises: []).} =
info "Exiting discovery task runner"
proc routingTableHealthLoop(b: DiscoveryEngine) {.async: (raises: []).} =
## Re-seed the DHT routing table from the configured bootstrap records when
## it goes empty.
try:
while b.discEngineRunning:
await sleepAsync(RoutingTableHealthInterval)
if b.discovery.protocol.nodesDiscovered() != 0:
continue
warn "Routing table empty, re-seeding from bootstrap records",
bootstrap = b.discovery.protocol.bootstrapRecords.len
b.discovery.protocol.seedTable()
try:
await b.discovery.protocol.populateTable()
debug "Routing table re-populated",
total = b.discovery.protocol.nodesDiscovered()
except CancelledError:
return
except CatchableError as exc:
warn "Failed to re-populate routing table", exc = exc.msg
except CancelledError:
trace "Routing table health loop cancelled"
return
proc queueFindBlocksReq*(b: DiscoveryEngine, cids: seq[Cid]) =
for cid in cids:
if cid notin b.discoveryQueue:
@ -102,6 +130,11 @@ proc start*(b: DiscoveryEngine) {.async: (raises: []).} =
let fut = b.discoveryTaskLoop()
b.trackedFutures.track(fut)
if not b.discovery.protocol.isNil and b.discovery.protocol.bootstrapRecords.len > 0:
b.trackedFutures.track(b.routingTableHealthLoop())
else:
trace "No bootstrap records configured, routing table health watchdog disabled"
trace "Discovery engine started"
proc stop*(b: DiscoveryEngine) {.async: (raises: []).} =