logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-05-13 05:49:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

kad loop interval conf

Browse Source
This commit is contained in:
SionoiS 2026-03-26 07:37:45 -04:00
parent 70bbcf8765
commit 2d914251d2
No known key found for this signature in database
GPG Key ID: C9458A8CB1852951
2 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
vendor/nim-libp2p vendored

@ -1 +1 @@
Subproject commit 687bbb64d48b976fd63dc4f3df4cd7f562cff586
Subproject commit 571abb7285a645085b50cffbedcf83d91cf8fab9

12
waku/discovery/waku_kademlia.nim
View File

@ -24,6 +24,7 @@ const DefaultKademliaDiscoveryInterval* = chronos.seconds(10)
type WakuKademlia* = ref object
protocol*: KademliaDiscovery
peerManager: PeerManager
loopInterval: Duration
walkIntervalFut: Future[void]
proc toRemotePeerInfo(record: ExtendedPeerRecord): Option[RemotePeerInfo] =
@ -128,6 +129,7 @@ proc new*(
peerManager: PeerManager,
bootstrapNodes: seq[(PeerId, seq[MultiAddress])],
providedServices: var seq[ServiceInfo],
loopInterval: Duration = DefaultKademliaDiscoveryInterval,
): T =
if bootstrapNodes.len == 0:
debug "creating kademlia discovery as seed node (no bootstrap nodes)"
@ -141,11 +143,11 @@ proc new*(
services = providedServices,
)
return WakuKademlia(protocol: kademlia, peerManager: peerManager)
return WakuKademlia(
protocol: kademlia, peerManager: peerManager, loopInterval: loopInterval
)
proc start*(
self: WakuKademlia, interval: Duration = DefaultKademliaDiscoveryInterval
) {.async.} =
proc start*(self: WakuKademlia) {.async.} =
if self.protocol.started:
warn "Starting waku kad twice"
return
@ -154,7 +156,7 @@ proc start*(
await self.protocol.start()
self.walkIntervalFut = self.runDiscoveryLoop(interval)
self.walkIntervalFut = self.runDiscoveryLoop(self.loopInterval)
info "Waku Kademlia Started"